RabbitMQ 详解

分布式消息中间件场景介绍

背景

​ 使用过分布式中间件的人都知道,程序员使用起来并不复杂,常用的客户端 API 就那么几个,比我们日常编写程序时用到的 API 要少得多。但是分布式中间件在中小研发团队中使用得并不多,为什么会这样呢?

​ 原因是中间件的职责相对单一,客户端的使用虽然简单,但整个环境搭起来却不容易。

场景介绍

​ 1、业务系统往往要求响应能力特别强,能够起到削峰填谷的作用

​ 2、解耦:如果一个系统挂了,则不会影响另外个系统的继续运行

​ 3、业务系统往往有对消息的高可靠要求,以及有对复杂功能如 Ack 的要求

​ 4、增强业务系统的异步处理能力,减少甚至几乎不可能出现并发现象

使用消息队列,就好比为了防汛而建葛洲坝,有大量数据的堆积能力,然后可靠地进行异步输出

RabbitMQ介绍

​ RabbitMQ 是基于 AMQP 实现的一个开源消息组件,主要用于在分布式系统中存储转发消息,由因高性能、高可用以及高扩展而出名的 Erlang 语言写成

​ 其中,AMQP(Advanced Message Queuing Protocol,即高级消息队列协议),是一个异步消息传递所使用的应用层协议规范,为面向消息的中间件设计

RabbitMQ 特点

高可靠:RabbitMQ 提供了多种多样的特性让你在可靠性和性能之间做出权衡,包括持久化、发送应答、发布确认以及高可用性。

高可用队列:支持跨机器集群,支持队列安全镜像备份,消息的生产者与消费者不论哪一方出现问题,均不会影响消息的正常发出与接收。

灵活的路由:所有的消息都会通过路由器转发到各个消息队列中,RabbitMQ 内建了几个常用的路由器,并且可以通过路由器的组合以及自定义路由器插件来完成复杂的路由功能。

支持多客户端:对主流开发语言(如:Python、Ruby、.NET、Java、C、PHP、ActionScript 等)都有客户端实现。

集群:本地网络内的多个 Server 可以聚合在一起,共同组成一个逻辑上的 broker。

扩展性:支持负载均衡,动态增减服务器简单方便。

权限管理:灵活的用户角色权限管理,Virtual Host 是权限控制的最小粒度。

插件系统:支持各种丰富的插件扩展,同时也支持自定义插件,其中最常用的插件是 Web 管理工具 RabbitMQ_Management

RabbitMQ 5种用法介绍

​ RabbitMQ共有5种使用方式,即单对单、单对多、发布订阅模式、按路由规则发送接收、主题

​ 1、单对单:单发送,单接收

​ 适用于一个生产者,一个消费者的情况

​ 2、单对多:单发送,多接收

​ 适用于只有一个生产者,多个消费者,如分布式的任务派发

​ 3、发布订阅模式:单发送,多接收

​ 一个生产者发送消息,多个消费者获取消息(同样的消息),包括一个生产者,一个交换机,多个队列,多个消费者。

思路解读

​ > 一个生产者,多个消费者

​ > 每一个消费者都有自己的一个队列

​ > 生产者没有直接发消息到队列中,而是发送到交换机

​ > 每个消费者的队列都绑定到交换机上

​ > 消息通过交换机到达每个消费者的队列

注意:交换机没有存储消息功能,如果消息发送到没有绑定消费队列的交换机,消息则丢失

​ 4、按路由规则发送接收

​ 生产者发送消息到交换机并指定一个路由key,消费者队列绑定到交换机时要制定路由key(key匹配就能接受消息,key不匹配就不能接受消息),例如:我们可以把路由key设置为insert ,那么消费者队列key指定包含insert才可以接收消息,消费者队列key定义为update或者delete就不能接收消息。很好的控制了更新,插入和删除的操作。

​ 5、主题

​ Exchange Type 为 topic,发送消息时,需要指定交换机及Routing Key,消费者的消息队列绑定到该交换机并匹配到Routing Key实现消息的订阅,订阅后则可接收消息。只有消费者队列绑定到该交换机且指定的Routing Key符合匹配规则,才能收到消息。

​ 其中Routing Key可以设置成通配符,如:* 或 #(* 表示匹配Routing Key中的某个单词,# 表示任意的Routing Key的消息都能被收到)。如果Routing Key由多个单词组成,则单词之间用 . 来分隔。

命名规范

​ 交换机名的命名建议

​ Ex{AppID}.{自定义 ExchangeName},队列名的命名建议:MQ{AppID}.{自定义 QueueName}