微服务中的灰度发布（又称为金丝雀发布）是一种持续部署策略，它允许在正式环境的小部分用户群体上先部署新版本的应用程序或服务，而不是一次性对所有用户同时发布全新的版本。
这种方式有助于在生产环境中逐步验证新版本的稳定性和兼容性，同时最小化潜在风险，不影响大部分用户的正常使用。
在 Spring Cloud 微服务架构中，实现灰度发布通常涉及到以下几个方面：
根据一定的策略（如用户 ID、请求头信息、IP 地址等）将流入的请求分配给不同版本的服务实例。
使用 Spring Cloud Gateway、Zuul 等 API 网关组件实现路由规则，将部分请求定向至新版本的服务节点。
新版本服务启动时会注册带有特定版本标签的服务实例到服务注册中心（如 Eureka 或 Nacos）。
请求在路由时可以根据版本标签选择相应版本的服务实例。
监控与评估：
在灰度发布的阶段，运维团队会对新版本服务的性能、稳定性以及用户体验等方面进行实时监控和评估。
如果新版本表现良好，则可以逐渐扩大灰度范围直至全面替换旧版本。
故障恢复与回滚：若新版本出现问题，可通过快速撤销灰度发布策略，使所有流量恢复到旧版本服务，实现快速回滚，确保服务整体可用性。
通过 Spring Cloud 的扩展组件和自定义路由策略，开发人员可以轻松实现灰度发布功能，确保在微服务架构中安全、平滑地进行版本迭代升级。
灰色发布的常见实现思路有以下几种：
而在生产环境中，比较常用的是根据用户标识来实现灰色发布，也就是说先让一小部分用户体验新功能，以发现新服务中可能存在的某种缺陷或不足。
Spring Cloud 全链路灰色发布的关键实现思路如下图所示：
图片
灰度发布的具体实现步骤如下：
在负载均衡器 Spring Cloud LoadBalancer 中，判断灰度发布标签，将请求分发到对应服务。
将灰度发布标签（如果存在），继续传递给下一个调用的服务。
经过第四步的反复传递之后，整个 Spring Cloud 全链路的灰度发布就完成了。
在灰度发布的执行流程中，有一个核心的问题，如果在 Spring Cloud LoadBalancer 进行服务调用时，区分正式服务和灰度服务呢？
这个问题的解决方案是：在灰度服务既注册中心的 MetaData（元数据）中标识自己为灰度服务即可，而元数据中没有标识（灰度服务）的则为正式服务，以 Nacos 为例，它的设置如下：
spring: application: name: gray-user-service cloud: nacos: discovery: username: nacos password: nacos server-addr: localhost:8848 namespace: public register-enabled: true metadata: { "gray-tag":"true" } # 标识自己为灰度服务Spring Cloud LoadBalancer 判断并调用灰度服务的关键实现代码如下：
private Response<ServiceInstance> getInstanceResponse(List<ServiceInstance> instances, Request request) { // 实例为空 if (instances.isEmpty()) { if (log.isWarnEnabled()) { log.warn("No servers available for service: " + this.serviceId); } return new EmptyResponse(); } else { // 服务不为空 RequestDataContext dataContext = (RequestDataContext) request.getContext(); HttpHeaders headers = dataContext.getClientRequest().getHeaders(); // 判断是否为灰度发布（请求） if (headers.get(GlobalVariables.GRAY_KEY) != null && headers.get(GlobalVariables.GRAY_KEY).get(0).equals("true")) { // 灰度发布请求，得到新服务实例列表 List<ServiceInstance> findInstances = instances.stream(). filter(s -> s.getMetadata().get(GlobalVariables.GRAY_KEY) != null && s.getMetadata().get(GlobalVariables.GRAY_KEY).equals("true")) .toList(); if (findInstances.size() > 0) { // 存在灰度发布节点 instances = findInstances; } } else { // 查询非灰度发布节点 // 灰度发布测试请求，得到新服务实例列表 instances = instances.stream(). filter(s -> s.getMetadata().get(GlobalVariables.GRAY_KEY) == null || !s.getMetadata().get(GlobalVariables.GRAY_KEY).equals("true")) .toList(); } // 随机正数值 ++i（ & 去负数） int pos = this.position.incrementAndGet() & Integer.MAX_VALUE; // ++i 数值 % 实例数 取模 -> 轮询算法 int index = pos % instances.size(); // 得到服务实例方法 ServiceInstance instance = (ServiceInstance) instances.get(index); return new DefaultResponse(instance); } }以上代码为自定义负载均衡器，并使用了轮询算法。如果 Header 中有灰度标签，则只查询灰度服务的节点实例，否则则查询出所有的正式节点实例（以供服务调用或服务转发）。
要在网关 Spring Cloud Gateway 中传递灰度标识，只需要在 Gateway 的全局自定义过滤器中设置 Response 的 Header 即可，具体实现代码如下：
package com.example.gateway.config;import com.loadbalancer.canary.common.GlobalVariables;import org.springframework.cloud.gateway.filter.GatewayFilterChain;import org.springframework.cloud.gateway.filter.GlobalFilter;import org.springframework.core.Ordered;import org.springframework.http.HttpStatus;import org.springframework.http.server.reactive.ServerHttpRequest;import org.springframework.http.server.reactive.ServerHttpResponse;import org.springframework.stereotype.Component;import org.springframework.web.server.ServerWebExchange;import reactor.core.publisher.Mono;@Componentpublic class LoadBalancerFilter implements GlobalFilter { @Override public Mono<Void> filter(ServerWebExchange exchange, GatewayFilterChain chain) { // 得到 request、response 对象 ServerHttpRequest request = exchange.getRequest(); ServerHttpResponse response = exchange.getResponse(); if (request.getQueryParams().getFirst(GlobalVariables.GRAY_KEY) != null) { // 设置金丝雀标识 response.getHeaders().set(GlobalVariables.GRAY_KEY, "true"); } // 此步骤正常，执行下一步 return chain.filter(exchange); }}HTTP 调用工具 Openfeign，我们需要在微服务间继续传递灰度标签，它的实现代码如下：
import feign.RequestInterceptor;import feign.RequestTemplate;import jakarta.servlet.http.HttpServletRequest;import org.springframework.stereotype.Component;import org.springframework.web.context.request.RequestContextHolder;import org.springframework.web.context.request.ServletRequestAttributes;import java.util.Enumeration;import java.util.LinkedHashMap;import java.util.Map;@Componentpublic class FeignRequestInterceptor implements RequestInterceptor { @Override public void apply(RequestTemplate template) { // 从 RequestContextHolder 中获取 HttpServletRequest ServletRequestAttributes attributes = (ServletRequestAttributes) RequestContextHolder.getRequestAttributes(); // 获取 RequestContextHolder 中的信息 Map<String, String> headers = getHeaders(attributes.getRequest()); // 放入 openfeign 的 RequestTemplate 中 for (Map.Entry<String, String> entry : headers.entrySet()) { template.header(entry.getKey(), entry.getValue()); } } /** * 获取原请求头 */ private Map<String, String> getHeaders(HttpServletRequest request) { Map<String, String> map = new LinkedHashMap<>(); Enumeration<String> enumeration = request.getHeaderNames(); if (enumeration != null) { while (enumeration.hasMoreElements()) { String key = enumeration.nextElement(); String value = request.getHeader(key); map.put(key, value); } } return map; }}本文链接：http://www.28at.com/showinfo-26-88919-0.html微服务如何灰度发布？你会吗？
声明：本网页内容旨在传播知识，若有侵权等问题请及时与本网联系，我们将在第一时间删除处理。邮件：2376512515@qq.com
Copyright © 2016-2023 天津谷骐科技有限公司 版权所有 sitemap.xml
违法及侵权请联系：2376512515@qq.com 津ICP备18001702号
津公网安备 12010102000574号
