本文介绍了spring boot整合JMS(ActiveMQ实现),分享给大家,也给自己留个学习笔记。
一、安装ActiveMQ
具体的安装步骤,请参考我的另一篇文章:
二、新建spring boot工程,并加入JMS(ActiveMQ)依赖
三、工程结构
pom依赖如下:
<?xml version="1.0" encoding="UTF-8"?> <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://.chhliu.springboot.jms; import javax.jms.Destination; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.jms.annotation.JmsListener; import org.springframework.jms.core.JmsMessagingTemplate; import org.springframework.stereotype.Service; @Service("producer") public class Producer { @Autowired private JmsMessagingTemplate jmsTemplate; public void sendMessage(Destination destination, final String message){ jmsTemplate.convertAndSend(destination, message); } @JmsListener(destination="out.queue") public void consumerMessage(String text){ System.out.println("从out.queue队列收到的回复报文为:"+text); } }
测试结果如下:
从out.queue队列收到的回复报文为:return messagemyname is chhliu!!! Consumer收到的报文为:myname is chhliu!!! Consumer2收到的报文为:myname is chhliu!!! 从out.queue队列收到的回复报文为:return messagemyname is chhliu!!! Consumer收到的报文为:myname is chhliu!!! Consumer2收到的报文为:myname is chhliu!!! 从out.queue队列收到的回复报文为:return messagemyname is chhliu!!! Consumer收到的报文为:myname is chhliu!!! Consumer2收到的报文为:myname is chhliu!!! 从out.queue队列收到的回复报文为:return messagemyname is chhliu!!!
以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持。