如何让Netflix Zuul代理基于HTTP请求头选择服务A/B的路由

嘿，这个需求其实用Zuul的自定义过滤器就能轻松搞定，我给你一步步拆解具体操作：

1. 编写自定义路由过滤器 #

Zuul的核心逻辑依赖过滤器链，我们需要创建一个继承ZuulFilter的类，在路由阶段根据请求头修改目标服务地址。直接上可复用的代码示例：

import com.netflix.zuul.ZuulFilter;
import com.netflix.zuul.context.RequestContext;
import org.springframework.cloud.netflix.zuul.filters.support.FilterConstants;
import org.springframework.stereotype.Component;
import javax.servlet.http.HttpServletRequest;

@Component
public class HeaderRouteFilter extends ZuulFilter {

    @Override
    public String filterType() {
        // 指定过滤器在路由阶段生效
        return FilterConstants.ROUTE_TYPE;
    }

    @Override
    public int filterOrder() {
        // 优先级高于默认路由过滤器，确保我们的修改先生效
        return FilterConstants.SIMPLE_HOST_ROUTING_FILTER_ORDER - 1;
    }

    @Override
    public boolean shouldFilter() {
        // 可自定义过滤范围，比如只处理/api前缀的请求
        RequestContext ctx = RequestContext.getCurrentContext();
        return ctx.getRequest().getRequestURI().startsWith("/api");
    }

    @Override
    public Object run() {
        RequestContext ctx = RequestContext.getCurrentContext();
        HttpServletRequest request = ctx.getRequest();
        
        // 获取约定的请求头（比如和前端约定用X-Target-Service指定目标服务）
        String targetService = request.getHeader("X-Target-Service");
        
        // 根据请求头值切换路由地址
        if ("service-a".equals(targetService)) {
            // 服务A的地址，若用Eureka可直接写服务名，无需硬编码IP端口
            ctx.setRouteHost(java.net.URI.create("http://service-a:8080").toURL());
        } else if ("service-b".equals(targetService)) {
            ctx.setRouteHost(java.net.URI.create("http://service-b:8081").toURL());
        } else {
            // 处理无效请求头的情况，返回明确错误并终止路由
            ctx.setResponseStatusCode(400);
            ctx.setResponseBody("请传入有效的X-Target-Service请求头，可选值：service-a/service-b");
            ctx.setSendZuulResponse(false);
        }
        
        return null;
    }
}

2. 基础路由配置（可选） #

如果你的Zuul已有基础路由配置，比如：

zuul:
  routes:
    api:
      path: /api/**
      url: http://default-service:8080 # 设置默认兜底服务，过滤器会覆盖此配置

这一步不是必须的，因为自定义过滤器已经能直接指定路由地址，基础配置仅作为兜底选项。

关键注意事项 #

• 请求头约定：务必和前端开发同学明确请求头的名称和可选值，避免出现参数误解。
• 整合服务发现：若使用Eureka/Nacos等服务发现组件，建议通过DiscoveryClient动态获取服务实例，避免硬编码地址：

  @Autowired
  private DiscoveryClient discoveryClient;
  
  // 在run方法中替换setRouteHost的逻辑
  List<ServiceInstance> instances = discoveryClient.getInstances(targetService);
  if (!instances.isEmpty()) {
      String serviceUrl = instances.get(0).getUri().toString();
      ctx.setRouteHost(java.net.URI.create(serviceUrl).toURL());
  } else {
      // 服务不存在时返回503错误
      ctx.setResponseStatusCode(503);
      ctx.setResponseBody("目标服务" + targetService + "暂时不可用");
      ctx.setSendZuulResponse(false);
  }
  

• 错误处理：一定要处理请求头缺失或值无效的场景，给前端明确的错误提示，避免排查困难。
• 过滤器优先级：filterOrder的数值必须设置正确，确保自定义过滤器在默认路由过滤器之前执行，否则修改会被覆盖。

测试验证 #

用curl或Postman发送请求验证效果：

# 路由到服务A
curl -H "X-Target-Service: service-a" http://你的Zuul地址:端口/api/xxx

# 路由到服务B
curl -H "X-Target-Service: service-b" http://你的Zuul地址:端口/api/xxx

# 无效请求头，返回400错误
curl -H "X-Target-Service: xxx" http://你的Zuul地址:端口/api/xxx

这样就能实现根据请求头动态选择路由到服务A或B啦～

内容的提问来源于stack exchange，提问作者Thomas