![\"\u5c01\u9762\u4fe1\u606f\u56fe\"](\"https:\/\/www.wsisp.com\/helps\/wp-content\/uploads\/2026\/09\/20260922210852-6ab2ee64585f0.webp\")
<\/p>\n<\/p>\n
\u5728\u73b0\u4ee3\u5927\u578b\u5206\u5e03\u5f0f\u5fae\u670d\u52a1\u4f53\u7cfb\u4e2d，\u4e00\u6b21\u5178\u578b\u7684\u4e1a\u52a1\u4ea4\u4e92\u5f80\u5f80\u9700\u8981\u8de8\u8d8a API \u7f51\u5173\u3001\u524d\u7aef\u805a\u5408\u5c42\u3001\u901a\u7528\u4e1a\u52a1\u670d\u52a1\u3001\u4e2d\u53f0\u5e95\u5c42\u670d\u52a1\u4ee5\u53ca\u7b2c\u4e09\u65b9\u652f\u4ed8\u901a\u9053\u7b49\u591a\u4e2a\u7cfb\u7edf\u8282\u70b9\u3002\u5f53\u7814\u53d1\u56e2\u961f\u9700\u8981\u5bf9\u6838\u5fc3\u4ea4\u6613\u94fe\u8def\u8fdb\u884c\u5927\u89c4\u6a21\u91cd\u6784\u6216\u53d1\u5e03\u91cd\u5927\u7279\u6027\u65f6，\u4f20\u7edf\u7684\u5355\u670d\u52a1\u91d1\u4e1d\u96c0（Canary）\u53d1\u5e03\u65b9\u5f0f\u66b4\u9732\u51fa\u660e\u663e\u7684\u5c40\u9650\u6027：\u5982\u679c\u4ec5\u4ec5\u5c06\u7f51\u5173\u540e\u9762\u7684\u805a\u5408\u670d\u52a1\u5347\u7ea7\u4e3a\u65b0\u7248\u672c，\u800c\u4e0b\u6e38\u4f9d\u8d56\u7684\u670d\u52a1\u4ecd\u5904\u4e8e\u65e7\u7248\u672c\u57fa\u7ebf，\u90a3\u4e48\u6d89\u53ca\u8de8\u670d\u52a1\u534f\u540c\u7684\u65b0\u4e1a\u52a1\u903b\u8f91\u5c31\u65e0\u6cd5\u5f97\u5230\u7aef\u5230\u7aef\u7684\u771f\u5b9e\u9a8c\u8bc1；\u800c\u5982\u679c\u4e3a\u4e86\u6bcf\u6b21\u53d1\u5e03\u90fd\u5355\u72ec\u642d\u5efa\u4e00\u5957\u7269\u7406\u9694\u79bb\u7684\u5168\u5957\u6d4b\u8bd5\u96c6\u7fa4，\u53c8\u4f1a\u5e26\u6765\u6210\u500d\u7684\u786c\u4ef6\u6210\u672c\u4e0e\u6781\u5176\u6c89\u91cd\u7684\u8fd0\u7ef4\u8d1f\u62c5\u3002<\/p>\n
\u5168\u94fe\u8def\u6d41\u91cf\u67d3\u8272\u4e0e\u6cf3\u9053\u9694\u79bb（Traffic Coloring & Swimlane Isolation）\u6280\u672f，\u901a\u8fc7\u4e3a\u7f51\u7edc\u8bf7\u6c42\u6253\u4e0a\u903b\u8f91\u8def\u7531\u6807\u7b7e，\u5e76\u5728\u5206\u5e03\u5f0f\u8c03\u7528\u94fe\u6761\u4e2d\u5168\u7a0b\u900f\u4f20\u8be5\u6807\u7b7e，\u9a71\u52a8\u7f51\u5173\u3001RPC \u8c03\u7528\u3001\u6d88\u606f\u961f\u5217\u548c\u6570\u636e\u5e93\u4e2d\u95f4\u4ef6\u8fdb\u884c\u534f\u540c\u8def\u7531，\u662f\u5b9e\u73b0\u9ad8\u9694\u79bb\u5ea6\u3001\u4f4e\u6210\u672c\u7070\u5ea6\u53d1\u5e03\u7684\u6700\u4f18\u89e3\u3002<\/p>\n
+————————————+
\n | Spring Cloud Gateway \u5165\u53e3\u7f51\u5173 |
\n | (\u6839\u636e\u7528\u6237 ID\/\u767d\u540d\u5355\u8ba1\u7b97\u67d3\u8272 Tag) |
\n +————————————+
\n |
\n +—————————+—————————+
\n | x-gray-tag: v2 (\u7070\u5ea6\u6cf3\u9053) | x-gray-tag: base (\u57fa\u7ebf\u6cf3\u9053)
\n v v
\n +————————-+ +————————-+
\n | Order Service (v2 \u5b9e\u4f8b) | | Order Service (v1 \u57fa\u7ebf) |
\n +————————-+ +————————-+
\n | |
\n | Feign Header \u900f\u4f20 | Feign Header \u900f\u4f20
\n v v
\n +————————-+ +————————-+
\n | Payment Service (v2 \u5b9e\u4f8b)| | Payment Service (v1 \u57fa\u7ebf)|
\n +————————-+ +————————-+
\n | |
\n | RocketMQ \u5e26 Tag \u53d1\u9001 | RocketMQ \u666e\u901a\u6d88\u606f\u53d1\u9001
\n v v
\n +————————-+ +————————-+
\n | \u6d88\u606f\u6d88\u8d39\u4e0e\u5f71\u5b50\u5e93\u9694\u79bb\u5199\u5165 | | \u6b63\u5e38\u751f\u4ea7\u6d88\u8d39\u4e0e\u4e3b\u5e93\u5199\u5165 |
\n +————————-+ +————————-+<\/p>\n
\u8981\u6784\u5efa\u4e00\u6761\u7a33\u56fa\u3001\u65e0\u7f1d\u7684\u5168\u94fe\u8def\u7070\u5ea6\u6cf3\u9053，\u5fc5\u987b\u5728\u4ee5\u4e0b\u4e09\u4e2a\u5c42\u9762\u5efa\u7acb\u95ed\u73af\u7684\u534f\u540c\u673a\u5236：<\/p>\n
\u5728 Spring Cloud Gateway \u4e2d\u6839\u636e\u7528\u6237\u7279\u5f81\u5b8c\u6210\u6d41\u91cf\u5224\u5b9a\u5e76\u5199\u5165\u5185\u90e8\u4e13\u5c5e\u8bf7\u6c42\u5934：<\/p>\n
package com.example.gateway.filter;<\/p>\n
import org.springframework.cloud.gateway.filter.GatewayFilterChain;
\nimport org.springframework.cloud.gateway.filter.GlobalFilter;
\nimport org.springframework.core.Ordered;
\nimport org.springframework.http.server.reactive.ServerHttpRequest;
\nimport org.springframework.stereotype.Component;
\nimport org.springframework.web.server.ServerWebExchange;
\nimport reactor.core.publisher.Mono;<\/p>\n
@Component
\npublic class GrayTrafficColoringFilter implements GlobalFilter, Ordered {<\/p>\n
public static final String HEADER_GRAY_TAG = "x-gray-tag";
\n public static final String TAG_V2 = "v2";<\/p>\n
@Override
\n public Mono<Void> filter(ServerWebExchange exchange, GatewayFilterChain chain) {
\n String userId = exchange.getRequest().getHeaders().getFirst("X-User-Id");<\/p>\n
\/\/ \u5224\u5b9a\u7070\u5ea6\u89c4\u5219：\u4f8b\u5982\u9488\u5bf9\u7279\u5b9a\u5185\u6d4b\u79df\u6237\u6216\u7528\u6237 ID \u5c3e\u53f7\u8fdb\u884c\u5206\u6d41
\n boolean isGray = isEligibleForGrayRelease(userId);<\/p>\n
ServerHttpRequest.Builder requestBuilder = exchange.getRequest().mutate();
\n if (isGray) {
\n requestBuilder.header(HEADER_GRAY_TAG, TAG_V2);
\n } else {
\n requestBuilder.header(HEADER_GRAY_TAG, "base");
\n }<\/p>\n
return chain.filter(exchange.mutate().request(requestBuilder.build()).build());
\n }<\/p>\n
private boolean isEligibleForGrayRelease(String userId) {
\n if (userId == null || userId.isBlank()) {
\n return false;
\n }
\n \/\/ \u7528\u6237 ID \u5c3e\u53f7\u4e3a\u7279\u5b9a\u6570\u5b57\u65f6\u63a5\u5165\u7070\u5ea6\u6cf3\u9053
\n return userId.endsWith("8") || userId.endsWith("9");
\n }<\/p>\n
@Override
\n public int getOrder() {
\n return Ordered.HIGHEST_PRECEDENCE;
\n }
\n}<\/p>\n
\u5229\u7528 TransmittableThreadLocal \u5728 Spring MVC \u62e6\u622a\u5668\u4e2d\u63d0\u53d6 Header，\u5e76\u5728 Feign \u8c03\u7528\u65f6\u65e0\u7f1d\u56de\u586b：<\/p>\n
package com.example.common.context;<\/p>\n
import com.alibaba.ttl.TransmittableThreadLocal;
\nimport feign.RequestInterceptor;
\nimport feign.RequestTemplate;
\nimport jakarta.servlet.http.HttpServletRequest;
\nimport jakarta.servlet.http.HttpServletResponse;
\nimport org.springframework.context.annotation.Bean;
\nimport org.springframework.context.annotation.Configuration;
\nimport org.springframework.web.servlet.HandlerInterceptor;
\nimport org.springframework.web.servlet.config.annotation.InterceptorRegistry;
\nimport org.springframework.web.servlet.config.annotation.WebMvcConfigurer;<\/p>\n
public class GrayContextHolder {
\n private static final TransmittableThreadLocal<String> CURRENT_TAG = new TransmittableThreadLocal<>();<\/p>\n
public static void setTag(String tag) {
\n CURRENT_TAG.set(tag);
\n }<\/p>\n
public static String getTag() {
\n return CURRENT_TAG.get();
\n }<\/p>\n
public static void clear() {
\n CURRENT_TAG.remove();
\n }
\n}<\/p>\n
@Configuration
\npublic class GrayPropagationConfiguration implements WebMvcConfigurer {<\/p>\n
@Override
\n public void addInterceptors(InterceptorRegistry registry) {
\n registry.addInterceptor(new HandlerInterceptor() {
\n @Override
\n public boolean preHandle(HttpServletRequest request, HttpServletResponse response, Object handler) {
\n String tag = request.getHeader("x-gray-tag");
\n if (tag != null && !tag.isBlank()) {
\n GrayContextHolder.setTag(tag);
\n }
\n return true;
\n }<\/p>\n
@Override
\n public void afterCompletion(HttpServletRequest request, HttpServletResponse response,
\n Object handler, Exception ex) {
\n GrayContextHolder.clear();
\n }
\n });
\n }<\/p>\n
@Bean
\n public RequestInterceptor feignGrayTrafficInterceptor() {
\n return (RequestTemplate template) -> {
\n String tag = GrayContextHolder.getTag();
\n if (tag != null && !tag.isBlank()) {
\n template.header("x-gray-tag", tag);
\n }
\n };
\n }
\n}<\/p>\n
\u5b9e\u73b0 ReactorServiceInstanceLoadBalancer \u63a5\u53e3，\u6839\u636e\u5b9e\u4f8b\u6ce8\u518c\u5728 Nacos \u4e0a\u7684 version \u5143\u6570\u636e\u8fdb\u884c\u7cbe\u786e\u8fc7\u6ee4：<\/p>\n
package com.example.common.loadbalancer;<\/p>\n
import com.example.common.context.GrayContextHolder;
\nimport org.springframework.cloud.client.ServiceInstance;
\nimport org.springframework.cloud.client.loadbalancer.DefaultResponse;
\nimport org.springframework.cloud.client.loadbalancer.EmptyResponse;
\nimport org.springframework.cloud.client.loadbalancer.Request;
\nimport org.springframework.cloud.client.loadbalancer.Response;
\nimport org.springframework.cloud.loadbalancer.core.ReactorServiceInstanceLoadBalancer;
\nimport org.springframework.cloud.loadbalancer.core.ServiceInstanceListSupplier;
\nimport reactor.core.publisher.Mono;<\/p>\n
import java.util.List;
\nimport java.util.concurrent.ThreadLocalRandom;
\nimport java.util.stream.Collectors;<\/p>\n
public class CustomGrayLoadBalancer implements ReactorServiceInstanceLoadBalancer {<\/p>\n
private final ServiceInstanceListSupplier supplier;<\/p>\n
public CustomGrayLoadBalancer(ServiceInstanceListSupplier supplier) {
\n this.supplier = supplier;
\n }<\/p>\n
@Override
\n public Mono<Response<ServiceInstance>> choose(Request request) {
\n String currentTag = GrayContextHolder.getTag();<\/p>\n
return supplier.get(request).next().map(instances -> {
\n if (instances.isEmpty()) {
\n return new EmptyResponse();
\n }<\/p>\n
\/\/ 1. \u5982\u679c\u5e26\u6709\u7070\u5ea6 Tag，\u4f18\u5148\u5339\u914d\u5bf9\u5e94 version \u5143\u6570\u636e\u7684\u5b9e\u4f8b
\n if (currentTag != null && !currentTag.isBlank() && !"base".equals(currentTag)) {
\n List<ServiceInstance> grayInstances = instances.stream()
\n .filter(inst -> currentTag.equals(inst.getMetadata().get("version")))
\n .collect(Collectors.toList());<\/p>\n
if (!grayInstances.isEmpty()) {
\n int index = ThreadLocalRandom.current().nextInt(grayInstances.size());
\n return new DefaultResponse(grayInstances.get(index));
\n }
\n }<\/p>\n
\/\/ 2. \u964d\u7ea7\u903b\u8f91：\u672a\u643a\u5e26 Tag \u6216\u672a\u627e\u5230\u7070\u5ea6\u5b9e\u4f8b\u65f6，\u8def\u7531\u81f3\u57fa\u7ebf\u5b9e\u4f8b
\n List<ServiceInstance> baseInstances = instances.stream()
\n .filter(inst -> {
\n String version = inst.getMetadata().get("version");
\n return version == null || "base".equals(version) || "v1".equals(version);
\n })
\n .collect(Collectors.toList());<\/p>\n
if (!baseInstances.isEmpty()) {
\n int index = ThreadLocalRandom.current().nextInt(baseInstances.size());
\n return new DefaultResponse(baseInstances.get(index));
\n }<\/p>\n
\/\/ \u515c\u5e95\u8fd4\u56de\u4efb\u610f\u53ef\u7528\u5b9e\u4f8b
\n return new DefaultResponse(instances.get(0));
\n });
\n }
\n}<\/p>\n
\u5728\u5b9e\u9645\u590d\u6742\u7684\u4f01\u4e1a\u7ea7\u67b6\u6784\u4e2d，\u4ec5\u5904\u7406 HTTP \u540c\u6b65\u8c03\u7528\u8fdc\u8fdc\u4e0d\u591f，\u8fd8\u5fc5\u987b\u843d\u5b9e\u4ee5\u4e0b\u9632\u5fa1\u89c4\u8303：<\/p>\n
Spring Cloud \u5fae\u670d\u52a1\u5168\u94fe\u8def\u7070\u5ea6\u67d3\u8272\u4e0e\u9694\u79bb\u5728\u73b0\u4ee3\u5927\u578b\u5206\u5e03\u5f0f\u5fae\u670d\u52a1\u4f53\u7cfb\u4e2d，\u4e00\u6b21\u5178\u578b\u7684\u4e1a\u52a1\u4ea4\u4e92\u5f80\u5f80\u9700\u8981\u8de8\u8d8a API \u7f51\u5173\u3001\u524d\u7aef\u805a\u5408\u5c42\u3001\u901a\u7528\u4e1a\u52a1\u670d\u52a1\u3001\u4e2d\u53f0\u5e95\u5c42\u670d\u52a1\u4ee5\u53ca\u7b2c\u4e09\u65b9\u652f\u4ed8\u901a\u9053\u7b49\u591a\u4e2a\u7cfb\u7edf\u8282\u70b9\u3002\u5f53\u7814\u53d1\u56e2\u961f\u9700\u8981\u5bf9\u6838\u5fc3\u4ea4\u6613\u94fe\u8def\u8fdb\u884c\u5927\u89c4\u6a21\u91cd\u6784\u6216\u53d1\u5e03\u91cd\u5927\u7279\u6027\u65f6，\u4f20\u7edf\u7684\u5355\u670d\u52a1\u91d1\u4e1d\u96c0（Canary）\u53d1\u5e03\u65b9\u5f0f\u66b4\u9732\u51fa\u660e\u663e\u7684\u5c40\u9650\u6027：\u5982\u679c\u4ec5\u4ec5\u5c06\u7f51\u5173\u540e\u9762\u7684\u805a\u5408\u670d\u52a1\u5347\u7ea7\u4e3a\u65b0\u7248\u672c，\u800c\u4e0b\u6e38\u4f9d\u8d56\u7684\u670d\u52a1\u4ecd\u5904\u4e8e\u65e7\u7248\u672c\u57fa\u7ebf<\/p>\n","protected":false},"author":2,"featured_media":0,"comment_status":"open","ping_status":"open","sticky":false,"template":"","format":"standard","meta":{"footnotes":""},"categories":[1],"tags":[66,99,101,50,1348],"topic":[],"class_list":["post-108984","post","type-post","status-publish","format-standard","hentry","category-server","tag-ai","tag-java","tag-spring","tag-50","tag-1348"],"yoast_head":"\n