重定向时向 Zuul 添加标头

Question

我正在尝试使用Zuul 将调用重定向到其他地方的下游系统。 在重定向中，我需要添加一个包含必要数据的标题，以便api 接收重定向以进行处理。我似乎无法让下游系统检测到这些数据。附上我的代码。 我正在使用来自Edgware.SR3, Spring Boot 1.5.12的Zuul

祖尔过滤器

@Component
public class RouteFilter extends ZuulFilter{

@Override
public Object run() {
//Testing to add header
    context.getRequest().getParameterMap().put("api", new String[]{"api"});
    context.getResponse().setHeader("api", api);
    context.addZuulResponseHeader("api", "api");
    context.addZuulRequestHeader("api", "api");
    context.setSendZuulResponse(false);
    context.put(FORWARD_TO_KEY, redirect_urls.get(key));
    context.setResponseStatusCode(HttpStatus.SC_TEMPORARY_REDIRECT);
    context.getResponse().sendRedirect(redirect_urls.get(key));
    return null;
}
}

重定向的服务代码

@RequestMapping(value = "/forward")
public ResponseEntity<String> forwardToMe(@RequestHeader(required = true, name = "api")String api){
    return new ResponseEntity<String>("Hi",HttpStatus.OK);
}

在 Postman 中收到错误

{ “时间戳”：1524737817729， “状态”：400， "error": "错误请求", “异常”：“org.springframework.web.bind.ServletRequestBindingException”， "message": "String 类型的方法参数缺少请求标头 'api'", "路径": "/forward" }

Answer 1

我猜你使用了 Route Filter，也许你可以尝试使用 Pre Filter。

添加自定义标题可以通过以下方式完成：context.addZuulRequestHeader("Authorization", "Basic " + credentials);。

重定向部分可以查看thread

Answer 2

我在这里更新我的评论，以防万一有人仍然面临这个问题。 我最近发现了这个问题并通过在我的application.yml中添加以下配置来解决

application.yml ... zuul: sensitive-headers: - Cookie,Set-Cookie ...

参考链接如下：
https://cloud.spring.io/spring-cloud-static/Dalston.SR5/multi/multi__router_and_filter_zuul.html

Answer 3

我的回复有点晚，但工作正常
参考官方文档Cookies and Sensitive Headers
sensitiveHeaders 为黑名单，默认不为空。因此，to make Zuul send all headers (except the ignored ones), you must explicitly set it to the empty list。 如果您想将 cookie 或授权标头传递到后端，这样做是必要的。下面的例子展示了如何使用sensitiveHeaders：

zuul:
  routes:
    entry:
      path: /users/**
      strip-prefix: false
      service-id: users-service
      sensitive-headers:
      - Cookie,Set-Cookie

这个实现了example也可以帮到你

Answer 4

如果有人仍然面临这个问题，

在 Zuul Proxy 中，将 header 添加到 RequestContext 中，如下所示：

RequestContext ctx = RequestContext.getCurrentContext();
ctx.addZuulRequestHeader("param", "value");

然后在各自的微服务中编写自定义过滤器并提取如下值

@Component
public class MyFilter extends OncePerRequestFilter {

    @Override
    protected void doFilterInternal(HttpServletRequest request,
                                HttpServletResponse response,
                                FilterChain filterChain)
                                throws ServletException, IOException {

        String headerParam  =   request.getHeaders("param").nextElement();
    
        logger.info("headerParam: "+headerParam);
    
        filterChain.doFilter(request, response);
    }

}

Answer 5

RequestContext ctx = RequestContext.getCurrentContext();
    String auth = "useeerrr" + ":" + "passsss";
    ctx.addZuulRequestHeader("Authorization", "Basic " +
            Base64Variants.MIME_NO_LINEFEEDS.encode(auth.getBytes(StandardCharsets.US_ASCII)));
    ctx.addZuulRequestHeader("X-USERNAME-HEADER","xxx");

    Map<String, List<String>> newParameterMap = new HashMap<>();
    Map<String, String[]> parameterMap = ctx.getRequest().getParameterMap();
    for (Map.Entry<String, String[]> entry : parameterMap.entrySet()) {
        String key = entry.getKey();
        String[] values = entry.getValue();
        newParameterMap.put(key, Arrays.asList(values));
    }
   
    String authenticatedKey = "authenticated";
    String authenticatedValue = "true";
    newParameterMap.put(authenticatedKey,Arrays.asList(authenticatedValue));
    ctx.setRequestQueryParams(newParameterMap);
    HttpServletRequest request = ctx.getRequest();

    logger.info(String.format("%s request to %s", request.getMethod(), request.getRequestURL().toString()));

    return null;