本文源码：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·点这里 | ☆☆☆☆☆ |
版权声明：本文内容由互联网用户自发贡献，该文观点仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 举报，一经查实，本站将立刻删除。
发布者：全栈程序员-站长，转载请注明出处：https://javaforall.net/2697.html原文链接：https://javaforall.net
