ActiveMQ介绍及使用
1. ActiveMQ介绍
ActiveMQ是Apache出品的开源信息总线,ActiveMQ是一个完全支持JMS1.1和J2EE1.4规范的JMS Provider实现。
MQ:message queue 消息队列,消息传递–消息通信,一个系统访问另外一个系统的方式
1.1 activeMQ中有两种消息模型
- Queue:一个消息只能被消费一次
- Topic:广播模型,类似微信公众号,一个消息可以被消费多次
1.2 ActiveMQ工作原理(按照发送短信为例)
- 解决服务之间代码耦合
- 使用消息队列,增加系统并发处理量
下载安装
官网:http://activemq.apache.org/components/classic/download/
下载后解压
修改conf下的activemq.xml文件
zhaoda
将0.0.0.0改为localhost
再打开bin目录下的win64中的activemq.bat启动
访问localhost:8161 账号密码均为admin
ActiveMQ使用的是标准生产者和消费者模型:有两种数据结构queue和topic
1、Queue 队列(P2P消息模型) ,生产者生产了一个消息,只能由一个消费者进行消费 :给微信
好友发消息
2、Topic 主题/广播(Pub/Sub消息模型),生产者生产了一个消息,可以由多个消费者进行消
费: 微信公众号给粉丝发消息
JMS是javaee13大核心技术之一,提供的是接口,activeMQ是jms的具体实现
JMS和ActiveMQ的对应
---------------------------------END----------------------------------------
下章关于使用java操作activeMQ