RabbitMQ的工作原理

  

 

Broker:消息队列服务进程，此进程包括两个部分:Exchange和Queue。

 

Exchange:消息队列交换机，按一定的规则将消息路由转发到某个队列，对消息进行过虑。

Queue:消息队列，存储消息的队列，消息到达队列并转发给指定的消费方。

Producer:消息生产者，即生产方客户端，生产方客户端将消息发送到MQ。

Consumer:消息消费者，即消费方客户端，接收MQ转发的消息。

消息发布接收流程:

-----发送消息-----

1、生产者和Broker建立TCP连接。

2、生产者和Broker建立通道。

3、生产者通过通道消息发送给Broker，由Exchange将消息进行转发。

4、Exchange将消息转发到指定的Queue(队列)

 

----接收消息-----
1、消费者和Broker建立TCP连接

2、消费者和Broker建立通道

3、消费者监听指定的Queue(队列)

4、当有消息到达Queue时Broker默认将消息推送给消费者。

5、消费者接收到消息。

 

RabbitMQ有以下几种工作模式 :

1、Work queues

2、Publish/Subscribe

3、Routing

4、Topics

5、Header

6、RPC

 1 Work queues

work queues与入门程序相比，多了一个消费端，两个消费端共同消费同一个队列中的消息。

应用场景:对于 任务过重或任务较多情况使用工作队列可以提高任务处理的速度。

Publish/subscribe

工作模式

1、每个消费者监听自己的队列。

2、生产者将消息发给broker，由交换机将消息转发到绑定此交换机的每个队列，每个绑定交换机的队列都将接收 到消息

Routing

1， 每个消费者监听自己的队列，并且设置routingkey

2、生产者将消息发给交换机，由交换机根据routingkey来转发消息到指定的队列。

Topics

工作模式

路由模式:

1、每个消费者监听自己的队列，并且设置带统配符的routingkey。

2、生产者将消息发给broker，由交换机根据routingkey来转发消息到指定的队列。

Header模式

header模式与routing不同的地方在于，header模式取消routingkey，使用header中的 key/value(键值对)匹配

队列

RPC

RPC即客户端远程调用服务端的方法 ，使用MQ可以实现RPC的异步调用，基于Direct交换机实现，流程如下: 1、客户端即是生产者就是消费者，向RPC请求队列发送RPC调用消息，同时监听RPC响应队列。 2、服务端监听RPC请求队列的消息，收到消息后执行服务端的方法，得到方法返回的结果 3、服务端将RPC方法 的结果发送到RPC响应队列 4、客户端(RPC调用方)监听RPC响应队列，接收到RPC调用结果。