Ignite Partition 筆記

數據復制機制： 客戶端根據HASH算出主節點，數據只從客戶端發到主節點
GridNearAtomicSingleUpdateFuture.mapOnTopology
GridNearAtomicSingleUpdateFuture.map
GridNearAtomicAbstractUpdateFuture.sendSingleRequest
GridCacheIoManager.send

當數據復制到主節點時，再從主節點復制到其他節點
GridDhtAtomicCache.updateAllAsyncInternal
GridDhtAtomicAbstractUpdateFuture.map
GridDhtAtomicAbstractUpdateFuture.sendDhtRequests
GridCacheIoManager.send

每當集群拓撲改變時候會重新計算主節點
GridCachePartitionExchangeManager.onDiscoveryEvent
GridDhtPartitionsExchangeFuture.onClusterStateChangeRequest/onCacheChangeRequest/onAffinityChangeRequest/
CacheAffinitySharedManager.applyx
GridAffinityAssignmentCache.calculate
AffinityFunction.assignPartitions

IGNITE 采用 Rendezvous hash 算法，計算每個節點的權重， 只要集群視圖一致，那么客戶端服務端都應用這種算法，找出權重最高的N個節點，
作為主節點和復制節點
RendezvousAffinityFunction：
為每個PARTITION 分配多個集群節點，PARTITION數量為參數傳入RendezvousAffinityFunction，默認1024. 分配的結果表示這個PARTITION的數據應該落在哪些節點上
為每個集群節點計算HASH: 值為節點的CONSISTENTHASHID 對 當前的PARTITION取模，
將HASH排序，然后取前N個節點，N為每個PARTITION最終需要復制到的節點，取決于BACKUP的數量，是否EXCLUDE NEIGHBOR等選項
計算 KEY屬于哪個PARTITION： 分配的結果存在GridAffinityAssignment中

GridCacheContext.allowFastLocalRead 中有一個方法判斷是否可以從本地快速讀取：
topology().partitionState(localNodeId(), part) == OWNING

GridCacheContext.toCacheKeyObject 方法將 key 轉化為KeyCacheObject, 并分配partition, 參考 IgniteCacheObjectProcessorImpl.partition

讀數據：
GridPartitionedSingleGetFuture.mapKeyToNode 方法獲取從哪個節點讀取數據
內部調用GridCacheAffinityManager.partition 和GridCacheAffinityManager.nodesByPartition
然后默認從獲得NODE 列表的第一個讀取數據

新的節點加入后會自動重新REBLANCE數據
CacheAffinitySharedManager.onServerJoin
CacheAffinitySharedManager.initAffinityOnNodeJoin

檢查rebalance 是否完成 CacheAffinitySharedManager.checkRebalanceState

Partition 的狀態 MOVING, OWNING, RENTING, EVICTED, LOST
OWNING 表示分區屬于主節點
RENTING 表示拓撲結構改變以后