• <ins id="pjuwb"></ins>
    <blockquote id="pjuwb"><pre id="pjuwb"></pre></blockquote>
    <noscript id="pjuwb"></noscript>
          <sup id="pjuwb"><pre id="pjuwb"></pre></sup>
            <dd id="pjuwb"></dd>
            <abbr id="pjuwb"></abbr>

            loop_in_codes

            低調做技術__歡迎移步我的獨立博客 codemaro.com 微博 kevinlynx

            淘寶分布式配置管理服務Diamond

            在一個分布式環境中,同類型的服務往往會部署很多實例。這些實例使用了一些配置,為了更好地維護這些配置就產生了配置管理服務。通過這個服務可以輕松地管理這些應用服務的配置問題。應用場景可概括為:

            zookeeper的一種應用就是分布式配置管理(基于ZooKeeper的配置信息存儲方案的設計與實現)。百度也有類似的實現:disconf

            Diamond則是淘寶開源的一種分布式配置管理服務的實現。Diamond本質上是一個Java寫的Web應用,其對外提供接口都是基于HTTP協議的,在閱讀代碼時可以從實現各個接口的controller入手。

            分布式配置管理

            分布式配置管理的本質基本上就是一種推送-訂閱模式的運用。配置的應用方是訂閱者,配置管理服務則是推送方。概括為下圖:

            其中,客戶端包括管理人員publish數據到配置管理服務,可以理解為添加/更新數據;配置管理服務notify數據到訂閱者,可以理解為推送。

            配置管理服務往往會封裝一個客戶端庫,應用方則是基于該庫與配置管理服務進行交互。在實際實現時,客戶端庫可能是主動拉取(pull)數據,但對于應用方而言,一般是一種事件通知方式。

            Diamond中的數據是簡單的key-value結構。應用方訂閱數據則是基于key來訂閱,未訂閱的數據當然不會被推送。數據從類型上又劃分為聚合和非聚合。因為數據推送者可能很多,在整個分布式環境中,可能有多個推送者在推送相同key的數據,這些數據如果是聚合的,那么所有這些推送者推送的數據會被合并在一起;反之如果是非聚合的,則會出現覆蓋。

            數據的來源可能是人工通過管理端錄入,也可能是其他服務通過配置管理服務的推送接口自動錄入。

            架構及實現

            Diamond服務是一個集群,是一個去除了單點的協作集群。如圖:

            圖中可分為以下部分講解:

            服務之間同步

            Diamond服務集群每一個實例都可以對外完整地提供服務,那么意味著每個實例上都有整個集群維護的數據。Diamond有兩種方式保證這一點:

            • 任何一個實例都有其他實例的地址;任何一個實例上的數據變更時,都會將改變的數據同步到mysql上,然后通知其他所有實例從mysql上進行一次數據拉取(DumpService::dump),這個過程只拉取改變了的數據
            • 任何一個實例啟動后都會以較長的時間間隔(幾小時),從mysql進行一次全量的數據拉取(DumpAllProcessor)

            實現上為了一致性,通知其他實例實際上也包含自己。以服務器收到添加聚合數據為例,處理過程大致為:

            DatumController::addDatum // /datum.do?method=addDatum
                PersistService::addAggrConfigInfo 
                MergeDatumService::addMergeTask // 添加一個MergeDataTask,異步處理
            
            MergeTaskProcessor::process
                PersistService::insertOrUpdate
                    EventDispatcher.fireEvent(new ConfigDataChangeEvent // 派發一個ConfigDataChangeEvent事件
            
            NotifyService::onEvent // 接收事件并處理
                TaskManager::addTask(..., new NotifyTask // 由此,當數據發生變動,則最終創建了一個NoticyTask
            
            // NotifyTask同樣異步處理
            NotifyTaskProcessor::process
                foreach server in serverList // 包含自己
                    notifyToDump // 調用 /notify.do?method=notifyConfigInfo 從mysql更新變動的數據
            

            雖然Diamond去除了單點問題,不過問題都下降到了mysql上。但由于其作為配置管理的定位,其數據量就mysql的應用而言算小的了,所以可以一定程度上保證整個服務的可用性。

            數據一致性

            由于Diamond服務器沒有master,任何一個實例都可以讀寫數據,那么針對同一個key的數據則可能面臨沖突。這里應該是通過mysql來保證數據的一致性。每一次客戶端請求寫數據時,Diamond都將寫請求投遞給mysql,然后通知集群內所有Diamond實例(包括自己)從mysql拉取數據。當然,拉取數據則可能不是每一次寫入都能拉出來,也就是最終一致性。

            Diamond中沒有把數據放入內存,但會放到本地文件。對于客戶端的讀操作而言,則是直接返回本地文件里的數據。

            服務實例列表

            Diamond服務實例列表是一份靜態數據,直接將每個實例的地址存放在一個web server上。無論是Diamond服務還是客戶端都從該web server上取出實例列表。

            對于客戶端而言,當其取出了該列表后,則是隨機選擇一個節點(ServerListManager.java),以后的請求都會發往該節點。

            數據同步

            客戶端庫中以固定時間間隔從服務器拉取數據(ClientWorker::ClientWorkerClientWorker::checkServerConfigInfo)。只有應用方關心的數據才可能被拉取。另外,為了數據推送的及時,Diamond還使用了一種long polling的技術,其實也是為了突破HTTP協議的局限性。如果整個服務是基于TCP的自定義協議,客戶端與服務器保持長連接則沒有這些問題

            數據的變更

            Diamond中很多操作都會檢查數據是否發生了變化。標識數據變化則是基于數據對應的MD5值來實現的。

            容災

            在整個Diamond系統中,幾個角色為了提高容災性,都有自己的緩存,概括為下圖:

            每一個角色出問題時,都可以盡量保證客戶端對應用層提供服務。

            參考文檔

            posted on 2014-10-12 12:57 Kevin Lynx 閱讀(2718) 評論(4)  編輯 收藏 引用 所屬分類: network

            評論

            # re: 淘寶分布式配置管理服務Diamond 2014-10-13 10:05 zuhd

            每個dimond與mysql一個連接嗎?如果dimond節點不斷增添,mysql的壓力是不是要考慮?  回復  更多評論   

            # re: 淘寶分布式配置管理服務Diamond[未登錄] 2014-10-14 00:30 楊粼波

            mysql用redis來替換,可能會更好,redis也支持master-slave,而且支持數據的熱備,即可保證數據的安全性,又可以防止單點故障,而且性能是要比mysql要好一些的。  回復  更多評論   

            # re: 淘寶分布式配置管理服務Diamond 2014-10-14 13:23 Kevin Lynx

            @zuhd
            diamond本身作為服務器不會太多的。  回復  更多評論   

            # re: 淘寶分布式配置管理服務Diamond 2015-01-10 09:40 jogosdofriv

            每個dimond與mysql一個連接嗎?  回復  更多評論   

            日韩中文久久| 国产精品国色综合久久| 久久免费大片| 一本色综合久久| 久久国产精品99国产精| 久久精品国产精品亚洲精品| 久久久久久国产精品美女| 亚洲а∨天堂久久精品| 99久久99这里只有免费的精品| segui久久国产精品| 免费无码国产欧美久久18| 天天综合久久久网| 亚洲中文字幕无码久久综合网| 国产L精品国产亚洲区久久 | 久久er国产精品免费观看2| 国内精品久久久久久麻豆| 色欲av伊人久久大香线蕉影院| 精品久久国产一区二区三区香蕉 | 久久国产欧美日韩精品| 亚洲欧美精品一区久久中文字幕| 久久久久久久久久久久中文字幕 | 精品久久久久久无码专区| 亚洲国产成人久久一区久久| 97超级碰碰碰碰久久久久| 久久久久亚洲AV无码网站| 久久亚洲精品国产亚洲老地址| 精品久久久久久久久久久久久久久| 久久久精品2019免费观看| 亚洲精品国产美女久久久| 国产69精品久久久久APP下载 | 色综合合久久天天综合绕视看 | 国产—久久香蕉国产线看观看| 国产91色综合久久免费分享| 久久亚洲中文字幕精品有坂深雪| 伊人久久精品无码二区麻豆| 久久综合久久综合亚洲| 午夜视频久久久久一区 | 日韩精品久久久肉伦网站| 漂亮人妻被中出中文字幕久久| 欧美日韩精品久久久免费观看| 久久亚洲国产成人影院网站|