Kafka消息隊列的兩種模式

消息隊列包括兩種模式，點(diǎn)對點(diǎn)模式（point to point， queue）和發(fā)布/訂閱模式（publish/subscribe，topic）

1、點(diǎn)對點(diǎn)模式

點(diǎn)對點(diǎn)模式下包括三個角色：

• 消息隊列
• 發(fā)送者 (生產(chǎn)者)
• 接收者（消費(fèi)者）

消息發(fā)送者生產(chǎn)消息發(fā)送到queue中，然后消息接收者從queue中取出并且消費(fèi)消息。消息被消費(fèi)以后，queue中不再有存儲，所以消息接收者不可能消費(fèi)到已經(jīng)被消費(fèi)的消息。

點(diǎn)對點(diǎn)模式特點(diǎn)：

• 每個消息只有一個接收者（Consumer）(即一旦被消費(fèi)，消息就不再在消息隊列中)；
• 發(fā)送者和接收者間沒有依賴性，發(fā)送者發(fā)送消息之后，不管有沒有接收者在運(yùn)行，都不會影響到發(fā)送者下次發(fā)送消息；
• 接收者在成功接收消息之后需向隊列應(yīng)答成功，以便消息隊列刪除當(dāng)前接收的消息；

 2、發(fā)布/訂閱模式 

發(fā)布/訂閱模式下包括三個角色：

• 角色主題（Topic）
• 發(fā)布者(Publisher)
• 訂閱者(Subscriber)

發(fā)布者將消息發(fā)送到Topic,系統(tǒng)將這些消息傳遞給多個訂閱者。

發(fā)布/訂閱模式特點(diǎn)：

• 每個消息可以有多個訂閱者；
• 發(fā)布者和訂閱者之間有時間上的依賴性。針對某個主題（Topic）的訂閱者，它必須創(chuàng)建一個訂閱者之后，才能消費(fèi)發(fā)布者的消息。
• 為了消費(fèi)消息，訂閱者需要提前訂閱該角色主題，并保持在線運(yùn)行；

Kafka消息隊列模型圖解

Kafka 的消息隊列一般分為兩種模式：點(diǎn)對點(diǎn)模式和發(fā)布訂閱模式

Kafka 是支持消費(fèi)者群組的，也就是說 Kafka 中會有一個或者多個消費(fèi)者，如果一個生產(chǎn)者生產(chǎn)的消息由一個消費(fèi)者進(jìn)行消費(fèi)的話，那么這種模式就是點(diǎn)對點(diǎn)模式

如果一個生產(chǎn)者或者多個生產(chǎn)者產(chǎn)生的消息能夠被多個消費(fèi)者同時消費(fèi)的情況，這樣的消息隊列成為發(fā)布訂閱模式的消息隊列

隊列模型非常簡單 topic主題：

隊列 就是消息的分類。

以上為個人經(jīng)驗，希望能給大家一個參考，也希望大家多多支持腳本之家。

最新評論