脚本之家 服务器常用软件
快捷导航
您的位置：首页 → 软件编程 → java → spring boot与activemq整合

Spring Boot与ActiveMQ整合的步骤

 更新时间：2019年01月14日 10:08:50   作者：qq_43193797  
今天小编就为大家分享一篇关于Spring Boot与ActiveMQ整合的步骤，小编觉得内容挺不错的，现在分享给大家，具有很好的参考价值，需要的朋友一起跟随小编来看看吧

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);
 } 
}

测试：启动服务后，在浏览器执行http://localhost:8088/send.do?text=aaaaa即可看到控制台输出消息提示。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); 
 }

总结

以上就是这篇文章的全部内容了，希望本文的内容对大家的学习或者工作具有一定的参考学习价值，谢谢大家对脚本之家的支持。如果你想了解更多相关内容请查看下面相关链接

您可能感兴趣的文章:

相关文章

  • Java中流的有关知识点详解

    Java中流的有关知识点详解

    今天小编就为大家分享一篇关于Java中流的有关知识点详解，小编觉得内容挺不错的，现在分享给大家，具有很好的参考价值，需要的朋友一起跟随小编来看看吧
    2019-01-01
  • Java concurrency之AtomicLong原子类_动力节点Java学院整理

    Java concurrency之AtomicLong原子类_动力节点Java学院整理

    AtomicLong是作用是对长整形进行原子操作。下面通过本文给大家介绍Java concurrency之AtomicLong原子类的相关知识，感兴趣的朋友一起看看吧
    2017-06-06
  • java实现停车场系统

    java实现停车场系统

    这篇文章主要为大家详细介绍了java实现停车场系统，文中示例代码介绍的非常详细，具有一定的参考价值，感兴趣的小伙伴们可以参考一下
    2020-11-11
  • Java Scala之面向对象

    Java Scala之面向对象

    Scala是一门面向对象的语言。在Scala中，一切皆为对象函数是对象，数字也是对象，本文详细介绍了Scala面向对象的原理和介绍，感兴趣的小伙伴可以参考一下
    2023-04-04
  • java中实现token过期失效超时

    java中实现token过期失效超时

    在Java应用程序中,为了确保安全性和保护用户数据,一种常见的做法是使用Token进行身份验证和授权,Token是由服务器生成的具有一定时效的令牌,用于识别和验证用户身份,当Token失效后,用户将无法再进行相关操作,从而提高系统的安全性
    2023-10-10
  • Java下变量大小写驼峰、大小写下划线、大小写连线转换

    Java下变量大小写驼峰、大小写下划线、大小写连线转换

    有时候需要处理对象属性的getter、setter方法，或者将属性与数据表字段进行相互转换，感兴趣的可以了解一下
    2021-06-06
  • 详解JavaEE中Apollo安装使用小结

    详解JavaEE中Apollo安装使用小结

    这篇文章主要介绍了详解JavaEE中Apollo安装与使用，本文给大家介绍的非常详细，对大家的学习或工作具有一定的参考借鉴价值,需要的朋友可以参考下
    2022-03-03
  • 解决spring cloud gateway 获取body内容并修改的问题

    解决spring cloud gateway 获取body内容并修改的问题

    这篇文章主要介绍了解决spring cloud gateway 获取body内容并修改的问题，具有很好的参考价值，希望对大家有所帮助。一起跟随小编过来看看吧
    2020-12-12
  • java写的伪微信红包功能示例代码

    java写的伪微信红包功能示例代码

    这篇文章主要介绍了java写的伪微信红包功能示例代码,文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧
    2019-08-08
  • JAVA实现简单停车场系统代码

    JAVA实现简单停车场系统代码

    JAVA项目中正号需要一个停车收费系统，就整理出来java实现的一个简单的停车收费系统给大家分享一下，希望对大家有所帮助
    2017-04-04

最新评论