一、创建项目并导入依赖

? ?

<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）测试

? ?

? ?

SpringBoot整合ActiveMQ

原文：https://www.cnblogs.com/fernfei/p/12210926.html