前言
市面上消息隊列中間件管理有蠻多的，如：ActiveMQ，RabbitMQ，ZeroMQ，Kafka，MetaMQ，RocketMQ，但我最先接觸的可能就是 Kafka 了，不過那時候為了用，只知道部分實用性的東西，這兩天稍稍花了點時間看了看。
消息隊列
在我看來，消息隊列的出現更多的是解耦合，我們不需關心數據的來處和出處，生產者和消費者可能都不知道對方是一種什么樣的存在方式，而且解決了突發的數據劇增現象. 我在例子中曾這樣實驗過
- 線程跑一會睡眠 20ms
- 線程一直在跑
實驗 1 的處理速度可以跟的上生產速度，offset 一直指向 end，但實驗 2 生產速度大幅上升，處理速度明顯跟不上，我停止生產后，幾毫秒再去看，offset 才指向 end。
例子
通過例子了解的可能會更加的快，這里我使用 docker-compose 搭建的 kafka 集群
SpringBoot 和 kafka 生產者
https://github.com/tokeneros/kafka_produce...SpringBoot 和 kafka 消費者
https://github.com/tokeneros/kafka_consumt...最后注意：光理論是不夠的。在此順便送大家十套2020最新JAVA架構項目實戰教程及大廠面試題庫，進我扣裙 ：七吧傘吧零而衣零傘 （數字的諧音）轉換下可以找到了，還可以跟老架構師交流
本文的文字及圖片來源於網絡加上自己的想法,僅供學習、交流使用,不具有任何商業用途,版權歸原作者所有,如有問題請及時聯系我們以作處理