前言

不論Kafka還是RabbitMQ和RocketMQ，作為消息中間件，其作用為應用解耦、異步通訊、流量削峰填谷等。 拿我之前參加的一個電商項目來說，訂單消息通過MQ從訂單系統(tǒng)到支付系統(tǒng)、庫存系統(tǒng)等，當訂單信息寫入MQ后就不再關心后續(xù)操作，既達到了應用解耦又達到異步通信。因為訂單的并發(fā)量較大，為了避免數據庫承受不住，在訂單信息持久化時通過MQ+定時任務將訂單信息均勻的持久到數據庫中，達到削峰填谷作用。 那為什么有這么多的MQ？這些MQ又有什么區(qū)別？本文基于RabbitMQ、Kafka、RocketMQ，從側重點、架構模型、消息通訊以及其他方面對比說明。

側重點

每個MQ的側重點不一樣。

• RabbitMQ RabbitMQ由以高性能、健壯以及可伸縮性出名的Erlang語言編寫，在擴展或刪除Rabbit服務節(jié)點時只需要同步erlang信息即可。另外rabbitmq在數據可靠性的問題上做了很大的努力，它保證在這里數據是非常可靠的。
• Kafka Kafka由Scala和Java編寫，與RabbitMQ不同，Kafka是一種高吞吐量的分布式消息中間件，其通過零拷貝、pagecahe技術以及分區(qū)的設計實現高吞吐，同時分區(qū)的設計也避免了消息存儲瓶頸問題。
• RocketMQ RocketMQ是阿里出品的，參考Kafka架構使用Java語言重新編寫的一個消息中間件，彌補了Kafka的擴展性，在Kafka基礎上擴展了多種消息模式，比如延遲消息、事務消息。

架構模型

• RabbitMQ

RabbitMQ 基于AMQP協(xié)議實現，其模型如下：

Kafka與RocketMQ架構類似，RocketMQ使用NameServer代替了Zookeeper，這一點我覺得對開發(fā)人員是比較友好的，少了一個組件。

• Kafka

• RocketMQ

消息通訊

• RabbitMQ

RabbitMQ支持發(fā)布訂閱、Topic及RPC多種通訊方式，滿足大部分消息通訊，并支持死信隊列。另外，RabbitMQ的插件社區(qū)支持豐富的插件，可通過安裝插件添加額外的功能。例如，延遲隊列、優(yōu)先隊列、管理控制臺等插件。

• Kafka

相比RabbitMQ，Kafka只有單一的Topic通訊方式，消息在消費后依然不支持死信隊列、延遲隊列等。

• RocketMQ

RocketMQ也是基于Topic進行通訊，畢竟架構模型相似，不過RocketMQ本身支持延遲消息、事務消息等，功能比較豐富。

其他對比

總結

每個MQ的功能及作用大差不差，都有自己的優(yōu)勢以及不足，選擇適合業(yè)務的MQ就可以。

到此這篇關于淺談一下RabbitMQ、Kafka和RocketMQ消息中間件對比的文章就介紹到這了,更多相關RabbitMQ、Kafka和RocketMQ對比內容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關文章希望大家以后多多支持腳本之家！

最新評論