DistroConsistencyServiceImpl

?

我們來看臨時實例的一致性實現：DistroConsistencyServiceImpl類的put方法：

public void put(String key, Record value) throws NacosException {// 先將要更新的實例信息寫入本地實例列表onPut(key, value);// 開始集群同步distroProtocol.sync(new DistroKey(key, KeyBuilder.INSTANCE_LIST_KEY_PREFIX), DataOperation.CHANGE,globalConfig.getTaskDispatchPeriod() / 2); }

這里方法只有兩行：

• onPut(key, value)：其中value就是Instances，要更新的服務信息。這行主要是基于線程池方式，異步的將Service信息寫入注冊表中(就是那個多重Map)

• distroProtocol.sync()：就是通過Distro協議將數據同步給集群中的其它Nacos節點

我們先看onPut方法

更新本地實例列表

1）放入阻塞隊列

onPut方法如下：

public void onPut(String key, Record value) {// 判斷是否是臨時實例if (KeyBuilder.matchEphemeralInstanceListKey(key)) {// 封裝 Instances 信息到 數據集：DatumDatum<Instances> datum = new Datum<>();datum.value = (Instances) value;datum.key = key;datum.timestamp.incrementAndGet();// 放入DataStoredataStore.put(key, datum);}if (!listeners.containsKey(key)) {return;}// 放入阻塞隊列，這里的 notifier維護了一個阻塞隊列，并且基于線程池異步執行隊列中的任務notifier.addTask(key, DataOperation.CHANGE); }

notifier的類型就是DistroConsistencyServiceImpl.Notifier，內部維護了一個阻塞隊列，存放服務列表變更的事件：

addTask時，將任務加入該阻塞隊列：

// DistroConsistencyServiceImpl.Notifier類的 addTask 方法： public void addTask(String datumKey, DataOperation action) {if (services.containsKey(datumKey) && action == DataOperation.CHANGE) {return;}if (action == DataOperation.CHANGE) {services.put(datumKey, StringUtils.EMPTY);}// 任務放入阻塞隊列tasks.offer(Pair.with(datumKey, action)); }

超強干貨來襲 云風專訪：近40年碼齡，通宵達旦的技術人生

總結

以上是生活随笔為你收集整理的Nacos源码DistroConsistencyServiceImpl的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。