微服务模式下怎么实现灰度发布模式

这篇文章主要介绍"微服务模式下怎么实现灰度发布模式"，在日常操作中，相信很多人在微服务模式下怎么实现灰度发布模式问题上存在疑惑，小编查阅了各式资料，整理出简单好用的操作方法，希望对大家解答"微服务模式下怎么实现灰度发布模式"的疑惑有所帮助！接下来，请跟着小编一起来学习吧！

一、基本逻辑

请求通过8001服务，在灰度规则中，会读取下次请求的服务列表，根据版本号参数规则，选中路由的服务。

配置版本号，区分灰度版本和默认正常版本； 自定义拦截器，管理版本号或其他标识参数在请求中传递； 自定义服务选中策略，基于版本标识路由服务； 如果灰度服务不存在，则基于规则选中默认服务；

二、版本配置

在node12-server集群配置两个服务：在8002端口配置版本v7.0.0,在8003端口配置版本v7.0.1，用来测试灰度版本选择。

8002服务

eureka:    metadata-map:      version: v7.0.0

8003服务

eureka:    metadata-map:      version: v7.0.1

Eureka注册中心，服务列表：

三、参数传递

微服务下通过实现RequestInterceptor接口，管理服务之间的Feign请求拦截器，在请求路由到服务前，可以对请求执行一些处理操作，常见操作例如传递版本号，用户Token等请求头等属性。

/** * 请求拦截器 */@Componentpublic class GrayReqInterceptor implements RequestInterceptor {    private static final String VERSION_KEY = "versionId" ;    /**     * 处理请求头参数携带问题     */    @Override    public void apply(RequestTemplate requestTemplate) {        HttpServletRequest request =                ((ServletRequestAttributes)                RequestContextHolder.getRequestAttributes()).getRequest();        String versionId = request.getHeader(VERSION_KEY);        if (StringUtils.isNotEmpty(versionId)){            requestTemplate.header(VERSION_KEY,versionId);        }    }}

这里就传递一个versionId参数，作为下次请求路由服务的核心标识。

四、灰度规则

在请求头的Header中添加要访问的版本号，如果有匹配的服务，则路由所有请求的灰度服务，如果没有则返回默认服务。

@Configurationpublic class GrayRule extends ZoneAvoidanceRule {    @Bean    public GrayReqInterceptor grayReqInterceptor(){        return new GrayReqInterceptor();    }    private static final String VERSION_KEY = "versionId" ;    @Override    public Server choose(Object key) {        HttpServletRequest request =                ((ServletRequestAttributes)                RequestContextHolder.getRequestAttributes()).getRequest();        String versionId = request.getHeader(VERSION_KEY);        // 服务匹配        List serverList = this.getPredicate().getEligibleServers(this.getLoadBalancer().getAllServers(), key);        Server toServer = getServer(serverList,versionId);        if (toServer != null){            return toServer ;        } else {            return getServer(serverList,GrayConstant.VERSION_DEF);        }    }    private Server getServer (List serverList,String version){        Server toServer = null ;        for (Server server : serverList) {            Map metadata = ((DiscoveryEnabledServer) server).getInstanceInfo().getMetadata();            String metaVersion = metadata.get("version");            if (!StringUtils.isEmpty(metaVersion)) {                if (metaVersion.equals(version)) {                    toServer = server;                }            }        }        return toServer ;    }}

在实际的过程中，服务的选择是十分复杂的，如果没有灰度服务，需要根据实际情况制定服务匹配的规则，例如根据响应时间，或者默认轮询等。

更需要注意的一点是，一旦使用底层API的二次封装，项目的整体就会受到框架版本升级的影响，需要持续关注框架的环境。

五、测试流程

1.启动相关服务，观察注册中心服务列表；

2.请求8001服务的接口，并带上版本号；

3.观察不同版本号的路由服务；

4.不携带版本号，观察默认服务选择；

六、源代码地址

GitHub地址：知了一笑https://github.com/cicadasmile/spring-cloud-baseGitEE地址：知了一笑https://gitee.com/cicadasmile/spring-cloud-base

到此，关于"微服务模式下怎么实现灰度发布模式"的学习就结束了，希望能够解决大家的疑惑。理论与实践的搭配能更好的帮助大家学习，快去试试吧！若想继续学习更多相关知识，请继续关注网站，小编会继续努力为大家带来更多实用的文章！