[转][RabbitMQ+Python入门经典] 兔子和兔子窝

高级消息队列协议（AMQP1）是一个异步消息传递所使用的应用层协议规范. AMQP的原始用途只是为金融界提供一个可以彼此协作的消息协议，而现在的目标则是为通用消息队列架构提供通用构建工具. RabbitMQ作为一个工业级的消息队列中间件，基于AMQP协议的实现，由erlang语言编写. 本文讲解 RabbitMQ+Python 的使用.

最近公司要用到服务器推送技术，google了一下，nodejs固然好，但是公司的东西都是python搞的，. 所以选择了python的 Orbited +  RabbitMQ，无奈Orbited文档极其缺乏，所以要做下笔记. 以下都是在windows平台上搞的测试. RabbitMQ：先要装好Erlang，然后下RabbitMQ的win版exe文件安装，由于要用到stomp协议，.

1      什么是RabbitMQ. RabbitMQ是实现AMQP（高级消息队列协议）的消息中间件的一种，最初起源于金融系统，用于在分布式系统中存储转发消息，在易用性、扩展性、高可用性等方面表现不俗. 消息中间件主要用于组件之间的解耦，消息的发送者无需知道消息使用者的存在，反之亦然：. 例如一个日志系统，很容易使用RabbitMQ简化工作量，一个Consumer可以进行消息的正常处理，另一个Consumer负责对消息进行日志记录，只要在程序中指定两个Consumer所监听的queue以相同的方式绑定到同一个exchange即可，剩下的消息分发工作由RabbitMQ完成.

转发请标明出处： http://blog.csdn.net/lmj623565791/article/details/37657225. 本系列教程主要来自于官网入门教程的翻译，然后自己进行了部分的修改与实验，内容仅供参考. 上一篇博客中，我们实现了工作队列，并且我们的工作队列中的一个任务只会发给一个工作者，除非某个工作者未完成任务意外被杀死，会转发给另外的工作者，如果你还不了解： RabbitMQ （二）工作队列.

以下内容由 [五四陈科学院]提供. AMQP协议是一个高级抽象层消息通信协议，RabbitMQ是AMQP协议的实现. 每个rabbitmq-server叫做一个Broker，等着tcp连接进入. 在rabbitmq-server进程内有Exchange，定义了这个消息的发送类型. Queue是进程内的逻辑队列，有多个，有名字.

        在上一节 《RabbitMQ集群类型一：在单节点上构建built-in内置集群》中我们已经学习过：在集群环境中,队列只有元数据会在集群的所有节点同步,但队列中的数据只会存在于一个节点，数据没有冗余且容易丢，甚至在durable的情况下,如果所在的服务器节点宕机，就要等待节点恢复才能继续提供消息服务.

传说rabbitmq网络层实现的优雅高效,于是我就尝试着将其中的网络层抽取出来,模拟着做了一个echo服务器,代码放在这里.. rabbitmq的做法是内置状态机,通过切换callback的形式处理不同的业务,这样只有一个子进程处理一个链接,性能提高不少.. 测试这个echo服务器的客户端我使用的是telnet,telnet输入的数据会自动在后面加上”\r\n”发送到对端,于是代码中以这个来判断是否接收了一条消息,抽取出来回复给对端..

摘要：本篇是本人对RabbitMQ使用的关键性问题进行的调研，如性能上限、数据存储、集群等，.             具体的 RabbitMQ概念、使用方法、SpringAMQP配置，假设读者已有了基础. 1.1  RabbitMQ数据速率问题. 在边读边写的情况下：速率只与网络带宽正相关，网络使用率最高能达到接近100%，并且数据使用率很高（90%以上）.

　　实现要点：1、构建本地消息表及定时任务，确保消息可靠发送；2、RabbitMQ可靠消费；3、redis保证幂等. 　　两个服务：订单服务和消息服务. 　　使用springboot构建项目，相关代码如下. //设置消息发送确认回调，发送成功后更新消息表状态. //定时扫描记录表，将发送状态为0的消息再次发送，甚至可以记录重发次数，必要时人工干预，生产环境中需要单独部署定时任务.

dropbox定制优化CPython虚拟机，自己搞了个malloc调度算法. 那个 !!!111cos(0). 期待这次PyCon China 2011.