Activemq
1. 什么是Activemq
1.1 什么是mq
维基百科:
在计算机科学中,消息队列(英语:Message queue)是一种进程间通信或同一进程的不同线程间的通信方式,软件的贮列用来处理一系列的输入,通常是来自用户。消息队列提供了异步的通信协议,每一个贮列中的纪录包含详细说明的数据,包含发生的时间,输入设备的种类,以及特定的输入参数,也就是说:消息的发送者和接收者不需要同时与消息队列交互。消息会保存在队列中,直到接收者取回它。
消息的发送者和接收者不需要同时与消息队列交互。消息会保存在队列中,直到接收者取回它。这句话把消息队列说明的很清楚。顾名思义就是保存消息的队列。
1.2 消息模型
-
P2P(Point-to-Point)
点对点模式,就是生产者发布的消息,只能被一个消费者消费。
Producer发布一条消息,ConsumerA和ConsumerB只能有一个能接收消息,消息在队列中被消费掉,就没有了。
-
Pub/Sub(Publish/Subscribe)
发布订阅模式,生产者发布的消息,可以被所有的消费者消费。
Producer发布一条消息,ConsumerA和ConsumerB都能接收到消息。
1.2 什么是Activemq
Apache ActiveMQ是Apache软件基金会所研发的开放源码消息中间件;由于ActiveMQ是一个纯Java程序,因此只需要操作系统支持Java虚拟机,ActiveMQ便可执行。
2. 为什么使用Activemq
mq的优点有很多,能觉得很多问题。下面是我使用中解决的一些问题
2.1 数据同步
在我们日常开发中,经常会对接到其他的公司。比如用户信息的同步,总不能别人的用户信息修改了,我们这里还是用之前的。这样肯定会出问题的。
解决方案
-
定时任务
定时查询变更数据,这样的缺点就是,数据不能实时同步。除非间隔时间很短,那也太吃服务性能了。
-
通过mq
每次变更数据时,发布到消息队列,让别人来订阅,这样别人可以实时的更新数据。
2.2 异步处理请求
直接用一个用户短信登录例子来说明
一般发短信,通常都是调用第三方服务。如果使用同步请求的方式,那样会很慢。所以可以通过消息队列,把需要发送的消息放到队列里,异步的处理。这样接口的响应就会很快。