亚洲国产精品无码久久一区二区,亚洲色大成网站www永久,亚洲中文字幕无码一久久区

淘寶分布式配置管理服務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更新變動的數據

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

　　數據的變更

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

　　容災

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

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

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

posted on 2014-12-11 23:39 順其自然EVO 閱讀(2251) 評論(0) 編輯收藏所屬分類: 測試學習專欄、數據庫

新用戶注冊刷新評論列表


只有注冊用戶登錄后才能發表評論。




網站導航: 博客園 IT新聞 Chat2DB C++博客博問管理
相關文章: 如何進行Web服務的性能測試？利用drozer進行Android滲透測試 Appium Android Bootstrap源碼分析之命令解析執行 Fliptest—iOS 的應用A/B測試框架 iOS功能測試工具 Frank iOS單元測試框架Kiwi for iOS Appium Android Bootstrap之控件AndroidElement 移動應用測試框架—Calabash Android 簡介 Appium Server源碼分析之作為Bootstrap客戶端移植MonkeyRunner的圖片對比功能實現-Appium篇

qileilove

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

導航

統計

常用鏈接

留言簿(55)

隨筆分類

隨筆檔案

文章分類

文章檔案

搜索

最新評論

閱讀排行榜

評論排行榜