一、前言

博主今天復(fù)習(xí)Nacos源碼的時候，發(fā)現(xiàn)了一個算是有意思的細節(jié)點，這里分享一下。

二、服務(wù)發(fā)現(xiàn)“懶加載”機制

當nacos客戶端運?起來之后，它只是去做服務(wù)注冊、配置獲取等操作；并不會立即去請求服務(wù)信息；當?shù)谝淮握埱髸r候，才會去獲取服務(wù)，即懶加載機制；

1、服務(wù)發(fā)現(xiàn)流程

Client端做服務(wù)發(fā)現(xiàn)時，無論是否能從本地緩存中獲取到服務(wù)實例信息，都會啟動一個定時任務(wù)（每秒做一次服務(wù)實例信息的更新）。然而由于可能多個請求同時要做服務(wù)發(fā)現(xiàn)，這樣總不能每一次做服務(wù)發(fā)現(xiàn)時都去啟動一個定時任務(wù)做服務(wù)實例信息更新吧。所以肯定要有一個機制去確保針對某一個Cluster下的Service，當前Client只會啟動一個定時任務(wù)。

2、HostReactor#scheduleUpdateIfAbsent()

HostReactor#scheduleUpdateIfAbsent()方法負責(zé)啟動做服務(wù)實例信息更新的定時任務(wù)。
從方法名也能看出來：是當定時任務(wù)不存在時，才會啟動一個定時任務(wù)。

private final Map<String, ScheduledFuture<?>> futureMap = new HashMap<String, ScheduledFuture<?>>();

public void scheduleUpdateIfAbsent(String serviceName, String clusters) {
    if (futureMap.get(ServiceInfo.getKey(serviceName, clusters)) != null) {
        return;
    }
    
    synchronized (futureMap) {
        if (futureMap.get(ServiceInfo.getKey(serviceName, clusters)) != null) {
            return;
        }
        
        ScheduledFuture<?> future = addTask(new UpdateTask(serviceName, clusters));
        futureMap.put(ServiceInfo.getKey(serviceName, clusters), future);
    }
}

看一下這個代碼邏輯：

• 為了防止一個實例開啟多個這種定時任務(wù)，會用一個Map來去重，針對這個Map的數(shù)據(jù)添加會采用一個類似雙重檢查鎖的機制，確保Map添加數(shù)據(jù)的線程安全性。
• 如果futureMap中已經(jīng)有了當前服務(wù)，則方法直接返回。
• 這一步是為了減少不必要的同步操作。
• 否則，對futureMap對象加synchronized鎖；同步代碼塊需要再進一步判斷futureMap不為空。
• 因為在多線程并發(fā)場景下，可能多個線程判斷futureMap中都沒有當前服務(wù)，都進入到同步代碼塊，一個線程進入同步代碼塊，將當前服務(wù)添加到futureMap中。
• 其他線程獲取到鎖之后再進入到同步代碼塊，再次判斷futureMap中是否含有當前服務(wù)，如果含有，則方法直接返回。
• 假如同步代碼中不判空，會重復(fù)執(zhí)行將當前服務(wù)添加到futureMap中的操作。

既然是DCL的變種版，為了futureMap沒有被volatile關(guān)鍵字修飾，不會有指令重排序的問題嗎？

• 并不會，futureMap.put()是Map的添加數(shù)據(jù)操作，和對象初始化是兩種場景。

3、DCL

Double check Lock確保類單例的代碼如下：

public class DoubleCheckLazySingleton {

    private volatile static DoubleCheckLazySingleton singleton;

    private DoubleCheckLazySingleton() {
    }

    public DoubleCheckLazySingleton getSingleton() {
        if (singleton == null) {
            synchronized (this) {
                //只有在singleton為null的時候才創(chuàng)建實例
                if (singleton == null) {
                    singleton = new DoubleCheckLazySingleton();
                }
            }
        }
        return singleton;
    }
}

到此這篇關(guān)于Nacos服務(wù)發(fā)現(xiàn)并發(fā)啟動scheduleUpdate定時任務(wù)的文章就介紹到這了,更多相關(guān)Nacos服務(wù)發(fā)現(xiàn)內(nèi)容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！

最新評論