本文的目的是讓讀者快速了解Kafka與消息隊(duì)列之間的關(guān)系，告訴讀者為什么會(huì)考慮使用它的原因。以下為譯文。
　　Kafka最初是由Linkedin社區(qū)開(kāi)發(fā)的一項(xiàng)技術(shù)。簡(jiǎn)而言之，它有點(diǎn)像消息隊(duì)列系統(tǒng)，但它與消息隊(duì)列系統(tǒng)不同的就是它能夠支持pub/sub，可以在許多服務(wù)器上進(jìn)行擴(kuò)展，并重新播放消息。
　　平時(shí)你可能不太關(guān)注這些問(wèn)題，但是當(dāng)你想要采用響應(yīng)式編程風(fēng)格而不是命令式編程風(fēng)格時(shí)，上述這些就是你需要進(jìn)行關(guān)注的了。
　　命令式編程和響應(yīng)式編程之間的區(qū)別
　　命令式編程是我們一開(kāi)始就采用的編程類(lèi)型。當(dāng)發(fā)生了一些事情，換句話說(shuō)，事件發(fā)生了，然后你的代碼被告知發(fā)生了該事件。例如，用戶單擊一個(gè)按鈕，你在代碼中處理這個(gè)事件的地方，就決定了你希望系統(tǒng)接下來(lái)觸發(fā)哪些動(dòng)作。您可以將記錄保存到數(shù)據(jù)庫(kù)中，調(diào)用另一個(gè)服務(wù)，發(fā)送電子郵件，或者將這些動(dòng)作組合在一起。這里最重要一點(diǎn)是，事件是與這些具體發(fā)生的動(dòng)作是直接耦合的。
　　響應(yīng)式編程使用戶能夠響應(yīng)發(fā)生的事件，通常以流的形式出現(xiàn)。多個(gè)關(guān)注點(diǎn)可以訂閱相同的事件，并讓事件在它的域中產(chǎn)生影響，而不管其他域發(fā)生了什么。換句話說(shuō)，它支持松散耦合的代碼，可以很容易地?cái)U(kuò)展到更多的功能。有可能在不同的棧中編碼的各種大的下流系統(tǒng)會(huì)受到事件的影響，甚至是在云的某個(gè)地方執(zhí)行的一大堆沒(méi)有服務(wù)器的函數(shù)。
　　從消息隊(duì)列到Kafka
　　為了理解Kafka會(huì)給你的架構(gòu)帶來(lái)什么，讓我們先談?wù)撘幌孪㈥?duì)列。我們之所以從消息隊(duì)列開(kāi)始，是因?yàn)槲覀儗⒂懻撍木窒扌?，然后看看Kafka是如何解決這些問(wèn)題的。
　　消息隊(duì)列允許一組訂閱者從隊(duì)列的末尾提取一條或多條消息。在消息被移除之前，隊(duì)列通常允許執(zhí)行某些級(jí)別的事務(wù)，以確保在消息被刪除之前執(zhí)行所需的操作。
　　并不是所有的隊(duì)列系統(tǒng)都具有相同的功能，但是一旦消息被處理了，就會(huì)從隊(duì)列中刪除掉。如果你仔細(xì)想想，它其實(shí)與命令式編程非常類(lèi)似，首先得發(fā)生一些事情，然后起始系統(tǒng)決定在下游系統(tǒng)中應(yīng)該執(zhí)行哪些操作。
　　盡管可以在隊(duì)列中擴(kuò)展多個(gè)消費(fèi)者，但它們都包含相同的功能，而這只是為了處理負(fù)載和并行處理消息，換句話說(shuō)，它不允許你基于相同的事件啟動(dòng)多個(gè)獨(dú)立的操作。隊(duì)列消息的所有處理器將在相同的域中執(zhí)行相同類(lèi)型的邏輯。這意味著隊(duì)列中的消息實(shí)際上是命令，它適合于命令式編程，而不是一個(gè)適合于響應(yīng)式編程的事件。
　　
　　對(duì)于隊(duì)列，通常在相同的域中為隊(duì)列中的每個(gè)消息執(zhí)行相同的邏輯
　　另一方面，使用Kafka，你可以將消息/事件發(fā)布到主題上，它們會(huì)被持久化。當(dāng)消費(fèi)者收到這些消息時(shí)，他們也不會(huì)被移除掉。這允許你重放消息，但更重要的是，它允許大量的消費(fèi)者基于相同的消息/事件處理各自不同邏輯。
　　你仍然可以在相同的域中進(jìn)行并行處理，但是更重要的是，你還可以添加不同類(lèi)型的消費(fèi)者，這些消費(fèi)者基于相同的事件執(zhí)行不同的邏輯。換句話說(shuō)，對(duì)于Kafka，用戶可以采用一個(gè)被動(dòng)的pub/sub體系結(jié)構(gòu)。

普通下載普通下載

相關(guān)電子資料下載

• kafka相關(guān)命令詳解 81
• Kafka架構(gòu)技術(shù)：Kafka的架構(gòu)和客戶端API設(shè)計(jì) 80
• Spring Kafka的各種用法 91
• kafka client在 spring如何實(shí)現(xiàn) 103
• 降本增效：Grab如何在云上將Kafka消費(fèi)者流量成本降到零 214
• 消息隊(duì)列中如何保證消息的順序性？ 180
• 監(jiān)控Kafka集群的常用的方法和工具介紹 167
• 嵌入式開(kāi)發(fā)中消息隊(duì)列的實(shí)現(xiàn) 142
• 從Kafka中學(xué)習(xí)高性能系統(tǒng)如何設(shè)計(jì) 211
• 物通博聯(lián)WG783-5G-kafka（帶kafka協(xié)議開(kāi)發(fā)調(diào)試）系列工業(yè)智能網(wǎng)關(guān) 134