前言 市面上消息隊列中間件管理有蠻多的,如:ActiveMQ,RabbitMQ,ZeroMQ,Kafka,MetaMQ,RocketMQ,但我最先接觸的可能就是 Kafka 了,不過那時候為了用,只知道部分實用性的東西,這兩天稍稍花了點時間看了看。 消息隊列 在我看來,消息隊列的出現更多的是解耦合, ...
前言
市面上消息隊列中間件管理有蠻多的,如: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架構項目實戰教程及大廠面試題庫,進我扣裙 :七吧傘吧零而衣零傘 (數字的諧音)轉換下可以找到了,還可以跟老架構師交流
本文的文字及圖片來源於網路加上自己的想法,僅供學習、交流使用,不具有任何商業用途,版權歸原作者所有,如有問題請及時聯繫我們以作處理