本文源码:GitHub·点这里 || GitEE·点这里java
请求经过8001服务,在灰度规则中,会读取下次请求的服务列表,根据版本号参数规则,选中路由的服务。node
配置版本号,区分灰度版本和默认正常版本;
自定义拦截器,管理版本号或其余标识参数在请求中传递;
自定义服务选中策略,基于版本标识路由服务;
若是灰度服务不存在,则基于规则选中默认服务;git
在node12-server集群配置两个服务:在8002端口配置版本v7.0.0,在8003端口配置版本v7.0.1,用来测试灰度版本选择。github
8002服务算法
eureka: metadata-map: version: v7.0.0
8003服务spring
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·点这里 | ☆☆☆☆☆ |