RabbitMQ消息队列中的几种典型问题再探

Posted 2022-11-05 宇宙歌者

转载请注明出处，作者:SoaringTiger http://blog.csdn.net/soaring_tiger/article/details/51039938

RabbitMQ 的官网教程当中展示了六个例子，但是并没有更深入的介绍在复杂需求下的解决方案

本文将结合官网教程和《RabbitMQ in Action》以及Pika 官方例子的基础上进一步探寻、总结和澄清一些问题：

基础概念再澄清

刚刚接触RabbitMQ的时候，可能会被扑面而来的一堆概念搞的有些糊涂，又是 Exchange（交换器）、又是Queue（队列）、又是Routing_Key（路由）；还有什么 Connection（连接）、Channel（管道）。而且各个官网的例子当中，有些概念会出现、有些又不会出现，也没有特别的讲清楚，所以我们还是要先把概念和流程搞搞清楚。

1、基础概念

既然我们用RabbitMQ来处理消息，那么我们就要清楚这个消息到底是什么。

（例1）：从实体的角度，我们可以把消息（Message）看成是个货物：我们从某宝、某东上买的货物，这个货物由厂家生产出来、通过卖家、快递送给我们，其中：货物就是“消息”，厂家就是生产者（publisher）、买家就是消费者（consumer）、某宝等平台就是交换器（Exchange）、物流快递就是队列（queue）。

（例2）：从虚拟的角度，我们也可以把消息 看成是个订单，这个时候，我们就是订单（Message）的生产者、而商家就成了订单的消费者，而这个时候的队列就不是快递而是运行在电商平台（Exchange）上的信息流了。

2、消息的生命周期

把大象放进冰箱要几步？
答：3步,第一步把冰箱门打开,第二步把大象放进去,第三步把冰箱门关上。

那么我们要在电商平台上下一个订单需要哪几步?
第一步：打开电脑
第二步：打开浏览器
第三步：打开某东网站
第四步：选定商品
第五步：选择付款方式（某东支付 or 白条支付 or 某信支付）
第六步：确认付款
第七步：关闭浏览器
第八步：关闭电脑

我们把消费的过程和消息队列的生命周期对应一下，会发现有一定相似性
第一步：打开电脑 （连接到指定的RabbitMQ服务器 ，建立connection）
第二步：打开浏览器 （获取信道、即open channel）
第三步：打开某东网站 （声明交换器、即exchange_declare）
第四步：选定商品 （声明队列、即 queue_declare）
第五步：选择付款方式 （把队列和交换器绑定起来、即 queue_bind）
第六步：确认付款 （消费信息、即 basic_consume ）
第七步：关闭浏览器 （关闭信道、即 close channel）
第八步：关闭电脑 （关闭连接、即 close connection）

一个完整的消息过程要包含上述八步，但是在打开电脑之后，其实你可以选择的事情有很多：你可以打开不止一个浏览器（channel）、也可以在不同的浏览器里打开很多个电商网站（exchange）、更不用说你在网站上可以任意的选择商品（queue）、以及选择喜欢的支付方式（queue_bind）。也就是说，connection只有一个、但是channel、exchange、exchange_type、queue、routing_key都可以根据一定的规则以及需求来组织。

表格

Markdown　Extra　表格语法：

项目	价格
Computer	$1600
Phone	$12
Pipe	$1

可以使用冒号来定义对齐方式：

项目	价格	数量
Computer	1600 元	5
Phone	12 元	12
Pipe	1 元	234

定义列表

Markdown　Extra　定义列表语法： 项目１ 项目２

定义 A

定义 B

项目３

定义 C

定义 D

定义D内容

代码块

代码块语法遵循标准markdown代码，例如：

@requires_authorization
def somefunc(param1='', param2=0):
    '''A docstring'''
    if param1 > param2: # interesting
        print 'Greater'
    return (param2 - param1 + 1) or None
class SomeClass:
    pass
>>> message = '''interpreter
... prompt'''

脚注

生成一个脚注1.

目录

用 [TOC]来生成目录：

• • • RabbitMQ 的官网教程当中展示了六个例子但是并没有更深入的介绍在复杂需求下的解决方案
    • 基础概念再澄清
      • 1基础概念
      • 2消息的生命周期
    • 表格
    • 定义列表
    • 代码块
    • 脚注
    • 目录
    • 数学公式
    • UML 图
  • 离线写博客
  • 浏览器兼容

数学公式

使用MathJax渲染LaTex 数学公式，详见math.stackexchange.com.

• 行内公式，数学公式为：$\\Gamma(n) = (n-1)!\\quad\\forall n\\in\\mathbb N$。
• 块级公式：

$$x = \\dfrac-b \\pm \\sqrtb^2 - 4ac2a$$

更多LaTex语法请参考 这儿.

UML 图:

可以渲染序列图：

或者流程图：

• 关于 序列图 语法，参考 这儿,
• 关于 流程图 语法，参考 这儿.

离线写博客

即使用户在没有网络的情况下，也可以通过本编辑器离线写博客（直接在曾经使用过的浏览器中输入write.blog.csdn.net/mdeditor即可。Markdown编辑器使用浏览器离线存储将内容保存在本地。

用户写博客的过程中，内容实时保存在浏览器缓存中，在用户关闭浏览器或者其它异常情况下，内容不会丢失。用户再次打开浏览器时，会显示上次用户正在编辑的没有发表的内容。

博客发表后，本地缓存将被删除。　

用户可以选择 把正在写的博客保存到服务器草稿箱，即使换浏览器或者清除缓存，内容也不会丢失。

注意：虽然浏览器存储大部分时候都比较可靠，但为了您的数据安全，在联网后，请务必及时发表或者保存到服务器草稿箱。

浏览器兼容

1. 目前，本编辑器对Chrome浏览器支持最为完整。建议大家使用较新版本的Chrome。
2. IE９以下不支持
3. IE９，１０，１１存在以下问题
   
   1. 不支持离线功能
   2. IE9不支持文件导入导出
   3. IE10不支持拖拽文件导入

---

---

1. 这里是 脚注 的 内容. ↩