Kafka和消息隊列的關系
大?。?/span>0.3 MB 人氣: 2017-09-28 需要積分:1
Kafka最初是由Linkedin社區(qū)開發(fā)的一項技術。簡而言之,它有點像消息隊列系統(tǒng),但它與消息隊列系統(tǒng)不同的就是它能夠支持pub/sub,可以在許多服務器上進行擴展,并重新播放消息。
平時你可能不太關注這些問題,但是當你想要采用響應式編程風格而不是命令式編程風格時,上述這些就是你需要進行關注的了。
命令式編程和響應式編程之間的區(qū)別
命令式編程是我們一開始就采用的編程類型。當發(fā)生了一些事情,換句話說,事件發(fā)生了,然后你的代碼被告知發(fā)生了該事件。例如,用戶單擊一個按鈕,你在代碼中處理這個事件的地方,就決定了你希望系統(tǒng)接下來觸發(fā)哪些動作。您可以將記錄保存到數(shù)據(jù)庫中,調(diào)用另一個服務,發(fā)送電子郵件,或者將這些動作組合在一起。這里最重要一點是,事件是與這些具體發(fā)生的動作是直接耦合的。
響應式編程使用戶能夠響應發(fā)生的事件,通常以流的形式出現(xiàn)。多個關注點可以訂閱相同的事件,并讓事件在它的域中產(chǎn)生影響,而不管其他域發(fā)生了什么。換句話說,它支持松散耦合的代碼,可以很容易地擴展到更多的功能。有可能在不同的棧中編碼的各種大的下流系統(tǒng)會受到事件的影響,甚至是在云的某個地方執(zhí)行的一大堆沒有服務器的函數(shù)。
從消息隊列到Kafka
為了理解Kafka會給你的架構帶來什么,讓我們先談論一下消息隊列。我們之所以從消息隊列開始,是因為我們將討論它的局限性,然后看看Kafka是如何解決這些問題的。
消息隊列允許一組訂閱者從隊列的末尾提取一條或多條消息。在消息被移除之前,隊列通常允許執(zhí)行某些級別的事務,以確保在消息被刪除之前執(zhí)行所需的操作。
并不是所有的隊列系統(tǒng)都具有相同的功能,但是一旦消息被處理了,就會從隊列中刪除掉。如果你仔細想想,它其實與命令式編程非常類似,首先得發(fā)生一些事情,然后起始系統(tǒng)決定在下游系統(tǒng)中應該執(zhí)行哪些操作。
盡管可以在隊列中擴展多個消費者,但它們都包含相同的功能,而這只是為了處理負載和并行處理消息,換句話說,它不允許你基于相同的事件啟動多個獨立的操作。隊列消息的所有處理器將在相同的域中執(zhí)行相同類型的邏輯。這意味著隊列中的消息實際上是命令,它適合于命令式編程,而不是一個適合于響應式編程的事件。
![Kafka和消息隊列的關系](/uploads/allimg/170928/2362486-1F92QH522521.png)
對于隊列,通常在相同的域中為隊列中的每個消息執(zhí)行相同的邏輯
另一方面,使用Kafka,你可以將消息/事件發(fā)布到主題上,它們會被持久化。當消費者收到這些消息時,他們也不會被移除掉。這允許你重放消息,但更重要的是,它允許大量的消費者基于相同的消息/事件處理各自不同邏輯。
你仍然可以在相同的域中進行并行處理,但是更重要的是,你還可以添加不同類型的消費者,這些消費者基于相同的事件執(zhí)行不同的邏輯。換句話說,對于Kafka,用戶可以采用一個被動的pub/sub體系結構。
非常好我支持^.^
(0) 0%
不好我反對
(0) 0%
下載地址
Kafka和消息隊列的關系下載
相關電子資料下載
- kafka相關命令詳解 81
- Kafka架構技術:Kafka的架構和客戶端API設計 80
- Spring Kafka的各種用法 91
- kafka client在 spring如何實現(xiàn) 103
- 降本增效:Grab如何在云上將Kafka消費者流量成本降到零 214
- 消息隊列中如何保證消息的順序性? 180
- 監(jiān)控Kafka集群的常用的方法和工具介紹 167
- 嵌入式開發(fā)中消息隊列的實現(xiàn) 142
- 從Kafka中學習高性能系統(tǒng)如何設計 211
- 物通博聯(lián)WG783-5G-kafka(帶kafka協(xié)議開發(fā)調(diào)試)系列工業(yè)智能網(wǎng)關 134