专栏首页一点博客Spring Boot与ActiveMQ整合

Spring Boot与ActiveMQ整合

Spring Boot与ActiveMQ整合

使用内嵌服务

(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的服务,所以我们不用单独启动也可以执行应用程序。

使用外部服务

在src/main/resources下的application.properties增加配置, 指定ActiveMQ的地址

spring.activemq.broker-url=tcp://192.168.25.135:61616

运行后,会在activeMQ中看到发送的queue

发送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);

}

本文分享自微信公众号 - 一点博客(xiaochen_182)

原文出处及转载信息见文内详细说明,如有侵权,请联系 yunjia_community@tencent.com 删除。

原始发表时间:2019-07-16

本文参与腾讯云自媒体分享计划,欢迎正在阅读的你也加入,一起分享。

我来说两句

0 条评论
登录 后参与评论

相关文章

  • Dubbox框架与Zookeeper入门之简介

    Dubbox 是一个分布式服务框架,其前身是阿里巴巴开源项目Dubbo ,被国内电商及互联网项目中使用,后期阿里巴巴停止了该项目的维护,当当网便在Dubbo基础...

    一点博客
  • JAVA设计模式详解

    设计模式有两种分类方法,即根据模式的目的来分和根据模式的作用的范围来分。 根据目的来分 根据模式是用来完成什么工作来划分,这种方式可分为创建型模式、...

    一点博客
  • 前端框架AngularJS入门

    AngularJS 诞生于2009年,由Misko Hevery 等人创建,后为Google所收购。是一款优秀的前端JS框架,已经被用于Google的多款产品当...

    一点博客
  • 零基础学习 Python 之模块(二)

    在昨天的文章(零基础学习 Python 之模块(一))中我们是在原来知识的基础上继续的了解了一下「模块」,已经显示了编写模块和在程序中导入模块的基本方式,当然了...

    Rocky0429
  • 笔记20 | 学习整理开源APP(BaseAnimation)程序源码“中的通讯录效果(一)

    项勇
  • 在 ASP.NET Core 项目中使用 AutoMapper 进行实体映射

      在实际项目开发过程中,我们使用到的各种 ORM 组件都可以很便捷的将我们获取到的数据绑定到对应的 List<T> 集合中,因为我们最终想要在页面上展示的数据...

    程序员宇说
  • EntityFramework 外键值映射

    如果在 EF OnModelCreating 中配置了实体外键映射,也就是 SQL Server 中的 ForeignKey,那么我们在添加实体的时候,主实体的...

    逸鹏
  • 开源导入导出通用库Magicodes.ExporterAndImporter发布

    https://github.com/xin-lai/Magicodes.ExporterAndImporter

    心莱科技雪雁
  • 开源导入导出通用库Magicodes.ExporterAndImporter发布

    Magicodes.ExporterAndImporter为心莱团队封装的导入导出通用库,并且仍在跟随项目不断地打磨。

    雪雁-心莱科技
  • 大数据分析到底需要多少种工具

    1.分类方法大比武 大数据分析主要依靠机器学习和大规模计算。机器学习包括监督学习、非监督学习、强化学习等,而监督学习又包括分类学习、回归学习、排序学习、匹配学习...

    小莹莹

扫码关注云+社区

领取腾讯云代金券