rabbitmq

应用场景

1. 解耦 ：降低发送者和接收者的耦合度
2. 有效均衡接收者的负载，降低服务并发。

系统架构

image.png

相关定义：

Broker： 简单来说就是消息队列服务器实体
Exchange： 消息交换机，它指定消息按什么规则，路由到哪个队列
Queue： 消息队列载体，每个消息都会被投入到一个或多个队列
Binding： 绑定，它的作用就是把exchange和queue按照路由规则绑定起来
Routing Key： 路由关键字，exchange根据这个关键字进行消息投递
VHost： 虚拟主机，一个broker里可以开设多个vhost，用作不同用户的权限分离。
Producer： 消息生产者，就是投递消息的程序
Consumer： 消息消费者，就是接受消息的程序
Channel： 消息通道，在客户端的每个连接里，可建立多个channel，每个channel代表一个会话任务

由Exchange、Queue、RoutingKey三个才能决定一个从Exchange到Queue的唯一的线路。

exchange_type :
fanout: 路由到所有他绑定的query中
direct : 它会把消息路由到那些Binding key与Routing key完全匹配的Queue中。
topic : 在direct基础之上添加模糊匹配
headers : 根据header进行匹配

消息根据exchange_type + routingKey => query

持久化

消息队列持久化包括3个部分：

1、exchange持久化，在声明时指定durable => true
2、queue持久化，在声明时指定durable => true
3、消息持久化，在投递时指定delivery_mode=> 2（1是非持久化）

如果exchange和queue都是持久化的，那么它们之间的binding也是持久化的

kafka 的区别

kfaka 严格控制顺序
rabbitmq 不保证顺序