RabbitMq-入门-02-工作模式介绍

标题1、RabbitMQ 提供了 6 种工作模式

  1. 简单模式
一个生产者对应一个消费者!
P:生产者,也就是要发送消息的程序
C:消费者:消息的接收者,会一直等待消息到来
queue:消息队列,图中红色部分。类似一个邮箱,可以缓存消息;生产者向其中投递消息,消费者从其中取出消息
  1. 工作模式
与入门程序的简单模式相比,多了一个或一些消费端,多个消费端共同消费同一个队列中的消息。
在一个队列中如果有多个消费者,但是只能有一个消费者获得消息!那么消费者之间对于同一个消息的关系是竞争的关系。
  1. 订阅/发布模式
  1. 路由模式:
1、队列与交换机的绑定,不能是任意绑定了,而是要指定一个 RoutingKey(路由key)消息的发送方在向 Exchange 发送消息时,也必须指定消息的 RoutingKey

2、Exchange 不再把消息交给每一个绑定的队列,而是根据消息的 Routing Key 进行判断,只有队列的Routingkey 与消息的 Routing key 完全一致,才会接收到消息

P:生产者,向 Exchange 发送消息,发送消息时,会指定一个routing key
X:Exchange(交换机),接收生产者的消息,然后把消息递交给与 routing key 完全匹配的队列
C1:消费者,其所在队列指定了需要 routing key 为 orange的消息
C2:消费者,其所在队列指定了需要 routing key 为 black、green的消息
  1. 通配符模式模式:
1、Topic 类型与 Direct 相比,都是可以根据 RoutingKey 把消息路由到不同的队列。只不过 Topic 类型Exchange 可以让队列在绑定 Routing key 的时候使用通配符!

2、Routingkey 一般都是有一个或多个单词组成,多个单词之间以”.”分割,例如: item.insert 

3、通配符规则:# 匹配一个或多个词,* 匹配不多不少恰好1个词,例如:item.# 能够匹配 item.insert.abc 或者 item.insert,item.* 只能匹配 item.insert
  1. RPC模式:
虽然有此模式,但是工作中极少使用此种模式:
 RPC即客户端远程调用服务端的方法 ,使用MQ可以实现RPC的异步调用,基于Direct交换机实现,流程如下:

1、客户端即是生产者也是消费者,向RPC请求队列发送RPC调用消息,同时监听RPC响应队列。

2、服务端监听RPC请求队列的消息,收到消息后执行服务端的方法,得到方法返回的结果。

3、服务端将RPC方法 的结果发送到RPC响应队列。

4、客户端(RPC调用方)监听RPC响应队列,接收到RPC调用结果。
经验分享 程序员 微信小程序 职场和发展