zuul網關實現灰度發布

本文使用zuul網關實現灰度發布，包括了網關到服務、服務到服務的灰度。項目gitee：https://gitee.com/menbbo/gray-demo.git

服務部署可分為三種方式

1）藍綠發布

　　藍綠發布是通過冗余的方式來解決部署問題，生產環境為綠色配置，冗余的服務為藍色配置。在部署服務時，首先在冗余服務器上部署最新代碼，由部分用戶使用，

若使用沒有問題，則通過負載均衡將所有用戶請求轉發到冗余服務器中，即冗余的服務轉變為生產環境服務。優點是無需停機部署，服務回滾方便。缺點耗費服務器資源。

2）滾動發布

　　滾動發布指每次只部署一個或多個服務，直到服務部署完成為止。優點：用戶無感知，平滑過渡；相比藍綠發布節省服務器資源。缺點：部署復雜，且時間長；遇到

問題回滾比較復雜。

3）灰度發布

　　只升級部分服務，讓少量用戶訪問新部署的服務，其他用戶使用老服務，用戶反饋無誤后，整個集群部署，將用戶遷移到新服務上來。優點：在灰度時即可發現問題及

時處理，保證系統穩定性；如果出現問題，影響范圍小；用戶無感知，過渡平滑。

灰度發布實現步驟：

1）定義規則：哪些用戶可以訪問灰度環境，比如按百分比（10%的用戶可以訪問灰度），或讓固定用戶先體驗灰度環境；

2）利用網關實現路由策略，即網關到服務的路由；

3）服務與服務之間的調用使用ribbon實現灰度規則。

代碼實現

代碼使用zuul網關實現，項目包括了zuul、im、search三個服務，im服務調用search服務，具體實現如下。

1.引入maven依賴，關鍵依賴

  <dependency>
            <groupId>io.jmnarloch</groupId>
            <artifactId>ribbon-discovery-filter-spring-cloud-starter</artifactId>
            <version>2.1.0</version>
 </dependency>        
<dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-zuul</artifactId>
            <version>1.4.6.RELEASE</version>
 </dependency>

2.application.properties配置文件進行配置

server.port=9090

spring.application.name=zuul
#注冊中心
eureka.client.service-url.defaultZone=http://localhost:8761/eureka
eureka.instance.prefer-ip-address=true
eureka.client.registerWithEureka=true 
#zuul網關路由 前綴
zuul.routes.prefix=/zuul
zuul.routes.im.path=/im/**
#im代表自定義服務
zuul.routes.im.service-id=im
#false不會截取  true截取前綴
zuul.routes.im.stripPrefix=true

#http://localhost:9090/zuul/im/index

3.GrayFilter過濾器實現網關到服務的灰度規則

@Component
public class GrayFilter extends ZuulFilter {
    private static final String GRAY = "gray";
    @Override
    public String filterType() {
        return FilterConstants.PRE_TYPE;
    }

    @Override
    public int filterOrder() {
        return 0;
    }

    @Override
    public boolean shouldFilter() {
        //是否開啟過濾
        return true;
    }

    @Override
    public Object run() throws ZuulException {
        //實現灰度邏輯
        //前端在請求頭中攜帶灰度標識字段
        //服務注冊時加入metadata數據，代表該服務節點為灰度節點
        //首先從頭部中獲取標識
        RequestContext currentContext = RequestContext.getCurrentContext();
        HttpServletRequest request = currentContext.getRequest();
        String header = request.getHeader("gray_header");
        //將灰度的請求轉發到meataData中forward為1的服務
        if(StringUtils.equals(header,GRAY)){
            RibbonFilterContextHolder.getCurrentContext().add("forward","1");
        }else {
            RibbonFilterContextHolder.getCurrentContext().add("forward","2");
        }
        return null;
    }
}

4.im、search服務啟動時注冊metadata到注冊中心

eureka.client.service-url.defaultZone=http://localhost:8761/eureka/
eureka.client.enabled=true
#eureka.instance.hostname=localhost
#eureka.instance.instance-id=im
#灰度端口
server.port=8081
#生產端口
#server.port=8082
spring.application.name=im
#灰度發布需要metadata
#灰度為1
eureka.instance.metadata-map.forward=1

 

eureka.client.service-url.defaultZone=http://localhost:8761/eureka
server.port=8089
spring.application.name=search

#灰度為1
eureka.instance.metadata-map.forward=1

5.實現服務到服務的灰度規則

/**
 *  定義服務間灰度調用規則
 */
@Component
public class GrayRule extends AbstractLoadBalancerRule {

    private static final String GRAY = "gray";
    private static final String GRAY_HEADER = "forward";
    private static final String GRAY_VALUE = "1";
    private Logger logger = LoggerFactory.getLogger(this.getClass());

    @Override
    public void initWithNiwsConfig(IClientConfig iClientConfig) {

    }

    @Override
    public Server choose(Object o) {
        ILoadBalancer loadBalancer = getLoadBalancer();
        return this.choose(loadBalancer);
    }

    private Server choose(ILoadBalancer lb){
        Server server = null;
        if (server==null){
　　　　　　　//獲取請求頭中的參數，具體實現在gitee
            Map<String, String> stringStringMap = GrayRibbonParamater.get();
            String grayParmater = null;
            if(stringStringMap!=null){
                grayParmater = stringStringMap.get("gray_header");
            }
            //獲得可到達的服務
            List<Server> reachableServers = lb.getReachableServers();
            for (Server reachableServer : reachableServers) {
                //獲取服務的metadata
                Map<String, String> metadata = ((DiscoveryEnabledServer) reachableServer).getInstanceInfo().getMetadata();
                if(StringUtils.equals(metadata.get(GRAY_HEADER),GRAY_VALUE)&&StringUtils.equals(grayParmater,GRAY)){
                    return reachableServer;
                }
            }
        }
        return server;
    }

}