java spring boot jms_spring boot整合JMS(ActiveMQ实现)
一、安装ActiveMQ
具体的安装步骤,请参考我的另一篇博文:
二、新建spring boot工程,并加入JMS(ActiveMQ)依赖
三、工程结构
pom依赖如下:
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
4.0.0
com.chhliu.springboot.jms
springboot-jms
0.0.1-SNAPSHOT
jar
springboot-jms
Demo project for Spring Boot Jms
org.springframework.boot
spring-boot-starter-parent
1.4.3.RELEASE
UTF-8
UTF-8
1.7
org.springframework.boot
spring-boot-starter-activemq
org.springframework.boot
spring-boot-starter-test
test
org.springframework.boot
spring-boot-maven-plugin
四、修改application.properties配置文件
## URL of the ActiveMQ broker. Auto-generated by default. For instance `tcp://localhost:61616`
# failover:(tcp://localhost:61616,tcp://localhost:61617)
# tcp://localhost:61616
spring.activemq.broker-url=tcp://localhost:61616
spring.activemq.in-memory=true
spring.activemq.pool.enabled=false
五、消息生产者
package com.chhliu.springboot.jms;
import javax.jms.Destination;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.jms.core.JmsMessagingTemplate;
import org.springframework.stereotype.Service;
@Service("producer")
public class Producer {
@Autowired // 也可以注入JmsTemplate,JmsMessagingTemplate对JmsTemplate进行了封装
private JmsMessagingTemplate jmsTemplate;
// 发送消息,destination是发送到的队列,message是待发送的消息
public void sendMessage(Destination destination, final String message){
jmsTemplate.convertAndSend(destination, message);
}
}
六、消息消费者
package com.chhliu.springboot.jms;
import org.springframework.jms.annotation.JmsListener;
import org.springframework.stereotype.Component;
@Component
public class Consumer {
// 使用JmsListener配置消费者监听的队列,其中text是接收到的消息
@JmsListener(destination = "mytest.queue")
public void receiveQueue(String text) {
System.out.println("Consumer收到的报文为:"+text);
}
}
消费者2的代码同上,注意,消息消费者的类上必须加上@Component,或者是@Service,这样的话,消息消费者类就会被委派给Listener类,原理类似于使用SessionAwareMessageListener以及MessageListenerAdapter来实现消息驱动POJO
七、测试
package com.chhliu.springboot.jms;
import javax.jms.Destination;
import org.apache.activemq.command.ActiveMQQueue;
import org.junit.Test;
import org.junit.runner.RunWith;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;
import org.springframework.test.context.junit4.SpringRunner;
@RunWith(SpringRunner.class)
@SpringBootTest
public class SpringbootJmsApplicationTests {
@Autowired
private Producer producer;
@Test
public void contextLoads() throws InterruptedException {
Destination destination = new ActiveMQQueue("mytest.queue");
for(int i=0; i<100; i++){
producer.sendMessage(destination, "myname is chhliu!!!");
}
}
}
测试结果如下:
Consumer2收到的报文为:myname is chhliu!!!
Consumer收到的报文为:myname is chhliu!!!
Consumer2收到的报文为:myname is chhliu!!!
Consumer收到的报文为:myname is chhliu!!!
Consumer2收到的报文为:myname is chhliu!!!
Consumer收到的报文为:myname is chhliu!!!
Consumer2收到的报文为:myname is chhliu!!!
Consumer收到的报文为:myname is chhliu!!!
Consumer2收到的报文为:myname is chhliu!!!
Consumer收到的报文为:myname is chhliu!!!
Consumer2收到的报文为:myname is chhliu!!!
Consumer收到的报文为:myname is chhliu!!!
Consumer2收到的报文为:myname is chhliu!!!
经过上面的几个步骤,spring boot和Jms就基本上整合完成了,是不是使用起来很方便了!
八、实现双向队列
1、下面首先来对Consumer2这个消费者来进行下改造,代码如下:
package com.chhliu.springboot.jms;
import org.springframework.jms.annotation.JmsListener;
import org.springframework.messaging.handler.annotation.SendTo;
import org.springframework.stereotype.Component;
@Component
public class Consumer2 {
@JmsListener(destination = "mytest.queue")
@SendTo("out.queue")
public String receiveQueue(String text) {
System.out.println("Consumer2收到的报文为:"+text);
return "return message"+text;
}
}
从上面的代码可以看出,我们在receiveQueue方法上面多加了一个注解@SendTo("out.queue"),该注解的意思是将return回的值,再发送的"out.queue"队列中,下面我们再来跑一下前面的测试,在监控页面中,我们发现,"out.queue"队列中已经有内容了,如下:
进入Browse界面观看:
最后看下收到的具体信息:
我们发现,该队列中的消息,就是我们返回的值!
九、对Producer进行改造
通过上面的示例,我们现在对Producer进行改造,使其既能生产报文,又能消费队列中的报文,代码如下:
package com.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!!!
java spring boot jms_spring boot整合JMS(ActiveMQ实现)相关推荐
- easyui结合java,Spring+SpringMVC+MyBatis+easyUI整合基础篇(二)牛刀小试
推荐文章 1.在没有安装有mvc3的主机上部署asp.net mvc3网站,需要包含的DLL文件. microsoft.web.infrastructure.dll system.web.helper ...
- java spring hiberate_Spring+SpringMVC+Hibernate整合实例讲解
使用Maven构建项目,用pom.xml引入相应jar,配置以下文件 创建spring.xml: xmlns="http://www.springframework.org/schema/b ...
- Spring Boot 与消息 (JMS、AMQP、RabbitMQ)
RabbitMQ教程 - 鸟哥的专栏 - CSDN博客 一.概述 大多应用中,可通过消息服务中间件来提升系统异步通信.扩展解耦能力 消息服务中两个重要概念: 消息代理(message broker)和 ...
- java 模板引擎_Spring Boot 如何快熟整合Thymeleaf模板引擎
前面介绍了Spring Boot的优点,然后介绍了如何快速创建Spring Boot 项目.不清楚的朋友可以看看之前的文章:https://www.cnblogs.com/zhangweizhong/ ...
- Spring整合JMS——基于ActiveMQ实现(一)
Spring整合JMS--基于ActiveMQ实现(一) 1.1 JMS简介 JMS的全称是Java Message Service,即Java消息服务.它主要用于在生产者和消费者之间进行消息 ...
- spring boot使用Jedis整合Redis
文章目录 spring boot使用jedis整合redis 总结 Spring Boot整合Redis有两种方式,分别是Jedis和RedisTemplate,那么它们二者有什么区别呢? 1.Jed ...
- 【校招VIP】Java Spring之spring boot
考点介绍: Spring Boot在校招面试中是高频考点,Spring Boot是由Pivotal团队提供的全新框架,其设计目的是用来简化新Spring应用的初始搭建以及开发过程.该框架使用了特定的方 ...
- Java+Spring Boot 二手书交易系统
目录 1 系统简介 2 系统相关技术 2.1 Java EE 2.2 Springboot框架 2.3 Maven技术 2.4 Tomcat服务器 2.5 MySQL 3 需求分析 3.1 需求概述 ...
- Spring Boot 2.x整合Quartz
宣传官网 xb.exrick.cn 在线Demo xboot.exrick.cn 开源版Github地址 github.com/Exrick/x-bo- 开发文档 www.kancloud.cn/ex ...
最新文章
- mysql5.7.20安装红黑_Window环境安装MySQLServer5.7.21
- linux目录统计编程,linux系统编程----统计一个目录下的普通文件个数
- python中 getnode用法_node.js 爬虫入门总结
- 一亿小目标成就_成就卓越的一种方式:自我选择
- PaperNotes(7)-GANs模式坍塌/训练不稳定
- Ubuntu Touch OTA-12 发布,Ubuntu 移动版本
- 怎么潜入别人家_小学生发明防雾口罩,别人家的孩子是怎么养成的?
- c# contains方法_C#/.Net Core/WPF框架初建(国际化、主题色)
- 李飞飞等6名华人入选ACM 2018 Fellow,无国内学者入选
- logstash mysql 准实时同步到 elasticsearch
- SPOJ 104 Highways(最小生成树计数)
- 《软件设计师》考点分布
- linux配置和查看dns三种方式 Non-authoritative answer
- 判断身份证:要么是15位,要么是18位,最后一位可以为字母,并写程序提出其中的年月日
- input number 数字输入限制,最大值最小值输入范围限制
- has text relocations
- 米家扫拖一体机器人重置键_如何评价小米米家扫拖一体机器人?
- java utill scanner_java.util.Scanner应用详解 转
- 华工计算机组成原理试卷,华工 2014计算机组成原理 作业答案
- 常网小站 骗子网站 大家小心别上当
热门文章
- access 升迁 mysql_随说秋色园从Access升迁到MSSQL过程
- 深度学习和机器学习之间的区别
- android 播放器 音乐,音乐我最行 七款Android播放器大比拼
- xmind 8 pro Mac破解版(思维导图) 附xmind 8 序列号
- 织梦Dedecms错误警告:连接数据库失败,可能数据库密码不对
- python 根据word生成ppt_python 生成 word、ppt 操作源码分享
- c++飞扬的小鸟1.0正式版
- 单总线协议(1—wire)
- 腾讯云大老亲码“Spring深度笔记”,不讲一句废话,全是精华
- linux运行python