Nepxion Discovery：Spring Cloud灰度釋出神器

1. 如果你是運維負責人，是否會經常發現，你掌管的測試環境中的服務註冊中心，被一些不負責的開發人員把他本地開發環境註冊上來，造成測試人員測試失敗。你希望可以把本地開發環境註冊給遮蔽掉，不讓註冊。

2. 如果你是運維負責人，生產環境的某個微服務叢集下的某個實體，暫時出了問題，但又不希望它下線。你希望可以把該實體給遮蔽掉，暫時不讓它被呼叫。

3. 如果你是業務負責人，鑒於業務服務的快速迭代性，微服務叢集下的實體釋出不同的版本。你希望根據版本管理策略進行路由，提供給下游微服務區別呼叫，例如訪問控制快速基於版本的不同而切換，例如在不同的版本之間進行流量調撥。

4. 如果你是業務負責人，希望灰度釋出功能可以基於業務場景特色定製，例如根據使用者手機號進行不同伺服器的路由。

5. 如果你是DBA負責人，希望灰度釋出功能可以基於資料庫切換上。

6. 如果你是測試負責人，希望對微服務做A/B測試，那麼透過動態改變版本達到該目的。

使用者可以實現跟業務有關的路由策略，根據業務引數的不同，負載均衡到不同的伺服器。

1. 基於服務的程式設計灰度路由，實現DiscoveryEnabledExtension，透過RequestContextHolder（獲取來自閘道器的Header引數）和ServiceStrategyContext（獲取來自RPC方式的方法引數）獲取業務背景關係引數，進行路由自定義

2. 基於Zuul的程式設計灰度路由，實現DiscoveryEnabledExtension，透過Zuul自帶的RequestContext（獲取來自閘道器的Header引數）獲取業務背景關係引數，進行路由自定義

3. 基於Spring Cloud Api Gateway的程式設計灰度路由，實現DiscoveryEnabledExtension，透過GatewayStrategyContext（獲取來自閘道器的Header引數）獲取業務背景關係引數，進行路由自定義

舉例如下：

基於Rest請求Header頭部自帶版本規則的實時動態路由：

場景舉例：外部->閘道器->A服務，A服務有a1, a2兩個實體，a1和a2是一模一樣的兩個服務，但a1和a2的區別是連的資料庫是不同的。a1對接外部的民生銀行通道，a2對接外部的浦發銀行通道。那麼外部Rest經過閘道器時，自動根據版本號路由到正確的服務上。

如圖所示，當前從Postman發起的請求，當走到example-a服務的時候，只能走1.0版本，到example-b服務的時候，也是1.0版本，到example-c服務的時候，能路由到1.1和1.2版本，下麵的打印出來的結果印證了這個路由方式。

加如下程式碼即可實現該功能：

@Bean
public MyDiscoveryEnabledExtension myDiscoveryEnabledExtension() {
    return new MyDiscoveryEnabledExtension();
}

public class MyDiscoveryEnabledExtension implements DiscoveryEnabledExtension {
    private static final Logger LOG = LoggerFactory.getLogger(MyDiscoveryEnabledExtension.class);

    @Override
    public boolean apply(Server server, Map<String, String> metadata) {
        // 對Rest呼叫傳來的Header引數（例如Token）做策略
        return applyFromHeader(server, metadata);
    }

    // 根據Rest呼叫傳來的Header引數（例如Token），選取執行呼叫請求的服務實體
    private boolean applyFromHeader(Server server, Map<String, String> metadata) {
        RequestContext context = RequestContext.getCurrentContext();
        String token = context.getRequest().getHeader("token");
        // String value = context.getRequest().getParameter("value");

        String serviceId = server.getMetaInfo().getAppName().toLowerCase();

        LOG.info("Zuul端負載均衡使用者定製觸發：serviceId={}, host={}, metadata={}, context={}", serviceId, server.toString(), metadata, context);

        String filterToken = "abc";
        if (StringUtils.isNotEmpty(token) && token.contains(filterToken)) {
            LOG.info("過濾條件：當Token含有'{}'的時候，不能被Ribbon負載均衡到", filterToken);

            return false;
        }

        return true;
    }
}

public class MyDiscoveryEnabledExtension implements DiscoveryEnabledExtension {
    private static final Logger LOG = LoggerFactory.getLogger(MyDiscoveryEnabledExtension.class);

    @Override
    public boolean apply(Server server, Map metadata) {
        // 對RPC呼叫傳來的方法引數做策略
        return applyFromMethd(server, metadata);
    }

    @SuppressWarnings("unchecked")

    private boolean applyFromMethd(Server server, Map<String, String> metadata) {
        ServiceStrategyContext context = ServiceStrategyContext.getCurrentContext();
        Map<String, Object> attributes = context.getAttributes();

        String serviceId = server.getMetaInfo().getAppName().toLowerCase();
        String version = metadata.get(DiscoveryConstant.VERSION);

        LOG.info("Serivice端負載均衡使用者定製觸發：serviceId={}, host={}, metadata={}, context={}", serviceId, server.toString(), metadata, context);

        String filterServiceId = "discovery-springcloud-example-b";
        String filterVersion = "1.0";
        String filterBusinessValue = "abc";
        if (StringUtils.equals(serviceId, filterServiceId) && StringUtils.equals(version, filterVersion)) {
            if (attributes.containsKey(ServiceStrategyConstant.PARAMETER_MAP)) {
                Map<String, Object> parameterMap = (Map<String, Object>) attributes.get(ServiceStrategyConstant.PARAMETER_MAP);
                String value = parameterMap.get("value").toString();
                if (StringUtils.isNotEmpty(value) && value.contains(filterBusinessValue)) {
                    LOG.info("過濾條件：當serviceId={} && version={} && 業務引數含有'{}'的時候，不能被Ribbon負載均衡到", filterServiceId, filterVersion, filterBusinessValue);

                    return false;
                }
            }
        }

        return true;
    }
}

@EventBus
public class MySubscriber {
    @Autowired
    private PluginAdapter pluginAdapter;

    @Subscribe
    public void onCustomization(CustomizationEvent customizationEvent) {
        CustomizationEntity customizationEntity = customizationEvent.getCustomizationEntity();
        String serviceId = pluginAdapter.getServiceId();
        if (customizationEntity != null) {
            Map<String, Map<String, String>> customizationMap = customizationEntity.getCustomizationMap();
            Map<String, String> customizationParameter = customizationMap.get(serviceId);
            // 根據customizationParameter的引數動態切換資料源
        } else {
            // 根據customizationParameter的引數動態切換資料源
        }
    }

    @Subscribe
    public void onRegisterFailure(RegisterFailureEvent registerFailureEvent) {
        System.out.println("========== 註冊失敗, eventType=" + registerFailureEvent.getEventType() + ", eventDescription=" + registerFailureEvent.getEventDescription() + ", serviceId=" + registerFailureEvent.getServiceId() + ", host=" + registerFailureEvent.getHost() + ", port=" + registerFailureEvent.getPort());
    }
}

public class MyRegisterListener extends AbstractRegisterListener {
    @Override
    public void onRegister(Registration registration) {
    }

    @Override
    public void onDeregister(Registration registration) {
    }

    @Override
    public void onSetStatus(Registration registration, String status) {
    }

    @Override
    public void onClose() {
    }
}

public class MyDiscoveryListener extends AbstractDiscoveryListener {
    @Override
    public void onGetInstances(String serviceId, List instances) {
    }

    @Override
    public void onGetServices(List services) {
    }
}

public class MyLoadBalanceListener extends AbstractLoadBalanceListener {
    @Override
    public void onGetServers(String serviceId, List extends Server> servers) {
    }
}

@EventBus
public class MySubscriber {
    @Subscribe
    public void onRegisterFailure(RegisterFailureEvent registerFailureEvent) {
    }
}

圖形化灰度釋出桌面程式：

具體操作不詳細述說了，請看相關影片：

灰度釋出-版本訪問策略：

請訪問http://www.iqiyi.com/w_19rzwzovrl.html，影片清晰度改成720P，然後最大化播放。

灰度釋出-版本權重策略：

請訪問http://www.iqiyi.com/w_19rzs9pll1.html，影片清晰度改成720P，然後最大化播放。

灰度釋出-全鏈路策略：

請訪問http://www.iqiyi.com/w_19s1e0zf95.html，影片清晰度改成720P，然後最大化播放。

實現相關一系列的監控：

任浩軍

贊賞

長按二維碼向我轉賬

受蘋果公司新規定影響，微信 iOS 版的贊賞功能被關閉，可透過二維碼轉賬支援公眾號。

閱讀原文


微信掃一掃
使用小程式
即將開啟”“小程式
取消
開啟