ONOS點滴學(xué)習(xí)之Distributed Primitives（分布式原語）

成都創(chuàng)新互聯(lián)專注于上海企業(yè)網(wǎng)站建設(shè),成都響應(yīng)式網(wǎng)站建設(shè),商城建設(shè)。上海網(wǎng)站建設(shè)公司,為上海等地區(qū)提供建站服務(wù)。全流程按需設(shè)計，專業(yè)設(shè)計，全程項目跟蹤，成都創(chuàng)新互聯(lián)專業(yè)和態(tài)度為您提供的服務(wù)

EventuallyConsistentMap

Eventually consistent map提供了弱一致性的保證，以換取讀/寫的性能。所有的讀都是在本地下執(zhí)行的，所有的寫都是先更新本地，然后再將更新傳播到后臺的其他副本。用戶可以使用ClockService來配置該Map，ClockService被用于時間戳標(biāo)識各種更新事件。時間戳用于確保每個副本以正確的順序更新到本地狀態(tài)。Eventually consistent map通過一個名為anti-entropy“反熵”的輕量級背景程序，修復(fù)了由于丟失的更新導(dǎo)致不同步的副本。

An eventually consistent map完全復(fù)制了它的所有狀態(tài)。這意味著集群中的每個節(jié)點都將擁有該Map內(nèi)容的完整副本。狀態(tài)存儲在每個節(jié)點的內(nèi)存中，這意味著一個完整的集群重啟將導(dǎo)致數(shù)據(jù)丟失。我們將引入一個選項，將數(shù)據(jù)保存到磁盤，這樣它就可以在完整的集群重啟時存活下來。

ConsistentMap

需要強一致性保障的應(yīng)用可以使用ConsistentMap 原語。ConsistentMap支持java.util.concurrent.ConcurrentMap風(fēng)格的條件更新操作，它確保所有給定鍵(在Map中)的所有操作都被序列化為強一致性。讓我們實現(xiàn)這一目標(biāo)的基本協(xié)議是Raft。此外，整個key空間(用于映射)被分區(qū)，以確保具有良好的擴展特性。例如，一致性映射中的每個鍵都映射到單個分區(qū)或shard。每個shard的一致性通過一個單獨的Raft共識簇來維持。這樣可以確保映射到不同分區(qū)key的操作可以獨立進(jìn)行。在N節(jié)點集群中，默認(rèn)情況下我們創(chuàng)建了N個shards。每個shard的責(zé)任在于3個不同的節(jié)點，因此即使其中一個節(jié)點失敗，也確保了shard可用性。

LeadershipService

ONOS有一項服務(wù)，可以為任意主題的領(lǐng)導(dǎo)人選舉提供便利。該服務(wù)確保在任何給定的時間點，單個控制器節(jié)點充當(dāng)給定主題的領(lǐng)導(dǎo)者。在任何給定的時間點，LeadershipService 都可以為多個主題的領(lǐng)導(dǎo)人選舉提供便利，同樣，每個控制器節(jié)點也可以同時參與多個主題的領(lǐng)導(dǎo)競選。

DistributedSet

與它的名字相似的，這是一個數(shù)據(jù)結(jié)構(gòu)，在分布式環(huán)境下提供了set的概念。

DistributedQueue

提供一個分布式FIFO隊列抽象，通過長輪詢支持非阻塞dequeue操作。

AtomicCounter

這類似于AtomicLong，但在分布式環(huán)境中。常用語全局唯一計數(shù)。

AtomicValue

AtomicReference的一個分布式版本。

LogicalClockService

該服務(wù)對于為各種事件分配全局有序時間戳非常有用。這對于在分布式環(huán)境下排序事件非常有用。

ClusterCommunicationService

該服務(wù)是其基本功能，允許控制器實例通過制造rpc來與他人進(jìn)行通信。控制器可以注冊在收到特定類型的消息時要調(diào)用的處理程序。該服務(wù)支持多種集群通信原語，如:單播、多播和廣播。

ClusterService

這個服務(wù)用來發(fā)現(xiàn)集群中的其他節(jié)點及其當(dāng)前狀態(tài)(存活或死亡)

wiki地址：https://wiki.onosproject.org/display/ONOS/Distributed+Primitives