springboot整合ActiveMQ1(基本使用)
- 基本使用,https://www.tapme.top/blog/detail/2018-09-05-10-38
- 主备模式,https://www.tapme.top/blog/detail/2018-09-06-10-38
说明:acitveMQ 版本为:5.9.1,springboot 版本为 2.0.3
一. 下载安装(windows)
官方下载地址:点我跳转,选择 windows 安装包下载,然后解压,解压后运行 bin 目录下的activemq.bat启动服务,无报错即可启动成功。默认管理地址为:localhost:8161/admin,默认管理员账号密码为admin/admin。
二. springboot 整合
1. 创建 springboot 项目
创建 springboot web 项目,加入 spring-boot-starter-activemq 依赖。
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-activemq</artifactId>
</dependency>
然后编辑配合文件,加上一个配置:61616 为 activeMQ 的默认端口,暂时不做其他配置,使用默认值。
spring:
activemq:
broker-url: tcp://localhost:61616
2. 创建生产者消费者
springboot 中 activeMQ 的默认配置为生产-消费者模式,还有一种模式为发布-订阅模式后面再讲。项目目录如下:
首先编写配置类 Config.java,代码如下
@Configuration
public class Config {
@Bean(name = "queue2")
public Queue queue2(){
return new ActiveMQQueue("active.queue2");
}
@Bean(name = "queue1")
public Queue queue1(){
return new ActiveMQQueue("active.queue1");
}
}
上面的代码建立了两个消息队列 queue1,queue2,分别由 queue1 和 queue2 这两个 Bean 注入到 Spring 容器中。程序运行后会在 activeMQ 的管理页面->queue 中看到如下:
生产者 Producer.java 代码如下:
@RestController
public class Producer {
@Autowired
private JmsMessagingTemplate jmsMessagingTemplate;
@Autowired()
@Qualifier("queue2")
private Queue queue2;
@Autowired()
@Qualifier("queue1")
private Queue queue1;
@GetMapping("/queue2")
public void sendMessage1(String message){
jmsMessagingTemplate.convertAndSend(queue2,"I'm from queue2:"+message);
}
@GetMapping("/queue1")
public void sendMessage2(String message){
jmsMessagingTemplate.convertAndSend(queue1,"I'm from queue1:"+message);
}
}
上面的类创建了两个 GET 接口,访问这两个接口分别向 queue1 和 queue2 中发送消息。
消费者 Comsumer.java 代码如下:
@Component //将该类注解到Spring 容器中
public class Comsumer {
//接受消息队列1消息
@JmsListener(destination = "active.queue1") //监听active.queue1消息队列
public void readActiveQueue11(String message){
System.out.println(1+message);
}
//接受消息队列1消息
@JmsListener(destination = "active.queue1")
public void readActiveQueue12(String message){
System.out.println(2+message);
}
//接受消息队列2消息
@JmsListener(destination = "active.queue2")
public void readActiveQueue21(String message){
System.out.println(1+message);
}
//接受消息队列2消息
@JmsListener(destination = "active.queue2")
public void readActiveQueue22(String message){
System.out.println(2+message);
}
}
上面的代码定义了 4 个消费者,每两个消费一个消息队列。
3. 运行
启动项目后分别向/queue1?message=niihao,/queue2?message=nihaoa 发送 http 请求,然后我们可以在控制台中看到如下输出:
2I'm from queue2:nihaoa
1I'm from queue2:nihaoa
2I'm from queue1:nihao
1I'm from queue1:nihao
消息都成功被消费者消费,从打印结果也可看出生产者消费者的一个特点:一个消息只会被一个消费者消费。同时在管理页面中可以看到:
每个消息队列有两个消费者,队列进入了三个消息,出了三个消息,说明消息都被消费掉了,如果注释掉消费者代码,再次运行,然后发送消息就会发现 MessagesEnqueued 数量大于 MessagesDequeued,然后再让消费者上线会立即消费掉队列中的消息。
本文原创发布于:https://www.tapme.top/blog/detail/2018-09-05-10-38
源码:https://github.com/FleyX/demo-project/tree/master/jms_demo
最新文章
- Mysql数据库主从心得整理
- [IOS初学]ios 第一篇 storyboard 与viewcontroller的关系
- Hyper-V初涉:Hyper-V虚拟机常规操作
- NYOJ 737---石子归并(GarsiaWachs算法)
- vim tab 中设置title
- [CareerCup] 17.14 Unconcatenate Words 断词
- CLH锁 、MCS锁
- uva 1629
- JVM ,JIT ,GC RUNTIME 解析
- Oracle内存参数配置及版本问题
- 从高德 SDK 学习 Android 动态加载资源
- C#管理控制IIS7的方法
- React Native App设置&;Android版发布
- 大型三甲医院管理系统源码PACS超声科室源码DICOM影像工作站
- jQuery的1.x版本的$(element).css()设置元素字体颜色时出现的问题(在IE8以下)
- GET vs. POST
- 12.7 Test
- Django框架详细介绍---ORM相关操作
- SQLServer 创建自己的数据库
- vue10行代码实现上拉翻页加载更多数据,纯手写js实现下拉刷新上拉翻页不引用任何第三方插件
热门文章
- 刷题记录:[SUCTF 2019]EasyWeb(EasyPHP)
- 2019_软工实践_Beta收官
- 剑指offer:数组中只出现一次的数字
- 浅谈SOA面向服务化编程架构(dubbo)
- unused function warning message(转)
- Spring cloud微服务安全实战-7-8ELK+SpringBoot环境搭建
- Spring MVC -- JSP标准标签库(JSTL)
- [LeetCode] 258. Add Digits 加数字
- orcad 删除不连接符号
- java通过下划线数字字面量增加可读性:10_00_00表示100000