python使用pika扩展库操作RabbitMQ的流程梳理。

1. 客户端连接到消息队列服务器，打开一个channel。
2. 客户端声明一个exchange，并设置相关属性。(可以省略，不过必须保证所指定的交换器存在)
3. 客户端声明一个queue，并设置相关属性。(可以省略，不过必须保证所指定的队列存在)
4. 客户端使用routing key，在exchange和queue之间建立好绑定关系。(可以省略，不过必须保证其绑定关系)

作为生产者
客户端投递消息到exchange。

作为消费者
客户端通过队列接收消息，处理后进行应答。

- 阅读剩余部分 -

之前通过比较选择，决定采用RabbitMQ这种消息队列来做中间件，目的舒缓是为了让整个架构的瓶颈环节。这里是做具体实施，用lua访问RabbitMQ消息队列。

RabbitMQ消息队列有几个比较重要的概念：生产者Producer,消费者Consumer,交换器Exchanges,队列Queues

- 阅读剩余部分 -

之所以要捣鼓这个，一方面是规划lua与redis交互后把redis与mysql的同步事务通过MQ发布出去。其他程序订阅该频道后去处理写入mysql的操作。另一方面，在实际情况中进程会遇到需要通过消息队列来处理各个环节间的延迟和阻塞带来的影响。

MQ的集群可扩展性、跨语言开发也确实很吸引。

在对比各个MQ平台后，对可靠性和成熟程度、各种语言的支持库和各种MQ协议的支持。最终选择rabbitMQ。

- 阅读剩余部分 -