Spring Cloud Gateway实现灰度发布方案
灰度发布又名金丝雀发布，在微服务中的表现为同一服务同时上线不同版本，让一部分用户使用新版本来验证新特性，如果验证没有问题，则将所有用户都迁移到新版本上。
在微服务架构中，网关负责请求的统一入口，主要功能之一是请求路由。而灰度发布实质就是让指定用户路由到指定版本的服务上。所以该功能可以在网关这一层实现。
今天就分享下Spring Cloud Gateway如何实现灰度发布。
1 Spring Cloud Gateway的路由逻辑
既然要让指定用户路由到指定服务版本，我们需要先了解Spring Cloud Gateway的路由逻辑。
Spring Cloud Gateway通过Predicate来匹配路由。
- id: user-route
uri: lb://user-login
predicates:
- Path=/user/**
上述路由规则表示只要请求URL符合/user/**则都会匹配到user-route这条路由规则中。（根据Predicate寻找路由匹配规则的源码在RoutePredicateHandlerMapping#lookupRoute方法中）。
那么要实现灰度发布该怎么做？我们这里可以自己写一个Predicate，来实现指定用户匹配到指定的路由规则当中。假设我们自己写的Predicate叫HeaderUserNameRoutePredicateFactory（相应源码在文后），相应的配置如下：
- id: user-route-gray
uri: lb://user-login
predicates:
- Path=/user/**
- HeaderUsername=Jack
上述路由规则表示请求URL符合/user/**并且请求的HTTP Header中的Username属性值为Jack则会匹配到user-route-gray这条路由规则中。
实现了指定用户匹配到指定规则只是第一步，下一步要实现的是如何让指定用户路由到指定版本的服务中，想要实现这一点，就需要先了解Spring Cloud Gateway的负载均衡逻辑，也就是Spring Cloud Gateway是如何选取要调用的服务的。
2 Spring Cloud Gateway的负载均衡逻辑
负载均衡的逻辑如下：
1、 从注册中心获取服务实例列表（实际实现中服务实例列表是后台定时刷新缓存在内存中的）；
2、根据负载均衡算法从实例列表中选取服务。
在Spring Cloud Gateway中，相应的代码在ReactiveLoadBalancerClientFilter#choose方法中。
默认情况下，Spring Cloud Gateway负载均衡策略会从注册中心所有服务实例中轮询选择一个服务实例。由此可以看出，默认实现无法满足我们的需求，因为我们想要特定用户路由到特定的服务版本上。
那么该如何解决呢？答案是重写负载均衡算法，来实现选择特定版本的服务实例功能。
3 版本号如何指定
灰度发布的目的是实现指定用户访问指定版本，用户信息可以在HTTP Header中带过来，那么版本号如何指定？
这里有两种方案。
第一种方案也是通过请求的HTTP Header带过来，缺点是需要客户端修改；
第二种方案是在网关层修改请求，动态为请求加上版本号信息，此方案较好，对客户端透明。
4 灰度发布的实现
看到这里，整个灰度发布的实现思路应该比较清晰了。
1、首先编写自己的Predicate，实现指定用户匹配到指定的路由规则中；
2、动态修改请求，添加版本号信息，版本号信息可以放在HTTP Header中（此处可以通过原生AddRequestHeaderGatewayFilterFactory来实现，无需自己写代码）；
3、重写负载均衡算法，根据版本号信息从注册中心的服务实例上选择相应的服务版本进行请求的转发。
思路如上，下面附上关键代码：
自定义HeaderUsernameRoutePredicateFactory源码如下：
@Component
public class HeaderUsernameRoutePredicateFactory extends AbstractRoutePredicateFactory<HeaderUsernameRoutePredicateFactory.Config> {
public static final String USERNAME = "Username";
public HeaderUsernameRoutePredicateFactory() {
super(Config.class);
}
@Override
public ShortcutType shortcutType() {
return ShortcutType.GATHER_LIST;
}
@Override
public List<String> shortcutFieldOrder() {
return Collections.singletonList("username");
}
@Override
public Predicate<ServerWebExchange> apply(Config config) {
List<String> usernames = config.getUsername();
return new GatewayPredicate() {
@Override
public boolean test(ServerWebExchange serverWebExchange) {
String username = serverWebExchange.getRequest().getHeaders().getFirst(USERNAME);
if (!StringUtils.isEmpty(username)) {
return usernames.contains(username);
}
return false;
}
@Override
public String toString() {
return String.format("Header: Username=%s", config.getUsername());
}
};
}
@NoArgsConstructor
@Getter
@Setter
@ToString
public static class Config {
private List<String> username;
}
}
自定义负载均衡算法GrayRoundRobinLoadBalancer如下：
@Slf4j
public class GrayRoundRobinLoadBalancer implements ReactorServiceInstanceLoadBalancer {
private static final position = new AtomicInteger(new Random().nextInt(1000));
private final ObjectProvider<ServiceInstanceListSupplier> serviceInstanceListSupplierProvider;
private final String serviceId;
private final AtomicInteger position;
public GrayRoundRobinLoadBalancer(ObjectProvider<ServiceInstanceListSupplier> serviceInstanceListSupplierProvider, String serviceId) {
this.serviceId = serviceId;
this.serviceInstanceListSupplierProvider = serviceInstanceListSupplierProvider;
}
@Override
public Mono<Response<ServiceInstance>> choose(Request request) {
HttpHeaders headers = (HttpHeaders) request.getContext();
ServiceInstanceListSupplier supplier = serviceInstanceListSupplierProvider.getIfAvailable(NoopServiceInstanceListSupplier::new);
return supplier.get(request).next().map(list -> getInstanceResponse(list, headers));
}
private Response<ServiceInstance> getInstanceResponse(List<ServiceInstance> instances, HttpHeaders headers) {
List<ServiceInstance> serviceInstances = instances.stream()
.filter(instance -> {
//根据请求头中的版本号信息，选取注册中心中的相应服务实例
String version = headers.getFirst("Version");
if (version != null) {
return version.equals(instance.getMetadata().get("version"));
} else {
return true;
}
}).collect(Collectors.toList());
if (serviceInstances.isEmpty()) {
if (log.isWarnEnabled()) {
log.warn("No servers available for service: " + serviceId);
}
return new EmptyResponse();
}
int pos = Math.abs(this.position.incrementAndGet());
ServiceInstance instance = serviceInstances.get(pos % serviceInstances.size());
return new DefaultResponse(instance);
}
}
自定义GrayReactiveLoadBalancerClientFilter，调用自定义的负责均衡算法：
@Slf4j
@Component
public class GrayReactiveLoadBalancerClientFilter implements GlobalFilter, Ordered {
private static final int LOAD_BALANCER_CLIENT_FILTER_ORDER = 10150;
private final LoadBalancerClientFactory clientFactory;
public GrayReactiveLoadBalancerClientFilter(LoadBalancerClientFactory clientFactory) {
this.clientFactory = clientFactory;
}
@Override
public Mono<Void> filter(ServerWebExchange exchange, GatewayFilterChain chain) {
URI url = (URI) exchange.getAttribute(ServerWebExchangeUtils.GATEWAY_REQUEST_URL_ATTR);
String schemePrefix = (String) exchange.getAttribute(ServerWebExchangeUtils.GATEWAY_SCHEME_PREFIX_ATTR);
if (url != null && ("grayLb".equals(url.getScheme()) || "grayLb".equals(schemePrefix))) {
ServerWebExchangeUtils.addOriginalRequestUrl(exchange, url);
if (log.isTraceEnabled()) {
log.trace(ReactiveLoadBalancerClientFilter.class.getSimpleName() + " url before: " + url);
}
return this.choose(exchange).doOnNext((response) -> {
if (!response.hasServer()) {
throw NotFoundException.create(true, "Unable to find instance for " + url.getHost());
} else {
URI uri = exchange.getRequest().getURI();
String overrideScheme = null;
if (schemePrefix != null) {
overrideScheme = url.getScheme();
}
DelegatingServiceInstance serviceInstance = new DelegatingServiceInstance((ServiceInstance) response.getServer(), overrideScheme);
URI requestUrl = this.reconstructURI(serviceInstance, uri);
if (log.isTraceEnabled()) {
log.trace("LoadBalancerClientFilter url chosen: " + requestUrl);
}
exchange.getAttributes().put(ServerWebExchangeUtils.GATEWAY_REQUEST_URL_ATTR, requestUrl);
}
}).then(chain.filter(exchange));
} else {
return chain.filter(exchange);
}
}
private Mono<Response<ServiceInstance>> choose(ServerWebExchange exchange) {
URI uri = (URI) exchange.getAttribute(ServerWebExchangeUtils.GATEWAY_REQUEST_URL_ATTR);
GrayRoundRobinLoadBalancer loadBalancer = new GrayRoundRobinLoadBalancer(clientFactory.getLazyProvider(uri.getHost(), ServiceInstanceListSupplier.class), uri.getHost());
return loadBalancer.choose(this.createRequest(exchange));
}
private Request createRequest(ServerWebExchange exchange) {
HttpHeaders headers = exchange.getRequest().getHeaders();
return new DefaultRequest<>(headers);
}
protected URI reconstructURI(ServiceInstance serviceInstance, URI original) {
return LoadBalancerUriTools.reconstructURI(serviceInstance, original);
}
@Override
public int getOrder() {
return LOAD_BALANCER_CLIENT_FILTER_ORDER;
}
}
最后的路由规则配置如下，表示用户Jack走V2版本，其他用户走V1版本：
- id: user-route-gray
uri: grayLb://user-login
predicates:
- Path=/user/**
- HeaderUsername=Jack
filters:
- AddRequestHeader=Version,v2
- id: user-route
uri: grayLb://user-login
predicates:
- Path=/user/**
filters:
- AddRequestHeader=Version,v1
写在最后
微服务中的灰度发布功能如上所述，相比实现，思路是大家更需要关注的地方。思路清晰了，即使换个网关实现，换个注册中心实现，都是一样的。
灰度发布实质是让指定用户访问指定版本的服务。
所以首先需要指定用户匹配到指定的路由规则。
其次，服务的版本号信息可以通过HTTP请求头字段来指定。
最后，负载均衡算法需要能够根据版本号信息来做服务实例的选择。
到此这篇关于Spring Cloud Gateway实现灰度发布方案的文章就介绍到这了,更多相关Spring Cloud Gateway灰度发布内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家！
相关文章
这篇文章主要介绍了Java编程中线程池的基本概念和使用,多线程编程是使Java程序实现并发的一个重要手段,需要的朋友可以参考下2015-11-11
下面小编就为大家带来一篇深入理解Java 对象和类。小编觉得挺不错的，现在分享给大家，也给大家做个参考。一起跟随小编过来看看吧2016-05-05
对one-to-one 关系进行延迟加载和其他关系相比稍微有些不同。many-to-one 的延迟加载是在配置文件的class 标签2008-10-10
这篇文章主要介绍了使用RabbitMQ实现延时消息自动取消的简单案例,案例代码包括导包的过程和相关配置文件，本文结合代码给大家讲解的非常详细，需要的朋友可以参考下2024-03-03
本篇文章主要介绍了redis与spring的整合（使用缓存），小编觉得挺不错的，现在分享给大家，也给大家做个参考。一起跟随小编过来看看吧2017-03-03
这篇文章主要介绍了java实现分段读取文件并通过HTTP上传的方法,实例分析了java分段读取文件及使用http实现文件传输的相关技巧,具有一定参考借鉴价值,需要的朋友可以参考下2015-07-07
这篇文章主要介绍了Spring依赖注入底层原理详解, 依赖注入是一种设计模式,它将对象之间的依赖关系从代码中移除,并由容器来管理这些依赖关系,依赖注入的主要目的是降低代码的耦合度,使代码更加灵活和可维护,需要的朋友可以参考下2023-09-09
Java作为一种流行的编程语言,可以用于编写程序来调用这些API接口,从而获取商品数据,本文将介绍如何使用Java基于API接口爬取商品数据,包括请求API、解析JSON数据、存储数据等步骤,并提供相应的代码示例,感兴趣的朋友跟随小编一起看看吧2023-10-10
springboot themaleaf 第一次进页面不加载css的问题
这篇文章主要介绍了springboot themaleaf 第一次进页面不加载css的问题，具有很好的参考价值，希望对大家有所帮助。如有错误或未考虑完全的地方，望不吝赐教2022-10-10
这篇文章主要介绍了手把手教你搭建第一个Spring Batch项目的步骤，文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧2020-09-09
最新评论