RabbitMQ简介 — 什么是消息中间件

消息(Message)是指在应用间传送的数据。

消息可以非常简单,比如只包含文本字符串JSON等,也可以很复杂,比如内嵌对象。

消息队列中间件(Message Queue Middleware,简称为MQ)是指利用高效可靠的消息传递机制进行与平台无关的数据交流,并基于数据通信来进行分布式系统的集成。

通过提供消息传递和消息排队模型,它可以在分布式环境下扩展进程间的通信。

消息队列中间件,也可以称为消息队列或者消息中间件。

它一般有两种传递模式:点对点(P2P,Point-to-Point)模式和发布/订阅(Pub/Sub)模式。

点对点模式是基于队列的,消息生产者发送消息到队列,消息消费者从队列中接受消息,队列的存在使得消息的异步传输成为可能。

发布订阅模式定义了如何向一个内容节点发布和订阅消息,这个内容节点称为主题(topic),主题可以认为是消息传递的中介。

消息发布者将消息发布到某个主题,而消息订阅者则从主题中订阅消息。

主题使得消息的订阅者与消息的发布者互相保持独立,不需要进行接触即可保证消息的传递,发布/订阅模式在消息的一对多广播时采用。

目前开源的消息中间件有很多,比较主流的有RabbitMQ、Kafka、ActiveMQ、RocketMQ等。

面向消息的中间件(简称为MOM,Message Oriented Middleware)提供了以松散耦合的灵活方式集成应用程序的一种机制。

它们提供了基于存储和转发的应用程序之间的异步数据发送,即应用程序彼此不直接通信,而是与作为中介的消息中间件通信。

消息中间件提供了有保证的消息发送,应用程序开发人员无须了解远程过程调用和网络通信协议的细节。

消息中间件适用于需要可靠的数据传送的分布式环境。

采用消息中间件的系统中,不同的对象之间通过传递消息来激活对方的事件,以完成相应的操作。

发送者将消息发送给消息服务器,消息服务器将消息存放在若干队列中,在合适的时候再将消息转发给接收者。

消息中间件能在不同平台之间通信,它常被用来屏蔽各种平台及协议之间的特性,实现应用程序之间的协同。

其优点在于能够在客户和服务器之间提供同步和异步的连接,并且在任何时刻都可以将消息进行传送或者存储转发,这也是它比远程过程调用更进步的原因。

举例说明,如下图所示,应用程序A与应用程序B通过消息中间件的应用程序编程接口API发送消息来进行通信。

消息中间件将消息路由给应用程序B,这样消息就可存在于完全不同的计算机上。

消息中间件负责处理网络通信,如果网络连接不可用,消息中间件会存储消息,直到连接变得可用,再将消息转发给应用程序B。

灵活性的另一方面体现在,当应用程序A发送其消息时,应用程序B甚至可以处于不运行状态,消息中间件将保留这份消息,直到应用程序B开始执行并消费消息。

这样还防止了应用程序A因为等待应用程序B消费消息而出现阻塞。

这种异步通信方式要求应用程序的设计与现在大多数应用不同。

不过对于时间无关或并行处理的场景,它可能是一个极其有用的方法。

订阅评论
提醒
0 评论
最旧
最新 最多投票
内联反馈
查看所有评论
滚动至顶部