0


RabbitMQ 7种工作模式详解及应用场景

🎇🎇🎇🎇🎇🎇🎇🎇🎇🎇🎇🎇🎇🎇🎇🎇🎇🎇🎇🎇

⭐ RabbitMQ ⭐

🎇🎇🎇🎇🎇🎇🎇🎇🎇🎇🎇🎇🎇🎇🎇🎇🎇🎇🎇🎇


RabbitMQ 7种工作模式

RabbitMQ 是一个广泛使用的开源消息代理和队列服务器,支持多种消息传递模式。以下是RabbitMQ提供的7种主要的工作模式及其应用场景的详细介绍。


1. Simple(简单模式)

角色

  • P (Producer): 生产者,负责发送消息。
  • C (Consumer): 消费者,负责接收消息。
  • Queue (消息队列): 类似于邮箱,可以缓存消息;生产者向其中投递消息,消费者从中取出消息。

特点:一个生产者,一个消费者,消息只能被消费一次。也称为点对点 (Point-to-Point) 模式。

适用场景:消息只能被单个消费者处理的情况。


2. Work Queue(工作队列)

角色

  • P (Producer): 生产者。
  • C1, C2 (Consumers): 多个消费者。
  • Queue (消息队列): 用于缓存消息。

特点:一个生产者,多个消费者。在多个消息的情况下,Work Queue 会将消息分派给不同的消费者,每个消费者都会接收到不同的消息。

适用场景:集群环境中做异步处理。例如,12306 短信通知服务,订单成功后,订单消息会被发送到 RabbitMQ,短信服务从 RabbitMQ 中获取订单信息,并发送通知信息。


3. Publish/Subscribe(发布/订阅)

角色

特点:生产者将消息发送到 Ex

  • P (Producer): 生产者。
  • X (Exchange, 交换机): 负责将消息按一定规则路由到一个或多个队列。
  • C1, C2 (Consumers): 多个消费者。
  • Queue (消息队列): 用于缓存消息。

**概念介绍 **

Exchange: 交换机 (X).

作⽤: ⽣产者将消息发送到Exchange, 由交换机将消息按⼀定规则路由到⼀个或多个队列中(上图中⽣产 者将消息投递到队列中, 实际上这个在RabbitMQ中不会发⽣. )

RabbitMQ交换机有四种类型: fanout,direct, topic, headers, 不同类型有着不同的路由策略.

AMQP协 议⾥还有另外两种类型, System和⾃定义, 此处不再描述.

  1. Fanout:⼴播,将消息交给所有绑定到交换机的队列(Publish/Subscribe模式)
  2. Direct:定向,把消息交给符合指定routing key的队列(Routing模式)
  3. Topic:通配符,把消息交给符合routing pattern(路由模式)的队列(Topics模式)
  4. headers类型的交换器不依赖于路由键的匹配规则来路由消息, ⽽是根据发送的消息内容中的

headers属性进⾏匹配. headers类型的交换器性能会很差,⽽且也不实⽤,基本上不会看到它的存在.

Exchange(交换机)只负责转发消息, 不具备存储消息的能⼒, 因此如果没有任何队 Exchange绑定,或者没有符合路由规则的队列,那么消息就会丢失

RoutingKey: 路由键.⽣产者将消息发给交换器时, 指定的⼀个字符串, ⽤来告诉交换机应该如何处理这个消息.

Binding Key:绑定. RabbitMQ中通过Binding(绑定)将交换器与队列关联起来, 在绑定的时候⼀般会指 定⼀个Binding Key, 这样RabbitMQ就知道如何正确地将消息路由到队列了.

change,由交换机将消息广播到所有绑定的队列。每个消费者都会接收到相同的消息。

⽐如下图: 如果在发送消息时, 设置了RoutingKey 为orange, 消息就会路由到Q1

当消息的Routing key与队列绑定的Bindingkey相匹配时,消息才会被路由到这个队列.

BindingKey其实也属于路由键中的⼀种, 官⽅解释为:the routingkey to use for the binding.

可以翻译为:在绑定的时候使⽤的路由键. ⼤多数时候,包括官⽅⽂档和RabbitMQJava API 中都把

BindingKey和RoutingKey看作RoutingKey, 为了避免混淆,可以这么理解:

  1. 在使⽤绑定的时候,需要的路由键是BindingKey.

  2. 在发送消息的时候,需要的路由键是RoutingKey

适用场景:消息需要被多个消费者同时接收的场景。例如,中国气象局发布天气预报的消息,新浪、百度、搜狐等门户网站通过队列绑定到该交换机,自动获取气象局推送的气象数据。


4. Routing(路由模式)

角色

  • P (Producer): 生产者。
  • X (Exchange, 交换机): 根据 RoutingKey 的规则将消息路由到对应的队列。
  • C1, C2 (Consumers): 多个消费者。
  • Queue (消息队列): 用于缓存消息。

特点:交换机根据 RoutingKey 将消息筛选后发给对应的消费者队列。

适用场景:需要根据特定规则分发消息的场景。例如,系统打印日志,日志等级分为 error, warning, info, debug,可以通过这种模式将不同的日志发送到不同的队列,最终输出到不同的文件。


5. Topics(通配符模式)

角色

  • P (Producer): 生产者。
  • X (Exchange, 交换机): 根据 RoutingKey 的通配符匹配规则将消息路由到对应的队列。
  • C1, C2 (Consumers): 多个消费者。
  • Queue (消息队列): 用于缓存消息。

特点:类似于 Routing 模式,但使用通配符来定义 RoutingKey 的模式,使得匹配更加灵活。

适用场景:需要灵活匹配和过滤消息的场景。

示例图:展示交换机根据通配符匹配规则将消息路由到不同的队列。


6. RPC (Remote Procedure Call, 远程过程调用)

角色

  • 客户端 (Client): 发送请求消息并等待响应。
  • 服务端 (Server): 接收请求消息并发送响应消息。

特点:客户端发送消息到指定的队列,并设置 replyTo 字段指定回调队列。服务端处理请求并发送响应消息到回调队列。客户端在回调队列上等待响应消息,并检查 correlationId 属性以确保它是所期望的响应。

适用场景:需要实现远程调用的过程,例如微服务间的通信。


7. Publisher Confirms(发布确认)

角色

  • P (Producer): 生产者。
  • RabbitMQ Server: 消息服务器.

特点:生产者将 Channel 设置为 confirm 模式,发布的每一条消息都会获得一个唯一的 ID。当消息被 RabbitMQ 服务器接收并处理后,服务器会异步地向生产者发送一个确认 (ACK),表明消息已经送达。

适用场景:对数据安全性要求较高的场景,例如金融交易、订单处理。

以上就是RabbitMQ 的七种工作模式,后续会介绍这些工作模式的具体代码实现。感谢阅览!!


本文转载自: https://blog.csdn.net/Y_1215/article/details/142690057
版权归原作者 ngioig 所有, 如有侵权,请联系我们删除。

“RabbitMQ 7种工作模式详解及应用场景”的评论:

还没有评论