【MQ】常见的几种消息队列及其特点

当前生产环境，使用较多的消息队列有ActiveMQ，RabbitMQ，ZeroMQ，Kafka，MetaMQ，RocketMQ等。

ActiveMQ是Apache出品，最流行的，能力强劲的开源消息总线，并且它一个完全支持JMS规范的消息中间件。其丰富的API、多种集群构建模式使得它成为业界老牌消息中间件，在中小型企业中应用广泛。 但是其性能稍差，在面对高并发的情况下，会出现消息阻塞、堆积、延迟等问题。

Kafka是LinkedIn开源的分布式发布-订阅消息系统，目前归属于Apache顶级项目。 主要特点就是基于Pull的模式来处理消息消费，追求高吞吐量，一开始的目的就是用于日志收集和传输。0.8版本开始支持复制，不支持事务，对消息的重复、丢失、错误没有严格要求，适合产生大量数据的互联网服务的数据收集业务。因为基于操作系统低层的Page Cache，仅仅使用内存管理，不存在内存和磁盘之间的IO操作，所以kafka能够支持廉价的服务器上以每秒100k条数据的吞吐量。(有ack机制，可以保证不丢失，不能保证不重复。)

RocketMQ是阿里开源的消息中间件，已孵化为Apache顶级项目，纯Java开发，具有高吞吐量、高可靠性、适合大规模分布式系统应用的特点。RocketMQ思路起源于Kafka，它对消息的可靠传输以及事务性做了优化，在2.0版本，RocketMQ集群通过Zookeeper进行管理，在3.0之后，放弃Zookeeper，使用NameServer进行集群的管理和协调。 特点： 能够保障消息的顺序消费，提供了丰富的消息拉取等处理模式，消费者可以高效进行水平扩展，能够承载上亿级别数据量级。 可以支持多种集群架构模式：Master-Slave模式、双Master-Slave模式、多主多从模式等等。 支持多种刷盘策略：同步双写、异步复制。借助了零拷贝等技术。

RabbitMQ是一个开源的消息代理和队列服务器，用来通过普通协议在不同的应用之间共享数据(跨平台跨语言)。RabbitMQ是使用Erlang语言编写，并且基于AMQP协议实现。 特点：

Kafka、RabbitMQ、RocketMQ消息中间件的对比 Kafka vs RocketMQ——单机系统可靠性 Kafka vs RocketMQ—— Topic数量对单机性能的影响