脚本之家 服务器常用软件
快捷导航
您的位置：首页 → 软件编程 → 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的观察者模式，文中示例代码介绍的非常详细，具有一定的参考价值，感兴趣的小伙伴们可以参考一下，希望能够给你带来帮助
    2022-03-03
  • springboot表单提交之validator校验

    springboot表单提交之validator校验

    在前台表单验证的时候，通常会校验一些数据的可行性，比如是否为空，长度，身份证，邮箱等等，这篇文章主要给大家介绍了关于springboot表单提交之validator校验的相关资料，需要的朋友可以参考下
    2021-05-05
  • Springboot使用redis进行api防刷限流过程详解

    Springboot使用redis进行api防刷限流过程详解

    这篇文章主要介绍了Springboot使用redis进行api防刷限流过程详解,文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下
    2019-12-12
  • SpringBoot配置Redis连接池的实现步骤

    SpringBoot配置Redis连接池的实现步骤

    本文主要介绍了SpringBoot配置Redis连接池的实现步骤,详细的讲解了连接池的作用、配置方式、连接池参数说明,具有一定的参考价值,感兴趣的可以了解一下
    2025-03-03
  • 关于Javaweb的转发和重定向详解

    关于Javaweb的转发和重定向详解

    这篇文章主要介绍了关于Javaweb的转发和重定向详解,请求的转发,是指服务器收到请求后,从一个服务器端资源跳转到同一个服务器端另外一个资源的操作,需要的朋友可以参考下
    2023-05-05
  • Mybatis plus 配置多数据源的实现示例

    Mybatis plus 配置多数据源的实现示例

    这篇文章主要介绍了Mybatis plus 配置多数据源的实现示例，文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧
    2020-08-08
  • 如何在springboot项目中自定义404页面

    如何在springboot项目中自定义404页面

    今天点击菜单的时候不小心点开了一个不存在的页面,然后看到浏览器给的一个默认的404页面,这篇文章主要介绍了如何在springboot项目中自定义404页面,需要的朋友可以参考下
    2024-05-05
  • Java IO流深入理解

    Java IO流深入理解

    这篇文章主要介绍了java IO流的深入理解，下面和小编来一起学习一下吧，希望能给你带来帮助，也希望您能够多多关注脚本之家的更多内容
    2021-07-07
  • JCommander解析命令行参数使用详解

    JCommander解析命令行参数使用详解

    这篇文章主要为大家介绍了JCommander解析命令行参数使用详解，有需要的朋友可以借鉴参考下，希望能够有所帮助，祝大家多多进步，早日升职加薪
    2023-09-09
  • java 方法泛型入参T和String的重载关系详解

    java 方法泛型入参T和String的重载关系详解

    这篇文章主要介绍了java 方法泛型入参T和String的重载关系详解，具有很好的参考价值，希望对大家有所帮助。如有错误或未考虑完全的地方，望不吝赐教
    2022-02-02

最新评论