图解RabbitMQ

Posted 2021-04-24 EnjoyMoving

消息队列可以实现流量削峰、降低系统耦合度、提高系统性能等。

RabbitMQ是一个实现了AMQP协议（Advanced Message Queue Protocol）的消息队列。

RabbitMQ中的概念

• producer： producer 是一个发送消息的应用
  

• exchange：producer 并不会直接将消息发送到 queue 上，而是将消息发送给 exchange，由 exchange 按照一定规则转发给指定queue
  

• queue： queue 用来存储 producer 发送的消息
  

• consumer： consumer是接收并处理消息的应用

RabbitMQ运作原理

RabbitMQ消息传递（单个队列）：

RabbitMQ消息传递（多个队列）：

多个Queue的场景中，消息会被Exchange按一定的路由规则分发到指定的Queue中去：

• 生产者指定Message的routing key，并指定Message发送到哪个Exchange
  

• Queue会通过binding key绑定到指定的Exchange
  

• Exchange根据对比Message的routing key和Queue的binding key，然后按一定的分发路由规则，决定Message发送到哪个Queue

每一类Exchange都有自己的分发路由规则：

Fanout Exchange：忽略key对比，发送Message到Exchange下游绑定的所有Queue

Direct Exchange：比较Message的routing key和Queue的binding key，完全匹配时，Message才会发送到该Queue

Topic Exchange：比较Message的routing key和Queue的binding key，按规则匹配成功时，Message才会发送到该Queue

• routing key命名规则：用"."分割的字母或数字

• 匹配规则：

• *：匹配单个字母或数字

• #：匹配0~多个字母或数字

• 比如：*.stock.#与usd.stock、eur.stock.db匹配；但与stock.nasdaq不匹配

默认Exchange：比较Message的routing key和Queue的名字，完全匹配时，Message才会发送到该Queue

RabbitMQ控制台

RabbitMQ控制台可以：

• 创建Queue
  

• 创建Exchange
  

• 通过binding key绑定Queue到Exchage
  

• 发送消息到Exchange
  

• 从Queue接收消息
  

• 其他运维监控功能

（本文图片来源于网络）

（完）

EnjoyMoving，与你共同成长~

如果觉得有收获，欢迎转发，谢谢~

EnjoyMoving