消息中间件的介绍-编程知识

消息中间件（message oriented middleware）是指支持与保障分布式应用程序之间同步/异步收发消息的中间件。消息是分布式应用之间进行数据交换的基本信息单位，分布式应用程序之间的通信接口由消息中间件提供。其中，异步方式指消息发送方在发送消息时不必知道接收方的状态，更无需等待接收方的回复，而接收方在收到消息时也不必知道发送方的目前状态，更无需进行同步的消息处理，它们之间的连接完全是松耦合的，通信是非阻塞的，这种异步通信方式是由消息中间件中的消息队列及其服务机制保障的。一般地，实时性要求较高的业务采用同步方式处理，实时性要求不高的业务采用异步方式进行处理。消息中间件已广泛应用于各类分布式应用系统中。

消息起源于分布式操作系统进程通信模型和分布式应用互操作技术的研究。1980年代，随着开放系统互连参考模型OSI的兴起，作为开放系统网络模式中底层的包交换通信范型的一种自然扩充，分布式系统消息机制的研究和应用得到极大的发展，而统一处理消息发送、接收和管理的消息中间件的概念和平台开始出现。 1980年代后期，IBM公司推出了消息中间件产品MQSeries，成为消息中间件成熟的一个标志。

进入1990年代，由于应用需求的推动，消息中间件技术得到极大的发展，并在世界范围内涌现出大量的消息中间件产品。为了有助于消息中间件技术的传播，由众多消息中间件厂商、用户和咨询机构组成了消息中间件协会（MOMA），MOMA是一个非盈利机构，旨在推动消息技术在跨平台、跨层次的分布计算中的广泛应用。国际对象管理组织（Object Management Group，简称OMG）制定了公共对象服务标准（Common Object Service Specifiaction，简称COSS），其中对消息服务进行了规范。

进入21世纪，消息中间件技术得到进一步的发展。在规范化方面，由于J2EE技术的广泛应用，J2EE的消息服务规范JMS（Java Message Service）得到消息中间件厂商的广泛采纳，并逐渐成为消息中间件的事实标准，与此同时，Web服务技术的兴起，与Web服务相关的标准体系得到发展，在消息方面，W3C组织定义了Web服务的可靠消息传送规范（WS-ReliableMessaging）。

目前，企业信息系统开始从部门级应用向企业级、跨企业集成的方向转变，在这一过程中，传统的消息中间件体系架构也暴露出它的局限性。传统的消息中间件通常采用点对点的消息传输结构，即在发送方对消息进行打包时需要显明地标注接收方的地址。因此，尽管消息的接收方和发送方是松耦合连接的，相互通信不必保持同步，但由于在消息中必须绑定接收方地址，导致在广域、大型应用系统中使用消息中间件不够灵活，系统扩展比较困难。为了增加消息发送方和接收方之间对地址的透明性，1990年代末期以后，消息中间件开始向发布/订阅架构转变，并成为企业应用集成中间件的一种核心机制，而基于发布/订阅架构的消息中间件通常称为发布/订阅消息中间件（Publish/Subscribe Middleware，简称P/S MOM）或消息代理（Message Broker），以与传统的消息中间件相区别。目前比较典型的消息中间件包括IBM WebSphere MQSeries、Tibco TIB/Rendezvous和Microsoft MSMQ等。

传统的点对点消息中间件通常由消息队列服务、消息传递服务、消息队列和消息应用程序接口API组成，其典型的结构如图6.1所示。

消息中间件的基本工作原理为：在消息发送方，消息发送者调用发送消息的API函数，将需要发送的消息经消息队列服务存储到发送消息队列中；通过双方消息传递服务之间的交互，经消息队列服务将需要发送的消息从发送队列取出，并送到接收方；接收方再经它的消息队列服务将接收到的消息存放到它的接收消息队列中；在消息接收方，消息接收者调用接收消息的API函数，同样经过消息队列服务，将需要的消息从接收队列中取出，并进行处理。消息在发送或接收成功后，消息队列服务将对相应的消息队列进行管理。

在基于消息代理的分布式应用系统中，消息的发送方称为出版者，消息的接收方称为订阅者，不同的消息通过不同的主题进行区分。出版者向消息代理出版其他应用系统感兴趣的消息，而订阅者从消息代理接收自己感兴趣的消息，出版者和订阅者之间通过消息代理进行关联。消息代理的基本结构如图6.2所示。

消息中间件的比较-转载

消息代理具有很好的灵活性和可扩展性，并支持主动、实时的信息传递方式，当消息发布者有动态更新的数据产生时，消息代理会通过事件的发布主动通知消息订阅者存在新的数据可用，而无需消息订阅者进行频度无法确定的查询。消息代理适合于具有实时性、异步性、异构性、动态性和松耦合的应用需求。

消息代理的工作原理为：消息发布者和订阅者分别同消息代理进行通信。消息发布者将包含主题的消息发布到消息代理；消息订阅者向消息代理订阅自己感兴趣的主题。消息代理对双方的主题进行匹配后，不断将订阅者感兴趣的消息推(Push)给订阅者，直到订阅者向消息代理发出取消订阅的消息。

消息代理实现了发布者和订阅者在时间、空间和流程三个方面的解耦：

时间解耦—－发布方和订阅方无需同时在线就能够进行消息传输，消息中间件通过存储转发提供了这种异步传输的能力；

空间解耦——发布方和订阅方都无需知道对方的物理地址、端口，甚至无需知道对方的逻辑名字和个数；

流程解耦——发布方和订阅方在发送和接收数据时并不阻塞各自的控制流程。

从消息中间件的基本功能来看，无论是点对点消息中间件还是消息代理，其体系结构都是非常清晰简单的。但由于分布式应用及其环境的多样性和复杂性，导致了消息中间件的复杂性。

消息中间件的复杂性主要体现在下面几个方面：

消息中间件需要为分布在企业各个物理服务器上的应用系统提供消息服务，而这些服务器可能采用不同硬件平台，相互之间可能通过不同的网络协议进行连接，这就要求消息中间件能够跨越不同的网络和硬件平台；

分布式应用可能采用不同开发语言或工具实现，因此需要消息中间件为这些应用程序提供各类应用程序接口；