本文共 1627 字,大约阅读时间需要 5 分钟。
1、在pom.xml文件中引入以下依赖:
org.springframework.boot spring-boot-starter-activemq
2、在文件下创建Producter和Consumer:
@RestControllerpublic class Producter { @Autowired private JmsMessagingTemplate jmsMessagingTemplate; @RequestMapping("/send") public void sendMessage(String text) { jmsMessagingTemplate.convertAndSend("xhy",text); }}
消费者Consumer代码如下:
@Componentpublic class Consumer { @JmsListener(destination = "xhy") public void receiveMessage(String text) { System.out.println("接收到消息"+text); }}
4、测试:启动服务后,在浏览器执行如下:
http://localhost:8081/send?text=aaaa
1、需要在操作系统上安装ActiveMQ,本次测试使用wind版,首先下载MQ的安装包:
http://activemq.apache.org/download.html
启动activeMq:我们用windows命令行模式启动,window + R,输入cmd打开命令窗口,进入到bin目录,然后运行如下启动命令:
activemq start
关闭:
activemq stop
然后浏览器地址栏输入
http://localhost:8161/admin
默认用户名密码为admin、admin,这个用户名密码可以再conf/users.properties中自行修改配置;
2、启动成功后,在application.properties配置文件中配置如下内容:
spring.activemq.broker-url=tcp://localhost:61616
3、然后Producter中添加如下方法:
@RequestMapping("/sendMap") public void sendMap() { Map map = new HashMap<>(); map.put("name","xhy"); map.put("content","恭喜获得10元代金券"); jmsMessagingTemplate.convertAndSend("xhy_map",map); }
Consumer中添加如下方法:
@JmsListener(destination = "xhy_map") public void receiveMap(Map map) { System.out.println(map); }
4、浏览器输入以下内容:
http://localhost:8081/sendMap
在amq中可以查看到消息消费的信息:
https://github.com/xhy12306/SpringBoot2.0
如需获取更多关于SpringBoot、SpringCloud学习资料关注下面公众号,后台回复SpringBoot关键字即可领取。
转载地址:http://csse.baihongyu.com/