浅谈Spring Boot 整合ActiveMQ的过程
时间:2019-04-12
本文章向大家介绍浅谈Spring Boot 整合ActiveMQ的过程,主要包括浅谈Spring Boot 整合ActiveMQ的过程使用实例、应用技巧、基本知识点总结和需要注意事项,具有一定的参考价值,需要的朋友可以参考一下。
RabbitMQ是比较常用的AMQP实现,这篇文章是一个简单的Spring boot整合RabbitMQ的教程。
安装ActiveMQ服务器,(也可以不安装,如果不安装,会使用内存mq)
构建Spring boot项目,增加依赖项,只需要添加这一项即可
<!-- 添加acitivemq依赖 --> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-activemq</artifactId> </dependency>
增加Application类
@SpringBootApplication @EnableScheduling //使用定时任务发送消息 public class MqTestApplication { public static void main(String[] args) { SpringApplication.run(MqTestApplication.class, args); } }
配置application.yml
spring: activemq: broker-url: tcp://127.0.01:61616 packages: trust-all: true
构建一个数据Model,可以发送和消费的数据类型有: String, byte array, Map<String,?>, Serializable object.
// 如果发送的消息是一个对象,必须implements Serializable接口 public class TModel implements Serializable { private static final long serialVersionUID = -921008687184331557L; private int count; public TModel(int count) { this.count = count; } @Override public String toString() { return "TModel [count=" + count + "]"; } }
构建Producer
@Component public class Producer { // 在Producer中注入JmsTemplate,我们可以通过这个template发送消息 private final JmsTemplate jmsTemplate; private int count = 0; @Autowired public Producer(JmsTemplate jmsTemplate) { this.jmsTemplate = jmsTemplate; } // 这里使用Spring Boot的定时任务发送消息 @Scheduled(fixedRate = 1000) public void create() { // 使用convertAndSend发送消息 jmsTemplate.convertAndSend("queue1", new TModel(count++)); } }
构建Consumer
@Component public class Consumer { @JmsListener(destination = "queue1") public void comsume(TModel content) { System.out.println("recive message from queue1 [" + content + "]"); } }
特别备注:如果我们的生产者和消费者在不同的Module中时,最好将要消费的数据抽象成公共Module.程序是通过Serializable来序列化和反序列化对象的。必须保证生产者和消费者的对象模型的serialVersionUID是一致的。
项目地址: https://github.com/ldwqh0/active-mq-spring.git
示例:配置rabbitmq ,增加一个队列
@Configuration public class Aqueue { @Bean public Queue queue() { return new Queue("good"); } }
定义一个生产者.
当启用activemq之后,会自动创建一个AmqpTemplate ,可以被注入到任何需要的地方,我们可以通过这个AmqpTemplate发送消息到MQ中
/** * 定义一个生产者 * @author LiDong */ @RestController @RequestMapping("/test") public class SendController { @Autowired private AmqpTemplate template; @GetMapping public String testSend() { // 使用AmqpTemplate发送消息 template.convertAndSend("good", "good"); return "success"; } }
定义消费者,通过指定RabbitListener(queues='good')指定消费的队列
@Component public class Consumer { /** * 定义一个消费者 * @param message */ @RabbitListener(queues = "good") public void handler(String message) { System.out.println("recive message from " + message); } }
启动测试,在浏览器中输入 http://localhost:8080/test 即可发送一条消息到队列中。 该对列可以被消费者处理
以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持脚本之家。
- 十分钟带你了解服务化框架
- WCF技术剖析之十七:消息(Message)详解(上篇)
- 微信年底重磅更新,这次小程序才是重头戏!
- 《EnterLib PIAB深入剖析》系列博文汇总
- Nodejs学习笔记(八)--- Node.js + Express 实现上传文件功能(felixge/node-formidable)
- 大牛教你使用7种卷积神经网络进行物体检测!
- Enterprise Library深入解析与灵活应用(3):倘若将Unity、PIAB、Exception Handling引入MVP模式.. .. ..
- 别对我说谎!你的小九九我都知道
- Spring集成RabbitMQ-使用RabbitMQ更方便
- Nodejs学习笔记(三)--- 模块
- 使用JClouds在Java中获取和发布云服务器
- Silverlight单元测试框架
- Enterprise Library深入解析与灵活应用(2): 通过SqlDependency实现Cache和Database的同步
- 让你感觉不真实的13个伟大科学成就和发现
- java教程
- Java快速入门
- Java 开发环境配置
- Java基本语法
- Java 对象和类
- Java 基本数据类型
- Java 变量类型
- Java 修饰符
- Java 运算符
- Java 循环结构
- Java 分支结构
- Java Number类
- Java Character类
- Java String类
- Java StringBuffer和StringBuilder类
- Java 数组
- Java 日期时间
- Java 正则表达式
- Java 方法
- Java 流(Stream)、文件(File)和IO
- Java 异常处理
- Java 继承
- Java 重写(Override)与重载(Overload)
- Java 多态
- Java 抽象类
- Java 封装
- Java 接口
- Java 包(package)
- Java 数据结构
- Java 集合框架
- Java 泛型
- Java 序列化
- Java 网络编程
- Java 发送邮件
- Java 多线程编程
- Java Applet基础
- Java 文档注释
- JavaScript 技术篇-js通过xpath获取dom节点,js校验xpath唯一性。
- Python 错误使用tuple问题:TypeError: 'tuple' object does not support item assignment. 原因及解决办法
- E-BERT,电商领域语言模型优化实践
- PyQt5 技术篇-透明窗口设置方法,窗口透明度的设置
- 为hexo增加gitalk评论系统
- Python 技巧篇-用print打印输出但不换行方法
- gitalk 自动初始化
- 给hexo申请证书并设置https
- Python 面向对象-如何查看类的父类,外部如何获取类的名字
- Python操作excel:用xlwt设置excel单元格背景颜色,给字体加粗。【附】颜色表
- Python+selenium 自动化-获取当前页面的url地址,打开指定的url地址
- PyQt5 技术篇-窗口置顶不生效解决办法,setWindowFlags()设置不生效解决办法
- 使用hooks自动监测git仓库更改并拉取
- 重新部署hexo
- 关于前端哈希加密密码的思考