SpringBoot整合ActiveMQ

一、创建项目并导入依赖

   

<dependency>

<groupId>org.springframework.boot</groupId>

<artifactId>spring-boot-starter-activemq</artifactId>

</dependency>

<dependency>

<groupId>org.springframework.boot</groupId>

<artifactId>spring-boot-starter-web</artifactId>

</dependency>

   

二、相关配置和代码

   

2.1）application.properties

   

spring.activemq.broker-url=tcp://192.168.21.136:61616

#发消息的时候可以是字符串也可以是对象，如果是对象就需要设置为true

spring.activemq.packages.trust-all=true

spring.activemq.user=admin

spring.activemq.password=admin

   

2.2）创建ActiveMQConfig配置

   

@Component

public class ActiveMQConfig{

@Bean

Queuequeue(){

//消息服务的名字|方便根据名字接受

return new ActiveMQQueue("hello.fernfei");

}

}

   

2.3）创建JmsComponet用于收发消息

注：我这里为了方便收发写在一起，真实业务收发各一个项目

   

@Component

public class JmsComponent{

@Autowired

JmsMessagingTemplate jmsMessagingTemplate;//SpringBoot提供的操作activemq模板

@Autowired

Queuequeue;

   

public void send(Message msg){

//第一个参数是目标，第二个是信息

jmsMessagingTemplate.convertAndSend(queue,msg);

   

}

//根据这个目标去监听

@JmsListener(destination="hello.fernfei")

public void receive(Messagemsg){

System.out.println(msg);

}

}

   

2.4）bean Message存储信息的类

   

   

2.5）测试