SpringCloud Consul choose server 選取 與 serverList 更新機制

（SpringCloud Consul  2.2.3）
ribbon-loadbalancer-2.3.0.jar

1. feign 調用時，server 選取的流程：（借助 ribbon 實現的）
可以加一個 feign.RequestInterceptor ，然后在 inteceptor 上打斷點，找到下面的調用關系

1. feign接口
 1.1 org.springframework.cloud.openfeign.ribbon.LoadBalancerFeignClient#execute()
    1.1.1 com.netflix.client.AbstractLoadBalancerAwareClient#executeWithLoadBalancer()
        1.1.1.1 com.netflix.loadbalancer.reactive.LoadBalancerCommand#selectServer()
            1.1.1.1.1 com.netflix.loadbalancer.ZoneAwareLoadBalancer#chooseServer()  // 它自己維護了一個 serverList 列表，每 30s 更新一次

 

// 從 ILoadBalancer#getServerList() 中選取一個 server
com.netflix.loadbalancer.ZoneAwareLoadBalancer#chooseServer()

// 獲取可用的服務 ILoadBalancer#getServerList
com.netflix.loadbalancer.BaseLoadBalancer#getServerList()

 

 

2. SpringCloud Consul ： serverList 更新機制 

com.netflix.loadbalancer.PollingServerListUpdater#start()  // 定時任務，30s 更新一次最新的服務列表信息
    --> org.springframework.cloud.consul.discovery.ConsulServerList#getUpdatedListOfServers() // 斷點打在這里，會發現隔段時間就會被調用

 

com.netflix.loadbalancer.PollingServerListUpdater#start()

public synchronized void start(final UpdateAction updateAction) {
    if (isActive.compareAndSet(false, true)) {
        final Runnable wrapperRunnable = new Runnable() {
            @Override
            public void run() {
                if (!isActive.get()) {
                    if (scheduledFuture != null) {
                        scheduledFuture.cancel(true);
                    }
                    return;
                }
                try {
                    updateAction.doUpdate(); // 更新 serverList
                    lastUpdated = System.currentTimeMillis();
                } catch (Exception e) {
                    logger.warn("Failed one update cycle", e);
                }
            }
        };

        scheduledFuture = getRefreshExecutor().scheduleWithFixedDelay(
                wrapperRunnable,
                initialDelayMs,
                refreshIntervalMs, // 默認 30*1000ms
                TimeUnit.MILLISECONDS
        );
    } else {
        logger.info("Already active, no-op");
    }
}

 

 

 

參考：
https://www.iflym.com/index.php/code/202003190001.html