深入RabbitMQ【2025|PDF|Epub|mobi|kindle电子书版本百度云盘下载】

深入RabbitMQPDF格式电子书版下载

注意：本站所有压缩包均有解压码： 点击下载压缩包解压工具

第一篇 RabbitMQ和应用程序体系结构3

第1章 RabbitMQ基础3

1.1 RabbitMQ特性以及好处4

1.1.1 RabbitMQ与Erlang5

1.1.2 RabbitMQ与AMQP6

1.2 谁在使用RabbitMQ，在怎么用7

1.3 松耦合架构的优势8

1.3.1 解耦你的应用10

1.3.2 解耦数据库写入11

1.3.3 无缝添加新功能12

1.3.4 复制数据与事件12

1.3.5 多主（Multi-Master）互联化数据与事件13

1.3.6 高级消息队列模型14

1.4 小结16

第2章 使用AMQ协议与Rabbit进行交互18

2.1 AMQP作为一种RPC传输机制19

2.1.1 启动会话20

2.1.2 调整正确的信道20

2.2 AMQP RPC帧结构21

2.2.1 AMQP帧组件21

2.2.2 帧类型22

2.2.3 将消息编组成帧23

2.2.4 方法帧结构24

2.2.5 内容头帧26

2.2.6 消息体帧26

2.3 使用协议27

2.3.1 声明交换器27

2.3.2 声明队列28

2.3.3 绑定队列到交换器29

2.3.4 发布消息到RabbitMQ29

2.3.5 从RabbitMQ中消费消息30

2.4 用Python编写消息发布者32

2.5 从RabbitMQ中获取消息36

2.6 小结37

第3章 消息属性详解38

3.1 合理使用属性39

3.2 使用content-type属性创建显式的消息契约41

3.3 通过gzip和content-encoding属性压缩消息大小43

3.4 使用message-id和correlation-id引用消息45

3.4.1 Message-id45

3.4.2 Correlation-id45

3.5 创建时间：timestamp属性46

3.6 消息自动过期47

3.7 使用delivery-mode平衡速度和安全性48

3.8 使用app-id和user-id验证消息来源49

3.8.1 app-id50

3.8.2 user-id51

3.9 使用type属性获取明细51

3.10 使用reply-to属性实现动态工作流52

3.11 使用消息头自定义属性53

3.12 优先级属性54

3.13 不能使用的属性：cluster-id/reserved54

3.14 小结55

第4章 消息发布的性能权衡58

4.1 平衡投递速度与可靠投递59

4.1.1 如果没有保证机制我们能期待什么60

4.1.2 使用mandatory设置，RabbitMQ将不接受不可路由消息62

4.1.3 发布者确认作为事务的轻量级替代方法64

4.1.4 使用备用交换器处理无法路由的消息66

4.1.5 基于事务的批量处理68

4.1.6 使用HA队列避免节点故障70

4.1.7 HA队列与事务72

4.1.8 通过设置delivery-mode为2将消息持久化到磁盘72

4.2 RabbitMQ回推75

4.2.1 使用rabbitpy来检测连接状态77

4.2.2 使用管理API管理连接状态77

4.3 小结78

第5章 消费消息，避免拉取79

5.1 对比Basic.Get和Basic.Consume80

5.1.1 Basic.Get80

5.1.2 Basic.Consume82

5.2 优化消费者性能84

5.2.1 使用no-ack模式实现更快的吞吐量85

5.2.2 通过服务质量设置控制消费者预取86

5.2.3 消费者使用事务89

5.3 拒绝消息90

5.3.1 Basic.Reject90

5.3.2 Basic.Nack91

5.3.3 死信交换器92

5.4 控制队列94

5.4.1 临时队列94

5.4.2 永久队列97

5.4.3 任意队列设置99

5.5 小结99

第6章 消息路由模式101

6.1 通过direct交换器路由消息102

6.1.1 创建应用架构103

6.1.2 创建RPC工作者107

6.1.3 编写简单的RPC发布者110

6.2 通过fanout交换器广播消息115

6.2.1 修改面部检测消费者116

6.2.2 创建一个简单的图片哈希消费者117

6.3 使用topic交换器有选择地路由消息119

6.4 使用headers交换器有选择地路由消息122

6.5 交换器性能基准124

6.6 交换器间路由125

6.7 使用一致性哈希交换器路由消息127

6.8 小结131

第二篇 管理数据中心或云中的RabbitMQ135

第7章 RabbitMQ集群135

7.1 集群简介136

7.1.1 集群和管理界面137

7.1.2 集群节点类型138

7.1.3 集群和队列行为139

7.2 集群设置142

7.2.1 虚拟机设置143

7.2.2 向集群中添加节点144

7.3 小结147

第8章 跨集群的消息分发148

8.1 联合交换器和联合队列149

8.1.1 联合交换器149

8.1.2 联合队列152

8.2 创建RabbitMQ虚拟机153

8.2.1 创建首个实例153

8.2.2 复制EC2实例159

8.3 连接上游节点162

8.3.1 定义联合中的上游节点162

8.3.2 定义策略164

8.3.3 利用上游集合167

8.3.4 双向联合交换器170

8.3.5 使用联合来升级集群171

8.4 小结173

第三篇 集成与定制177

第9章 使用替代协议177

9.1 MQTT和RabbitMQ178

9.1.1 MQTT协议178

9.1.2 通过MQTT发送消息182

9.1.3 MQTT订阅者184

9.1.4 MQTT插件配置187

9.2 STOMP和RabbitMQ189

9.2.1 STOMP协议190

9.2.2 发布消息191

9.2.3 消费消息195

9.2.4 配置STOMP插件198

9.2.5 在Web浏览器中使用STOMP199

9.3 通过HTTP进行无状态发布200

9.3.1 statelessd的由来200

9.3.2 使用statelessd201

9.3.3 运营架构202

9.3.4 通过statelessd来发布消息203

9.4 小结203

第10章 数据库集成205

10.1 PostgreSQL扩展：pg＿amqp206

10.1.1 安装pg＿amqp扩展207

10.1.2 配置pg＿amqp扩展209

10.1.3 通过pg＿amqp发送消息210

10.2 监听PostgreSQL通知212

10.2.1 安装PostgreSQL LISTEN交换器213

10.2.2 基于策略的配置215

10.2.3 创建交换器217

10.2.4 创建并绑定测试队列217

10.2.5 通过NOTIFY发送消息218

10.3 将消息存入InfluxDB中219

10.3.1 InfluxDB的安装与设置220

10.3.2 安装InfluxDB存储交换器222

10.3.3 创建测试交换器223

10.3.4 测试交换器224

10.4 小结227

附录 准备就绪228

A.1 安装VirtualBox228

A.2 安装Vagrant230

A.3 设置Vagrant虚拟机233

A.4 确认安装234

A.5 小结236