消息 (Message) 是指在应用间传送的数据。消息可以非常简单，比如只包含文本字符串、 JSON 等，也可以很复杂，比如内嵌对象。

消息队列中间件 (Message Queue Middleware ，简称为 MQ) 是指利用高效可靠的消息传递 机制进行与平台无关的数据交流，并基于数据通信来进行分布式系统的集成。通过提供消息传 递和消息排队模型，它可以在分布式环境下扩展进程间的通信。

消息队列中间件，也可以称为消息队列或者消息中间件。它一般有两种传递模式：点对点 (P2P, Point-to-Point) 模式和发布 / 订阅 (Pub/Sub) 模式。点对点模式是基于队列的，消息生产 者发送消息到队列，消息消费者从队列中接收消息，队列的存在使得消息的异步传输成为可能。 发布订阅模式定义了如何向 一个内容节点发布和订阅消息，这个内容节点称为主题 (topic) ，主 题可以认为是消息传递的中介，消息发布者将消息发布到某个主题，而消息订阅者则从主题中 订阅消息。主题使得消息的订阅者与消息的发布者互相保持独立，不需要进行接触即可保证消 息的传递，发布 / 订阅模式在消息的一对多广播时采用 。

目前开源的消息中间件有很多，比较主流的有 RabbitMQ、 Kafka、 ActiveMQ 、 RocketMQ 等。 面向消息的中间件 (简称为 MOM， Message Oriented Middleware) 提供了以松散藕合的灵 活方式集成应用程序的 一种机制。它们提供了基于存储和转发的应用程序之间的异步数据发送，

即 应用程序彼此不直接通信，而是与作为中介的消息中间件通信 。

消息中间件提供了有保证的

消息发送，应用程序开发人员无须了解远程过程调用

(RPC) 和网络通信协议的细节 。

消息中间件适用于需要可靠的数据传送的分布式环境 。 采用消息中间件的系统中，不同的 对象之 间通过传递消息来激活对方的事件，以完成相应的操作 。 发送者将消息发送给消息服务 器， 消 息服务器将消息存放在若干队列中，在合适的时候再将消息转发给接收者 。 消息中间件 能在不同平台之间通信，它常被用来屏蔽各种平台及协议之间的特性，实现应用程序之间的协 同，其优点在于能够在客户和服务器之间提供同步和异步的连接，并且在任何时刻都可以将消 息进行传送或者存储转发，这也是它比远程过程调用更进步的原因 。

举例说明，如图 1-1 所示，应用程序 A 与应用程序 B 通过使用消息中间件的应用程序编程接口 (API ， Application Program Interface) 发送消息来进行通信。

消息中间件将消息路由给应用程序 B ，这样消息就可存在于完全不同的计算机上。消息中 间件负责处理网络通信，如果网络连接不可用，消息 中间件会存储消息 ，直到连接变得可用， 再将消息转发给应用程序 B 。灵活性的另一方面体现在，当应用程序 A 发送其消息时，应用程 序 B 甚至可以处于不运行状态，消息中间件将保留这份消息，直到应用程序 B 开始执行并消费消息，这样还防止了应用程序 A 因为等待应用程序 B 消费消息而出现阻塞 。这种异步通信方式要求应用程序的设计与现在大多数应用不同。不过对于时间无关或并行处理的场景，它可能是 一个极其有用的方法 。