RabbitMQ 是一个基于 AMQP 协议实现的开源消息中间件,其核心概念包括以下几个部分:
-
消息(Message):指数据传输的基本单位,它由消息头(Header)、属性(Properties)和消息体(Body)组成;
-
队列(Queue):指消息的缓存区,用于暂存待处理的消息;
-
交换机(Exchange):指消息的路由器,用于将消息发送到特定的队列中;
-
绑定(Binding):指将交换机和队列进行绑定的过程,通常需要同时指定一个路由键(Routing Key),以便交换机可以将消息路由到正确的队列中。
RabbitMQ 的消息传递原理如下图所示:
具体来说,应用程序将消息发送到 RabbitMQ 的交换机中,交换机根据预先设置的路由规则,将消息路由到一个或多个队列,并将消息存储在队列中。消费者从队列中接收消息,并将消息传送给消费者进行处理。在消息传递的过程中,RabbitMQ 可以保证消息的可靠性、顺序性和及时性。
其中,AMQP(Advanced Message Queuing Protocol)是 RabbitMQ 使用的标准协议,它定义了消息格式、交换机类型、队列类型、路由规则等内容,使得不同的程序之间可以互相通信并共享消息。RabbitMQ 还提供了多种语言的客户端库和管理界面,方便开发人员使用和管理 RabbitMQ 服务。
在RabbitMQ中的几种交换机,以及匹配规则:
RabbitMQ 支持以下 4 种类型的交换机:
-
直连交换机(Direct Exchange):将消息路由到与路由键完全匹配的队列中,它的 routingkey 是一个字符串,可以与队列的 binding key 进行精确匹配。
-
主题交换机(Topic Exchange):将消息路由到与匹配模式相符的队列中,它的 routingkey 是一个由单词和分隔符组成的字符串,其中 * 可以代替一个单词,# 可以代替任意多个单词,用于实现通配符匹配。
-
扇形交换机(Fanout Exchange):将消息广播到所有与交换机绑定的队列中,忽略 routingkey 的值,适用于一对多的广播场景。
-
头部交换机(Headers Exchange):将消息路由到与 header 属性相匹配的队列中,它的 routingkey 是空字符串,要求发送的消息必须携带至少一个 header 属性,通过设置 header-properties 参数来实现复杂的匹配规则。
需要注意的是,可以在绑定队列和交换机时,指定一个 binding key,用于进一步约束消息的路由规则。对于直连交换机和主题交换机,binding key 和 routingkey 需要精确匹配;对于扇形交换机和头部交换机,binding key 被忽略。
标签:routingkey,队列,RabbitMQ,交换机,消息,路由 From: https://www.cnblogs.com/just1t/p/17417447.html