Spring Boot与ActiveMQ整合的步骤
程序员文章站
2024-02-23 21:40:10
1.1使用内嵌服务
(1)在pom.xml中引入activemq起步依赖
org.sp...
1.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); } }
测试:启动服务后,在浏览器执行即可看到控制台输出消息提示。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); }
总结
以上就是这篇文章的全部内容了,希望本文的内容对大家的学习或者工作具有一定的参考学习价值,谢谢大家对的支持。如果你想了解更多相关内容请查看下面相关链接
上一篇: 简单谈谈Mysql索引与redis跳表
推荐阅读
-
Spring Boot与ActiveMQ整合的步骤
-
spring boot项目打包成war在tomcat运行的全步骤
-
Spring Boot整合elasticsearch的详细步骤
-
Spring Boot整合MyBatis连接Oracle数据库的步骤全纪录
-
Springboot整合activemq的方法步骤
-
Spring boot 默认静态资源路径与手动配置访问路径的方法
-
详解基于Spring Boot与Spring Data JPA的多数据源配置
-
Spring + Spring Boot + MyBatis + MongoDB的整合教程
-
Spring Boot实现STOMP协议的WebSocket的方法步骤
-
消息队列 RabbitMQ 与 Spring 整合使用的实例代码