SpringCloud 分區(qū)支持

2023-11-24 15:31 更新

Spring Cloud Stream支持在給定應(yīng)用程序的多個(gè)實(shí)例之間分區(qū)數(shù)據(jù)。在分區(qū)方案中,物理通信介質(zhì)(例如代理主題)被視為結(jié)構(gòu)化為多個(gè)分區(qū)。一個(gè)或多個(gè)生產(chǎn)者應(yīng)用程序?qū)嵗龑?shù)據(jù)發(fā)送到多個(gè)消費(fèi)者應(yīng)用程序?qū)嵗?,并確保由共同特征標(biāo)識(shí)的數(shù)據(jù)由同一消費(fèi)者實(shí)例處理。

Spring Cloud Stream提供了用于以統(tǒng)一方式實(shí)現(xiàn)分區(qū)處理用例的通用抽象。因此,無(wú)論代理本身是否自然地被分區(qū)(例如,Kafka)(例如,RabbitMQ),都可以使用分區(qū)。

圖28.4。Spring Cloud Stream分區(qū)

SCSt分區(qū)


分區(qū)是有狀態(tài)處理中的關(guān)鍵概念,對(duì)于確保所有相關(guān)數(shù)據(jù)都一起處理,分區(qū)是至關(guān)重要的(出于性能或一致性方面的考慮)。例如,在帶時(shí)間窗的平均計(jì)算示例中,重要的是,來(lái)自任何給定傳感器的所有測(cè)量都應(yīng)由同一應(yīng)用實(shí)例處理。

 要設(shè)置分區(qū)處理方案,必須同時(shí)配置數(shù)據(jù)產(chǎn)生端和數(shù)據(jù)消耗端。

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

掃描二維碼

下載編程獅App

公眾號(hào)
微信公眾號(hào)

編程獅公眾號(hào)