我们需要消息中间件吗？ · 一切的变化都可以看做是一系列独立事件的变化的组合 · 将峰值熨平，减少对系统的冲击同步转异步，提高吞吐量，量，平换系统的压力 · 解决事件的重发（回放）实现现实中消息的传播方式 · 充当简单的ETL功能，数据流的分发和汇总，通过pipeline的方法处理数据

本备忘录描述实时消息协议块流。块流是一种应用层协议，主要用于通过一种合适的传输层协议（例如TCP）复用、打包多媒体数据流（音频，视频和交互数据）。

Kafka是一种分布式的，基于发布/订阅的消息系统。

消息中间件作为一个中间层软件，它为分布式系统中创建、发送、接收消息提供了一套可靠通用的方法，实现了分布式系统中可靠的、高效的、实时的跨平台数据传输。

运行维护服务包括，信息系统相关的主机设备、操作系统、数据库和存储设备的运行维护服务，保证用户现有的信息系统的正常运行，降低整体管理成本，提高网络信息系统的整体服务水平。同时根据日常维护的数据和记录，提供用户信息系统的整体建设规划和建议，更好的为用户的信息化发展提供有力的保障。

ActiveMQ是Apache出品，最流行的，能力强劲的开源消息总线。ActiveMQ是一个完全支持JMS1.1和J2EE1.4规范的JMSProvider实现

 在云计算环境中，很多时候需要用它其他机器的计算资源，我们有可能会在接收到Message进行处理时，会把一部分计算任务分配到其他节点来完成。那么，RabbitMQ如何使用RPC呢？在本篇文章中，我们将会通过其它节点求来斐波纳契完成示例。

从本篇文章开始，我们将结合更加实际的应用场景来讲解更多的高级用法。  

在这篇文章中，我们将会将同一个Messagedeliver到多个Consumer中。这个模式也被成为"publish/subscribe"。  

  上篇文章中，我们构建了一个简单的日志系统。接下来，我们将丰富它：能够使用不同的severity来监听不同等级的log。比如我们希望只有error的log才保存到磁盘上。 1. Bindings绑定     上篇文章中我们是这么做的绑定： [python]view plaincopy 1. channel.queue_bind(exchange=exchange_name,   2.     

本文将使用Python（pika0.9.8）实现从Producer到Consumer传递数据”Hello,World“。    

 RabbitMQ是一个由erlang开发的AMQP（AdvancedMessageQueue）的开源实现。AMQP的出现其实也是应了广大人民群众的需求，虽然在同步消息通讯的世界里有很多公开标准（如COBAR的IIOP，或者是SOAP等），但是在异步消息处理中却不是这样，只有大企业有一些商业实现（如微软的MSMQ，IBM的WebsphereMQ等），因此，在2006年的6月，Cisco、Redhat、iMatix等联合制定了AMQP的公开标准。   

本文档旨在描述 RocketMQ 的多个关键特性的实现原理，并对消息中间件遇到的各种问题进行总结，阐述RocketMQ 如何解决这些问题。

目前在房仓云平台中存在多个业务场景需要使用消息中间的技术。如注册场景、数据同步场景、订单跟进场景、以及未来需要实现的用户行为和网站运营统计、日志采集等。现在云平台中消息的生产者发送消息到消息的消费者是通过数据库方式实现，即消息的生产者把消息通过API保存进数据库，消息的消费者通过定时轮询数据库获取消息；基于定时轮询方式实现的消息机制存在消息不及时、对数据库产生压力等问题

AActiveMQ什么是queue，什么是topic？什么时候用queue，什么时候用topic？ActiveMQ使用过程中那么多配置，ConnectionFactory,Destination等等都是干啥的？

MQ系统错误记录目录： /var/mqm/errors MQ队列管理器目录（缺省情况下） /var/mqm/qmgrs/<QMName> 注意：必须保证该目录下的任何文件不被修改，不被删除，否则MQ队列管理器将遭到致命破坏，无法恢复，本地消息全部丢失。