SpringCloud 消費(fèi)群體

2023-11-24 15:31 更新

盡管發(fā)布-訂閱模型使通過共享主題輕松連接應(yīng)用程序變得很重要，但是通過創(chuàng)建給定應(yīng)用程序的多個實(shí)例進(jìn)行擴(kuò)展的能力同樣重要。這樣做時，會將應(yīng)用程序的不同實(shí)例置于競爭的消費(fèi)者關(guān)系中，在該消費(fèi)者關(guān)系中，僅其中一個實(shí)例可以處理給定消息。

Spring Cloud Stream通過消費(fèi)者群體的概念對這種行為進(jìn)行建模。（Spring Cloud Stream消費(fèi)者組類似于Kafka消費(fèi)者組并受其啟發(fā)。）每個消費(fèi)者綁定都可以使用spring.cloud.stream.bindings.<channelName>.group屬性來指定組名。對于下圖所示的消費(fèi)者，此屬性將設(shè)置為spring.cloud.stream.bindings.<channelName>.group=hdfsWrite或spring.cloud.stream.bindings.<channelName>.group=average。

圖28.3 Spring Cloud Stream消費(fèi)群體

SCSt小組

訂閱給定目標(biāo)的所有組都將收到已發(fā)布數(shù)據(jù)的副本，但是每個組中只有一個成員從該目標(biāo)接收給定消息。默認(rèn)情況下，未指定組時，Spring Cloud Stream會將應(yīng)用程序分配給與所有其他使用者組具有發(fā)布-訂閱關(guān)系的匿名且獨(dú)立的單成員使用者組。


以上內(nèi)容是否對您有幫助：
在線筆記
App下載
App下載

掃描二維碼

下載編程獅App

公眾號
微信公眾號

編程獅公眾號