W3Cschool
恭喜您成為首批注冊(cè)用戶
獲得88經(jīng)驗(yàn)值獎(jiǎng)勵(lì)
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ū)
分區(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ù)消耗端。
Copyright©2021 w3cschool編程獅|閩ICP備15016281號(hào)-3|閩公網(wǎng)安備35020302033924號(hào)
違法和不良信息舉報(bào)電話:173-0602-2364|舉報(bào)郵箱:jubao@eeedong.com
掃描二維碼
下載編程獅App
編程獅公眾號(hào)
聯(lián)系方式:
更多建議: