SpringBoot与ActiveMQ整合的步骤
1.1使用内嵌服务
成都创新互联坚持“要么做到,要么别承诺”的工作理念,服务领域包括:成都网站制作、成都网站设计、外贸营销网站建设、企业官网、英文网站、手机端网站、网站推广等服务,满足客户于互联网时代的陵城网站设计、移动媒体设计的需求,帮助企业找到有效的互联网解决方案。努力成为您成熟可靠的网络建设合作伙伴!
(1)在pom.xml中引入ActiveMQ起步依赖
org.springframework.boot spring-boot-starter-activemq
(2)创建消息生产者
/** * 消息生产者 * @author Administrator **/ @RestController public class QueueController { @Autowired private JmsMessagingTemplate jmsMessagingTemplate; @RequestMapping("/send") public void send(String text){ jmsMessagingTemplate.convertAndSend("itcast", text); } }
(3)创建消息消费者
@Component public class Consumer { @JmsListener(destination="itcast") public void readMessage(String text){ System.out.println("接收到消息:"+text); } }
测试:启动服务后,在浏览器执行http://localhost:8088/send.do?text=aaaaa即可看到控制台输出消息提示。Spring Boot内置了ActiveMQ的服务,所以我们不用单独启动也可以执行应用程序。
1.2使用外部服务
在src/main/resources下的application.properties增加配置, 指定ActiveMQ的地址spring.activemq.broker-url=tcp://192.168.25.135:61616
运行后,会在activeMQ中看到发送的queue
1.3.3发送Map信息
(1)修改QueueController.java
@RequestMapping("/sendmap") public void sendMap(){ Map map=new HashMap<>(); map.put("mobile", "13900001111"); map.put("content", "恭喜获得10元代金券"); jmsMessagingTemplate.convertAndSend("itcast_map",map); }
(2)修改Consumer.java
@JmsListener(destination="itcast_map") public void readMap(Map map){ System.out.println(map); }
总结
以上就是这篇文章的全部内容了,希望本文的内容对大家的学习或者工作具有一定的参考学习价值,谢谢大家对创新互联的支持。如果你想了解更多相关内容请查看下面相关链接
文章名称:SpringBoot与ActiveMQ整合的步骤
当前路径:http://scyanting.com/article/jscgig.html