1.引入依赖

org.springframework.boot
spring-boot-starter-parent
1.5.3.RELEASE

org.springframework.boot
spring-boot-starter-activemq

2.修改配置文件（其实配置也是默认值，不配置也可以）
spring.activemq.in-memory=true
spring.activemq.pool.enabled=false
3.添加ActiveMq连接池（如果不开启连接池，则每发送一条数据创建一个连接）
①.添加依赖

org.apache.activemq
activemq-pool

②.修改配置文件

4.添加JMS相关配置
①.开启JMS扫描注解：@EnableJms 相当于application.xml中的
②.配置Queue类：
@Bean
public Queue queue() {
return new ActiveMQQueue(“queueName1”);
}
③.创建生产者:
@Resource
JmsMessagingTemplate jmsMessagingTemplate;
public void sendMessage(Destination destination, String message) {
jmsMessagingTemplate.convertAndSend(destination, message);
}
④.创建消费者：
@JmsListener(destination = “queueName1”)
public void receiveQueue(String message) {
System.out.println(“=========接受到了消息:” + message);
grabService.addSearchContent(message, mainConfig.getCharset());
}
ps:@JmsListener(destination = “queueName1”)注解用于监听指定名称的消息
参数message代表具体的消息

版权声明：本文为zhangsansan原创文章，遵循 CC 4.0 BY-SA 版权协议，转载请附上原文出处链接和本声明。
本文链接：https://www.cnblogs.com/zhangsansan/p/10597569.html