數(shù)據(jù)復(fù)制機(jī)制： 客戶端根據(jù)HASH算出主節(jié)點(diǎn)，數(shù)據(jù)只從客戶端發(fā)到主節(jié)點(diǎn)
GridNearAtomicSingleUpdateFuture.mapOnTopology
GridNearAtomicSingleUpdateFuture.map
GridNearAtomicAbstractUpdateFuture.sendSingleRequest
GridCacheIoManager.send

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

當(dāng)數(shù)據(jù)復(fù)制到主節(jié)點(diǎn)時(shí)，再從主節(jié)點(diǎn)復(fù)制到其他節(jié)點(diǎn)
GridDhtAtomicCache.updateAllAsyncInternal
GridDhtAtomicAbstractUpdateFuture.map
GridDhtAtomicAbstractUpdateFuture.sendDhtRequests
GridCacheIoManager.send

每當(dāng)集群拓?fù)涓淖儠r(shí)候會(huì)重新計(jì)算主節(jié)點(diǎn)
GridCachePartitionExchangeManager.onDiscoveryEvent
GridDhtPartitionsExchangeFuture.onClusterStateChangeRequest/onCacheChangeRequest/onAffinityChangeRequest/
CacheAffinitySharedManager.applyx
GridAffinityAssignmentCache.calculate
AffinityFunction.assignPartitions

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

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

GridCacheContext.toCacheKeyObject 方法將 key 轉(zhuǎn)化為KeyCacheObject, 并分配partition, 參考 IgniteCacheObjectProcessorImpl.partition

讀數(shù)據(jù)：
GridPartitionedSingleGetFuture.mapKeyToNode 方法獲取從哪個(gè)節(jié)點(diǎn)讀取數(shù)據(jù)
內(nèi)部調(diào)用GridCacheAffinityManager.partition 和GridCacheAffinityManager.nodesByPartition
然后默認(rèn)從獲得NODE 列表的第一個(gè)讀取數(shù)據(jù)

新的節(jié)點(diǎn)加入后會(huì)自動(dòng)重新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ǎng)頁題目：IgnitePartition筆記
網(wǎng)站地址：http://aaarwkj.com/article46/phojhg.html

成都網(wǎng)站建設(shè)公司_創(chuàng)新互聯(lián)，為您提供面包屑導(dǎo)航、電子商務(wù)、網(wǎng)站營銷、品牌網(wǎng)站設(shè)計(jì)、虛擬主機(jī)、品牌網(wǎng)站建設(shè)

廣告

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