SpringCloud 消費群體

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

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

圖28.3 Spring Cloud Stream消費群體

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