RabbitMQ、Kafka、RocketMQ三种消息中间件对比总结

不论Kafka还是RabbitMQ和RocketMQ&＃xff0c;作为消息中间件&＃xff0c;其作用为应用解耦、异步通讯、流量削峰填谷等。
拿我之前参加的一个电商项目来说&＃xff0c;订单消息通过MQ从订单系统到支付系统、库存系统等&＃xff0c;当订单信息写入MQ后就不再关心后续操作&＃xff0c;既达到了应用解耦又达到异步通信。因为订单的并发量较大&＃xff0c;为了避免数据库承受不住&＃xff0c;在订单信息持久化时通过MQ&＃43;定时任务将订单信息均匀的持久到数据库中&＃xff0c;达到削峰填谷作用。
那为什么有这么多的MQ&＃xff1f;这些MQ又有什么区别&＃xff1f;

每个MQ的侧重点不一样。

• RabbitMQ
  RabbitMQ由以高性能、健壮以及可伸缩性出名的Erlang语言编写&＃xff0c;在扩展或删除Rabbit服务节点时只需要同步erlang信息即可。另外rabbitmq在数据可靠性的问题上做了很大的努力&＃xff0c;它保证在这里数据是非常可靠的。
• Kafka
  Kafka由Scala和Java编写&＃xff0c;与RabbitMQ不同&＃xff0c;Kafka是一种高吞吐量的分布式消息中间件&＃xff0c;其通过零拷贝、pagecahe技术以及分区的设计实现高吞吐&＃xff0c;同时分区的设计也避免了消息存储瓶颈问题。
• RocketMQ
  RocketMQ是阿里出品的&＃xff0c;参考Kafka架构使用Java语言重新编写的一个消息中间件&＃xff0c;弥补了Kafka的扩展性&＃xff0c;在Kafka基础上扩展了多种消息模式&＃xff0c;比如延迟消息、事务消息。

• RabbitMQ
  RabbitMQ基于AMQP协议实现&＃xff0c;其模型如下&＃xff1a;
  

Kafka与RocketMQ架构类似&＃xff0c;RocketMQ使用NameServer代替了Zookeeper&＃xff0c;这一点我觉得对开发人员是比较友好的&＃xff0c;少了一个组件。

• Kafka
  
• RocketMQ
  

• RabbitMQ
  RabbitMQ支持发布订阅、Topic及RPC多种通讯方式&＃xff0c;满足大部分消息通讯&＃xff0c;并支持死信队列。另外&＃xff0c;RabbitMQ的插件社区支持丰富的插件&＃xff0c;可通过安装插件添加额外的功能。例如&＃xff0c;延迟队列、优先队列、管理控制台等插件。
• Kafka
  相比RabbitMQ&＃xff0c;Kafka只有单一的Topic通讯方式&＃xff0c;消息在消费后依然不支持死信队列、延迟队列等。
• RocketMQ
  RocketMQ也是基于Topic进行通讯&＃xff0c;毕竟架构模型相似&＃xff0c;不过RocketMQ本身支持延迟消息、事务消息等&＃xff0c;功能比较丰富。

每个MQ的功能及作用大差不差&＃xff0c;都有自己的优势以及不足&＃xff0c;选择适合业务的MQ就可以。

Kafka、RabbitMQ、RocketMQ详细了解参考消息中间件专栏