图解RabbitMQ

Posted 2020-11-05 南墙

花点时间重新把rabbitMQ的整体流程粗略的梳理了一遍，便于理解。总体来说，消息产生者->queue->消息消费者可以图解如下：

文字解说：消息产生者 producter 和 consumer 通过 TCP 连接到 rabbitmq server 进行消息的发生和接收，且消息数据的传递都是在 Channel 中进行。每一个 message 经产生后发送给交换器 exchange 时，会带一个路由键 Routing key，用于与 Binding Key 配合，标记这是属于哪个 queue 的消息。exchange 并不会对消息进行存储，而是起到一个枢纽的作用，通过 Binding Key 指定当前的 Exchange 下什么样的  Routing Key 对应到什么样的 queue ，即消息应该属于哪个 queue 。消费者 consumer 从 queue 中获取消息，针对同一个 queue 可以有多个不同的消费者，但是此时 queue 中的消息会被平均分摊给这些消费者进行处理，而不是每个消费者都接收这个 queue 的全部消息。

注意：message传递到queue时，主要是Routing Key和Binding Key在起桥梁作用，需要这二者进行匹配才能正常的传递，所以目前存在三种匹配类型（exchange types）：完全匹配（Direct）、模式匹配（Topic）、忽略匹配（Fanout）。

Direct：消息路由到那些Routing Key与Binding Key完全匹配的Queue中，比如Routing Key为key1，则只会转发key1的消息；

Topic：exchange会把消息发送到一个或者多个满足通配符规则的routing key的Queue中。其中*表示匹配一个word，#匹配多个word和路径，路径之间通过.隔开。比如满足key.*.1的routing key有key.test.1；满足#.key的routing key有test1.test2.test3.key。

Fanout：忽略匹配，把所有发送到该exchange的消息路由到所有与它绑定的queue中。