RabbitMQ简介
RabbitMQ是一个消息代理:它接受和转发消息。你可以把它想象成一个邮局:当你把你想要发布的邮件放在邮箱中时,你可以确定邮差先生最终将邮件发送给你的收件人。在这个比喻中,RabbitMQ是邮政信箱,邮局和邮递员。
RabbitMQ和邮局的主要区别在于它不处理纸张,而是接受,存储和转发二进制数据块——消息。引自(官网介绍)。
尽管消息流经RabbitMQ,但它们只能存储在队列中。一个队列只受主机内存和磁盘限制的约束,它本质上是一个很大的消息缓冲区。许多生产者可以发送进入一个队列的消息,并且许多消费者可以尝试从一个队列接收数据。实质上是生产者——消费者关系。
什么叫消息队列
消息(消息)是指在应用间传送的数据。消息可以非常简单,比如只包含文本字符串,也可以更复杂,可能包含嵌入对象。
消息队列(消息队列)是一种应用间的通信方式,消息发送后可以立即返回,由消息系统来确保消息的可靠传递。消息发布者只管把消息发布到MQ中而不用管谁来取,消息使用者只管从MQ中取消息而不管是谁发布的。这样发布者和使用者都不用知道对方的存在。
为何用消息队列
从上面的描述中可以看出消息队列是一种应用间的异步协作机制,那什么时候需要使用MQ呢?
以常见的订单系统为例,用户点击【下单】按钮之后的业务逻辑可能包括:扣减库存,生成相应单据,发红包,发短信通知。在业务发展初期这些逻辑可能放在一起同步执行,随着业务的发展订单量增长,需要提升系统服务的性能,这时可以将一些不需要立即生效的操作拆分出来异步执行,比如发放红包,发短信通知等。这种场景下就可以用MQ在下单的主流程(比如扣减库存,生成相应单据)完成之后发送一条消息到MQ让主流程快速完结,而由另外的单独线程拉取MQ的消息(或者由MQ推送消息),当发现MQ中有发红包或发短信之类的消息时,执行相应的业务逻辑。
以上是用于业务解耦的情况,其它常见场景包括最终一致性,广播,错峰流控等等。
RabbitMQ特点
RabbitMQ是一个由Erlang语言开发的AMQP的开源实现。
AMQP:高级消息队列,高级消息队列协议。它是应用层协议的一个开放标准,为面向消息的中间件设计,基于此协议的客户端与消息中间件可传递消息,并不受产品,开发语言等条件的限制。
RabbitMQ最初起源于金融系统,用于在分布式系统中存储转发消息,在易用性,扩展性,高可用性等方面表现不俗。具体特点包括:
(1)可靠性(可靠性)
RabbitMQ使用一些机制来保证可靠性,如持久化,传输确认,发布确认。
(2)灵活的路由(灵活的路由)
在消息进入队列之前,通过交换来路由消息的。对于典型的路由功能,RabbitMQ已经提供了一些内置的交换来实现。针对更复杂的路由功能,可以将多个交换绑定在一起,也通过插件机制实现自己的交换。
(3)消息集群(集群)
多个RabbitMQ服务器可以组成一个集群,形成一个逻辑代理。
(4)高可用(高可用队列)
队列可以在集群中的机器上进行镜像,使得在部分节点出问题的情况下队列仍然可用。
(5)多种协议(多协议)
RabbitMQ支持多种消息队列协议,比如跺脚,MQTT等等。
(6)多语言客户端(很多客户)
RabbitMQ几乎支持所有常用语言,比如Java、。净,Ruby等等。
(7)管理界面(管理UI)
RabbitMQ提供了一个易用的用户界面,使得用户可以监控和管理消息经纪人的许多方面。
(8)跟踪机制(跟踪)
如果消息异常,RabbitMQ提供了消息跟踪机制,使用者可以找出发生了什么。
(9)插件机制(插件系统)
RabbitMQ提供了许多插件,来从多方面进行扩展,也可以编写自己的插件。
RabbitMQ中的概念模型——消息模型
所有MQ产品从模型抽象上来说都是一样的过程:
消费者(消费者)订阅某个队列。生产者(生产者)创建消息,然后发布到队列(队列)中,最后将消息发送到监听的消费者
RabbitMQ基本概念
上面只是最简单抽象的描述,具体到RabbitMQ则有更详细的概念需要解释。上面介绍过RabbitMQ是AMQP协议的一个开源实现,所以其内部实际上也是AMQP中的基本概念:
