RabbitMq
image.png
1. 背景
a. AMQP-高级消息队列协议
b. 解耦
c. 方便拓展
2. 概念
A. 消费者和生产者
(1). 生产者-producer创建消息,然后发布(发送到)代理服务器(RabbitMQ)
$1. 什么是消息
a. 有效载荷(payload)
任意数据，任意格式
b. 标签(label)
描述了有效载荷,RabbitMQ通过它能决定谁能获得消息的拷贝
c. 发后即忘(fire-and-forget)的通信方式
(2). 消费者连接到代理服务器,订阅到队列上
a. 队列类似一个具名邮箱
b. 消息在到达队列后,RabbitMQ会把消息传递给其中的一个订阅/监听的消费者
c. 消息标签不会随着有效载荷一同传递
d. 如果需要得知发送方信息,只有把发送方信息放入有效载荷中
(3). 信道(生产者或消费者向服务器建立连接)
a. 建立在tcp连接内的虚拟连接
b. 每条信道都会有一个唯一的ID(AMQP库存储)
c. 避免了每次建立和销毁TCP连接会话带来的开销
d. 避免了遭遇高峰期操作系统TCP的瓶颈
e. 一次tcp连接里可以创建多条信道,既保证了线程的私密性,同时也避免了给操作系统的tcp栈带来额外负担
B. AMQP消息路由
(1). 队列
$1. AMQP消息通信的基础模块
a. 为消息提供了住所,消息在此等待消费
b .对负载均衡来说,队列是绝佳方案,只需附加一堆消费者,并让RabbitMQ以循环的方式均匀的分配发来的消息
c. 队列是RabbitMQ中消息最后的终点(除非消息进入了黑洞)
$2. 消费者通过两种方式接受特定队列里的消息
a. basic.consume 订阅
将信道设置为订阅模式,消息到达队列时自动接受
b. basic.get 单条消息
不建议放在循环里使用,影响性能
消费者应通过consume来实现高吞吐量
$3. 队列没有消费者订阅
消息在队列中等待,直到有消费者订阅,才把消息发给消费者
$4. 多消费者订阅队列
a. 机制
(1). 循环发送给消费者
(2). 每条消息只会发送给一个消费者
$5. 消费者消息确认机制
a. 命令
(1). basic.ack 显示向Rabbit发送确认
(2). auto_ack参数设置为true
b. 机制
(1). 消费者收到消息没有确认就从服务器断开连接
Rabbit会把消息传递给下一位消费者
(2). 消费者收到消息没有确认并且仍在线
不会再往该消费者发送消息了
c. 拒绝消息
(1). 从服务器断开连接
(2). RabbitMQ2.0以上版本,basic.reject
reject命令中的requeue的参数设置
为true 时 ,RabbitMQ会自动把消息传送给下一个消费者
为false时，Rabbit会从队列移除该消息,不会发送给其他消费者
$6. 队列创建
a. 须知
消费者在同一条信道上订阅另一条队列时,无法再声明队列,必须取消订阅,设置信道为传输模式
b. 队列名称
(1). 指定队列名称
(2). 不指定名称
Rabbit随机分配名称并在queue.declare命令中返回
c. 重点参数
(1). exclusive
为true时,队列变成私有的, 只有当前应用程序才能消费队列，可以用来限制一个队列只能有一个消费者
(2). auto-delete
当最后一个消费者取消订阅时,队列就会自动移除
(2). 交换器
$1. 四种类型的交换器
a. direct
如果路由建匹配,消息就被投递到对应的队列
b. fanout
将收到的消息广播到绑定的队列上
c. topic
使来自不同源头的消息到达相同的队列上
(3). 多租户于权限控制
$1. vhost 虚拟主机
a. 方便迁移
b. 数据隔离
$2. 权限控制可以在服务器上或vhost上
a.消息持久化与策略
* 必须点
(1). 消息的投递模式设置成2
(2). 发送给持久化的交换器
(3). 到达持久化的队列
b. AMQP事务
发送方确认
3. 实践
(1). 目的
$1. 解耦
$2. 提高请求处理速度
$3. 方便扩展
(2). 发后即忘模式
$1. 概念
a. 创建任务,放置到交换机上,无需知道结果
$2. 场景运用
a. 日志告警框架
b. 并行处理
(1). 执行主线任务
(2). 附带任务分开进行
(3). 实现rpc
$1. 使用消息来发回应答
a. AMQP消息头字段 reply_to
b. 生产者以该字段创建队列,并监听队列
c. 消费者检查该字段，并以该队列名称作为路由键
$2. 匿名队列
网友评论