ONOS點滴學習之Distributed Primitives（分布式原語）

ONOS點滴學習之Distributed Primitives（分布式原語）

EventuallyConsistentMap

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

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

ConsistentMap

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

LeadershipService

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

DistributedSet

與它的名字相似的，這是一個數據結構，在分布式環境下提供了set的概念。

DistributedQueue

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

AtomicCounter

這類似于AtomicLong，但在分布式環境中。常用語全局唯一計數。

AtomicValue

AtomicReference的一個分布式版本。

LogicalClockService

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

ClusterCommunicationService

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

ClusterService

這個服務用來發現集群中的其他節點及其當前狀態(存活或死亡)

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