數(shù)據(jù)復(fù)制機(jī)制: 客戶端根據(jù)HASH算出主節(jié)點(diǎn),數(shù)據(jù)只從客戶端發(fā)到主節(jié)點(diǎn)
GridNearAtomicSingleUpdateFuture.mapOnTopology
GridNearAtomicSingleUpdateFuture.map
GridNearAtomicAbstractUpdateFuture.sendSingleRequest
GridCacheIoManager.send
當(dāng)數(shù)據(jù)復(fù)制到主節(jié)點(diǎn)時,再從主節(jié)點(diǎn)復(fù)制到其他節(jié)點(diǎn)
GridDhtAtomicCache.updateAllAsyncInternal
GridDhtAtomicAbstractUpdateFuture.map
GridDhtAtomicAbstractUpdateFuture.sendDhtRequests
GridCacheIoManager.send
每當(dāng)集群拓?fù)涓淖儠r候會重新計(jì)算主節(jié)點(diǎn)
GridCachePartitionExchangeManager.onDiscoveryEvent
GridDhtPartitionsExchangeFuture.onClusterStateChangeRequest/onCacheChangeRequest/onAffinityChangeRequest/
CacheAffinitySharedManager.applyx
GridAffinityAssignmentCache.calculate
AffinityFunction.assignPartitions
IGNITE 采用 Rendezvous hash 算法,計(jì)算每個節(jié)點(diǎn)的權(quán)重, 只要集群視圖一致,那么客戶端服務(wù)端都應(yīng)用這種算法,找出權(quán)重最高的N個節(jié)點(diǎn),
作為主節(jié)點(diǎn)和復(fù)制節(jié)點(diǎn)
RendezvousAffinityFunction:
為每個PARTITION 分配多個集群節(jié)點(diǎn),PARTITION數(shù)量為參數(shù)傳入RendezvousAffinityFunction,默認(rèn)1024. 分配的結(jié)果表示這個PARTITION的數(shù)據(jù)應(yīng)該落在哪些節(jié)點(diǎn)上
為每個集群節(jié)點(diǎn)計(jì)算HASH: 值為節(jié)點(diǎn)的CONSISTENTHASHID 對 當(dāng)前的PARTITION取模,
將HASH排序,然后取前N個節(jié)點(diǎn),N為每個PARTITION最終需要復(fù)制到的節(jié)點(diǎn),取決于BACKUP的數(shù)量,是否EXCLUDE NEIGHBOR等選項(xiàng)
計(jì)算 KEY屬于哪個PARTITION: 分配的結(jié)果存在GridAffinityAssignment中
GridCacheContext.allowFastLocalRead 中有一個方法判斷是否可以從本地快速讀?。?br/>topology().partitionState(localNodeId(), part) == OWNING
GridCacheContext.toCacheKeyObject 方法將 key 轉(zhuǎn)化為KeyCacheObject, 并分配partition, 參考 IgniteCacheObjectProcessorImpl.partition
讀數(shù)據(jù):
GridPartitionedSingleGetFuture.mapKeyToNode 方法獲取從哪個節(jié)點(diǎn)讀取數(shù)據(jù)
內(nèi)部調(diào)用GridCacheAffinityManager.partition 和GridCacheAffinityManager.nodesByPartition
然后默認(rèn)從獲得NODE 列表的第一個讀取數(shù)據(jù)
新的節(jié)點(diǎn)加入后會自動重新REBLANCE數(shù)據(jù)
CacheAffinitySharedManager.onServerJoin
CacheAffinitySharedManager.initAffinityOnNodeJoin
檢查rebalance 是否完成 CacheAffinitySharedManager.checkRebalanceState
Partition 的狀態(tài) MOVING, OWNING, RENTING, EVICTED, LOST
OWNING 表示分區(qū)屬于主節(jié)點(diǎn)
RENTING 表示拓?fù)浣Y(jié)構(gòu)改變以后
另外有需要云服務(wù)器可以了解下創(chuàng)新互聯(lián)scvps.cn,海內(nèi)外云服務(wù)器15元起步,三天無理由+7*72小時售后在線,公司持有idc許可證,提供“云服務(wù)器、裸金屬服務(wù)器、高防服務(wù)器、香港服務(wù)器、美國服務(wù)器、虛擬主機(jī)、免備案服務(wù)器”等云主機(jī)租用服務(wù)以及企業(yè)上云的綜合解決方案,具有“安全穩(wěn)定、簡單易用、服務(wù)可用性高、性價(jià)比高”等特點(diǎn)與優(yōu)勢,專為企業(yè)上云打造定制,能夠滿足用戶豐富、多元化的應(yīng)用場景需求。
網(wǎng)頁名稱:IgnitePartition筆記-創(chuàng)新互聯(lián)
標(biāo)題路徑:http://muchs.cn/article16/dejpdg.html
成都網(wǎng)站建設(shè)公司_創(chuàng)新互聯(lián),為您提供網(wǎng)站改版、網(wǎng)站策劃、小程序開發(fā)、外貿(mào)網(wǎng)站建設(shè)、靜態(tài)網(wǎng)站、網(wǎng)站維護(hù)
聲明:本網(wǎng)站發(fā)布的內(nèi)容(圖片、視頻和文字)以用戶投稿、用戶轉(zhuǎn)載內(nèi)容為主,如果涉及侵權(quán)請盡快告知,我們將會在第一時間刪除。文章觀點(diǎn)不代表本網(wǎng)站立場,如需處理請聯(lián)系客服。電話:028-86922220;郵箱:631063699@qq.com。內(nèi)容未經(jīng)允許不得轉(zhuǎn)載,或轉(zhuǎn)載時需注明來源: 創(chuàng)新互聯(lián)
猜你還喜歡下面的內(nèi)容