• 如果您觉得本站非常有看点,那么赶紧使用Ctrl+D 收藏吧

架构设计:微服务模式下,实现灰度发布模式

互联网 diligentman 1周前 (11-19) 5次浏览

本文源码:GitHub·点这里 || GitEE·点这里

一、基本逻辑

请求通过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等请求头等属性。

/**
 * 请求拦截器
 */
@Component
public 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中添加要访问的版本号,如果有匹配的服务,则路由所有请求的灰度服务,如果没有则返回默认服务。

@Configuration
public 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<Server> 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<Server> serverList,String version){
        Server toServer = null ;
        for (Server server : serverList) {
            Map<String, String> 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-base
GitEE地址:知了一笑
https://gitee.com/cicadasmile/spring-cloud-base

推荐阅读:编程体系整理

序号 项目名称 GitHub地址 GitEE地址 推荐指数
01 Java描述设计模式,算法,数据结构 GitHub·点这里 GitEE·点这里 ☆☆☆☆☆
02 Java基础、并发、面向对象、Web开发 GitHub·点这里 GitEE·点这里 ☆☆☆☆
03 SpringCloud微服务基础组件案例详解 GitHub·点这里 GitEE·点这里 ☆☆☆
04 SpringCloud微服务架构实战综合案例 GitHub·点这里 GitEE·点这里 ☆☆☆☆☆
05 SpringBoot框架基础应用入门到进阶 GitHub·点这里 GitEE·点这里 ☆☆☆☆
06 SpringBoot框架整合开发常用中间件 GitHub·点这里 GitEE·点这里 ☆☆☆☆☆
07 数据管理、分布式、架构设计基础案例 GitHub·点这里 GitEE·点这里 ☆☆☆☆☆
08 大数据系列、存储、组件、计算等框架 GitHub·点这里 GitEE·点这里 ☆☆☆☆☆

喜欢 (0)