RabbitMQ简介及其使用方法

一 、RabbitMQ简介

RabbitMQ是基于AMQP实现的一个开源消息组件,主要用于在分布式系统中存储转发消息,由因高性能、高可用以及高扩展而出名的 Erlang 写成。其中,AMQP(Advanced Message Queuing Protocol,即高级消息队列协议),是一个异步消息传递所使用的应用层协议规范,为面向消息的中间件设计。RabbiMQ是EDA事件驱动架构的核心,也是CQRS同步数据的关键。


二、RabbitMQ特点

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

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

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

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

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

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

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

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

三、RabbitMQ工作原理简介

消息从发送端到接收端的流转过程即RabbitMQ的消息工作机制。请见图1。


RabbitMQ简介及其使用方法

四、RabbitMQ的基本用法

共有6种基本用法:单对单、单对多、发布订阅模式、按路由规则发送接收、主题、RPC(即远程存储调用)。我们将介绍单对单、单对多和主题的用法。

1、单对单:单发送、单接收,请见图2。

RabbitMQ简介及其使用方法

2、单对多:一个发送端,多个接收端,如分布式的任务派发,请见图3。

RabbitMQ简介及其使用方法

3、主题:Exchange Type为topic,发送消息时指定交换机及Routing Key,消费者的消息队列绑定到该交换机以及被监听消息的Key实现消息的订阅,订阅后则可接收消息。只有消费者将队列绑定到该交换机且指定的Routing Key符合匹配规则时才能收到消息。其中Routing Key可以设置成通配符,如:*或#(*表示匹配Routing Key中的任何一个规则,#表示能收到任何消息);如果Routing Key由多个单词组成,则单词之间用.来分隔。

RabbitMQ简介及其使用方法