Spring Boot与ActiveMQ整合
spring boot与activemq整合
1使用内嵌服务
(1)在pom.xml中引入activemq起步依赖
<dependency> <groupid>org.springframework.boot</groupid> <artifactid>spring-boot-starter-activemq</artifactid> </dependency> |
(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); } } |
测试:启动服务后,在浏览器执行
.do?text=aaaaa
即可看到控制台输出消息提示。spring boot内置了activemq的服务,所以我们不用单独启动也可以执行应用程序。
2使用外部服务
在src/main/resources下的application.properties增加配置, 指定activemq的地址
spring.activemq.broker-url=tcp://192.168.25.135:61616 |
运行后,会在activemq中看到发送的queue,如下图:
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); } |
推荐阅读
-
Spring Boot与Docker部署实践
-
Spring Boot整合ElasticSearch实现多版本兼容的方法详解
-
Spring Boot 与 kotlin 使用Thymeleaf模板引擎渲染web视图的方法
-
Spring Boot整合mybatis并自动生成mapper和实体实例解析
-
spring boot整合CAS Client实现单点登陆验证的示例
-
spring boot整合quartz实现多个定时任务的方法
-
spring boot+vue 的前后端分离与合并方案实例详解
-
spring-boot整合ehcache实现缓存机制的方法
-
spring boot整合spring-kafka实现发送接收消息实例代码
-
Spring Boot 中application.yml与bootstrap.yml的区别