IgnitePartition筆記

數(shù)據復制機制: 客戶端根據HASH算出主節(jié)點,數(shù)據只從客戶端發(fā)到主節(jié)點
GridNearAtomicSingleUpdateFuture.mapOnTopology
GridNearAtomicSingleUpdateFuture.map
GridNearAtomicAbstractUpdateFuture.sendSingleRequest
GridCacheIoManager.send

創(chuàng)新互聯(lián)堅持“要么做到,要么別承諾”的工作理念,服務領域包括:網站設計、網站制作、企業(yè)官網、英文網站、手機端網站、網站推廣等服務,滿足客戶于互聯(lián)網時代的開陽網站設計、移動媒體設計的需求,幫助企業(yè)找到有效的互聯(lián)網解決方案。努力成為您成熟可靠的網絡建設合作伙伴!

當數(shù)據復制到主節(jié)點時,再從主節(jié)點復制到其他節(jié)點
GridDhtAtomicCache.updateAllAsyncInternal
GridDhtAtomicAbstractUpdateFuture.map
GridDhtAtomicAbstractUpdateFuture.sendDhtRequests
GridCacheIoManager.send

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

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

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

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

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

新的節(jié)點加入后會自動重新REBLANCE數(shù)據
CacheAffinitySharedManager.onServerJoin
CacheAffinitySharedManager.initAffinityOnNodeJoin

檢查rebalance 是否完成 CacheAffinitySharedManager.checkRebalanceState

Partition 的狀態(tài) MOVING, OWNING, RENTING, EVICTED, LOST
OWNING 表示分區(qū)屬于主節(jié)點
RENTING 表示拓撲結構改變以后

網頁題目:IgnitePartition筆記
網站地址:http://www.muchs.cn/article46/phojhg.html

成都網站建設公司_創(chuàng)新互聯(lián),為您提供面包屑導航、電子商務、網站營銷、品牌網站設計、虛擬主機品牌網站建設

廣告

聲明:本網站發(fā)布的內容(圖片、視頻和文字)以用戶投稿、用戶轉載內容為主,如果涉及侵權請盡快告知,我們將會在第一時間刪除。文章觀點不代表本網站立場,如需處理請聯(lián)系客服。電話:028-86922220;郵箱:631063699@qq.com。內容未經允許不得轉載,或轉載時需注明來源: 創(chuàng)新互聯(lián)

網站建設網站維護公司