消息队列原理

清疚 2022-05-31 05:06 144阅读 0赞

# [发布-订阅消息模式][-] #

**一、订阅杂志**

我们很多人都订过杂志，其过程很简单。只要告诉邮局我们所要订的杂志名、投递的地址，付了钱就OK。出版社定期会将出版的杂志交给邮局，邮局会根据订阅的列表，将杂志送达消费者手中。这样我们就可以看到每一期精彩的杂志了。

![20130429112013450][]

仔细思考一下订杂志的过程，我们会发现这样几个特点：1、消费者订杂志不需要直接找出版社；2、出版社只需要把杂志交给邮局；3、邮局将杂志送达消费者。邮局在整个过程中扮演了非常重要的中转作用，在出版社和消费者相互不需要知道对方的情况下，邮局完成了杂志的投递。  
**二、发布-订阅消息模式**

刚刚讲了订阅杂志，下面我们会讲传统调用模式演化到发布-订阅消息模式。  
有些网站在注册用户成功后发一封激活邮件，用户收到邮件后点击激活链接后才能使用该网站。一般的做法是在注册用户业务逻辑中调用发送邮件的逻辑。这 样用户业务就依赖于邮件业务。如果以后改为短信激活，注册用户业务逻辑就必须修改为调用发送短信的逻辑。如果要注册后给用户加点积分，再加一段逻辑。经过 多次修改，我们发现很简单的注册用户业务已经越来越复杂，越来越难以维护。相信很多开发者都会有类似痛苦的经历。

![20130429112041052][]

即使用户业务实现中对其他业务是接口依赖，也避免不了业务变化带来的依赖影响。怎么办？解耦！将注册用户业务逻辑中注册成功后的处理剥离出来。  
再回头看看”订阅杂志”，如果没有邮局，出版社就必须自己将杂志送达所有消费者。这种情形就和现在的注册用户业务一样。我们发现问题了，在用户业务和其他业务之间缺少了邮局所扮角色。  
我们把邮局抽象成一个管理消息的地方，叫”消息管理器”。注册用户成功后发送一个消息给消息管理器，由消息管理器转发该消息给需要处理的业务。现在，用户业务只依赖于消息管理器了，它再也不会为了注册用户成功后的其他处理而烦恼。

![20130429112120082][]

注册用户的改造就是借鉴了”订阅杂志”这样原始的模式。我们再进一步抽象，用户业务就是消息的”生产者”，它将消息发布到消息管理器。邮件业务就是 消息的”消费者”，它将收到的消息进行处理。邮局可以订阅很多种杂志，杂志都是通过某种编号来区分；消息管理器也可以管理多种消息，每种消息都会有一个 “主题”来区分，消费者都是通过主题来订阅的。  
![20130429112138988][]

发布-订阅消息模式已经呈现在我们面前，利用它可以产生更灵活、更松散耦合的系统。

# [MQ相关概念][MQ] #

1.消息(Message)

消息是MQ中最小的概念，本质上就是一段数据，它能被一个或者多个应用程序所理解，是应用程序之间传递的信息载体。

2.队列(Queue）

2.1本地队列

本地队列按照功能可划分为初始化队列，传输队列，目标队列和死信队列。

初始化队列用作消息触发功能。

传输队列只是暂存待传的消息，条件许可的情况下，通过管道将消息传送到其他的队列管理器。

目标队列是消息的目的地，可以长期存放消息。

如果消息不能送达目标队列，也不能再路由出去，则被自动放入死信队列保存。

2.2别名队列&远程队列

只是一个队列定义，用来指定远端队列管理器的队列。使用了远程队列，程序就不需要知道目标队列的位置。

2.3模型队列

模型队列定义了一套本地队列的属性结合，一旦打开模型队列，队列管理器会按照这些属性动态地创建出一个本地队列。

3.队列管理器(Queue Manager)

队列管理器是一个负责向应用程序提供消息服务的机构，如果把队列管理器比作数据库，那么队列就是其中一张表。

4.通道(Channel)

通道是两个管理器之间的一种单向点对点的的通信连接，如果需要双向交流，可以建立一对通道。

5.监听器(listner)

# [MQ产品的特性][MQ 1] #

可靠性传输

这个特点可以说是消息中间件的立足之本，对于应用来说，只要成功把数据提交给消息中间件，那么关于数据可靠传输的问题就由消息中间件来负责。

不重复传输

不重复传播也就是断点续传的功能，特别适合网络不稳定的环境，节约网络资源。

异步性传输

异步性传输是指，接受信息双方不必同时在线，具有脱机能力和安全性。

消息驱动

接到消息后主动通知消息接收方。

支持事务

应用程序可以把一些数据更新组合成一个工作单元，这些更新通常是逻辑相关的，为了保障数据完整性，所有的更新必须同时成功或者同时失败）。

![20130429112310570][]

[-]: http://wiki.pdm.sdo.com/pages/viewpage.action?pageId=1705376
[20130429112013450]: /images/20220531/817e283c8d5141ad9eb456a55d12d012.png
[20130429112041052]: /images/20220531/5a28a235549344ecb19114848365cd37.png
[20130429112120082]: /images/20220531/c3eb67a3900d466cba12100351f0d5b6.png
[20130429112138988]: /images/20220531/b25a9ac44118405b83ed68525b317ad2.png
[MQ]: http://wiki.pdm.sdo.com/pages/viewpage.action?pageId=1705115
[MQ 1]: http://wiki.pdm.sdo.com/pages/viewpage.action?pageId=1705117
[20130429112310570]: /images/20220531/c099cc75c1194b9fb8228fe00ae705ad.png