Jersey 2 过滤器在客户端请求过滤器中使用容器请求上下文

Question

我有一个 Jersey 2 Web 服务，它在收到请求后，向另一个 Web 服务发出另一个请求，以形成对原始请求的响应。因此，当客户端“A”向我的 Web 服务“B”发出请求时，“B”向“C”发出请求，作为对“A”的响应的一部分。

A->B->C

我想为 Jersey 2 Web 服务实现一个过滤器，它基本上是这样做的：

• 客户端“A”将发送一个请求，其标题如下 “我的标题：第一”

• 当我的 Web 服务“B”随后发出客户端请求“C”时，它应该 附加到该标头，因此它使用此标头发送请求 “我的标题：第一，第二”。

我想将其实现为过滤器，这样我的所有资源就不必重复附加到请求标头的逻辑。

但是，在 Jersey 2 中，您会获得以下 4 个过滤器：

• ContainerRequestFilter - 过滤/修改入站请求
• ContainerResponseFilter - 过滤/修改出站响应
• ClientRequestFilter - 过滤/修改出站请求
• ClientResponseFilter - 过滤/修改入站响应

我需要使用入站请求的标头，对其进行修改，然后将其用作出站请求，因此基本上我需要既是 ContainerRequestFilter 又是 ClientRequestFilter 的东西。我不认为在同一个过滤器中实现两者会起作用，因为你不知道哪个客户端请求映射到哪个容器请求，或者你知道吗？

Answer 1

我找到了一种很好的方法来做到这一点，它不使用ThreadLocal 在ContainerRequestFilter 和ClientRequestFilter 之间进行通信，因为您不能假设响应容器请求的客户端请求将是在同一个线程上。

我实现这一点的方法是在ContainerRequestFilter 中的ContainerRequestConext 对象中设置一个属性。然后我可以将ContainerRequestContext 对象（显式或通过依赖注入）传递给我的ClientRequestFilter。如果您使用依赖注入（如果您使用的是 Jersey 2，那么您可能使用的是 HK2），那么所有这些都可以在不修改任何资源级别逻辑的情况下实现。

有一个像这样的ContainerRequestFilter：

public class RequestIdContainerFilter implements ContainerRequestFilter {

@Override
public void filter(ContainerRequestContext containerRequestContext) throws IOException {
    containerRequestContext.setProperty("property-name", "any-object-you-like");
}

还有一个 ClientRequestFilter 在其构造函数中采用 ContainerRequestContext：

public class RequestIdClientRequestFilter implements ClientRequestFilter {

    private ContainerRequestContext containerRequestContext;

    public RequestIdClientRequestFilter(ContainerRequestContext containerRequestContext) {
        this.containerRequestContext = containerRequestContext;
    }

    @Override
    public void filter(ClientRequestContext clientRequestContext) throws IOException {
        String value = containerRequestContext.getProperty("property-name");
        clientRequestContext.getHeaders().putSingle("MyHeader", value);
    }
}

那么这只是将这一切捆绑在一起的情况。您将需要一个工厂来创建您需要的任何 Client 或 WebTarget：

public class MyWebTargetFactory implements Factory<WebTarget> {

    @Context
    private ContainerRequestContext containerRequestContext;

    @Inject
    public MyWebTargetFactory(ContainerRequestContext containerRequestContext) {
        this.containerRequestContext = containerRequestContext;
    }

    @Override
    public WebTarget provide() {
        Client client = ClientBuilder.newClient();
        client.register(new RequestIdClientRequestFilter(containerRequestContext));
        return client.target("path/to/api");
    }

    @Override
    public void dispose(WebTarget target) {

    }
}

然后注册过滤器并将你的工厂绑定到你的主应用ResourceConfig:

public class MyApplication extends ResourceConfig {

    public MyApplication() {
        register(RequestIdContainerFilter.class);
        register(new AbstractBinder() {
            @Override
            protected void configure() {
                bindFactory(MyWebTargetFactory.class).to(WebTarget.class);
            }
        }
    }
}

Answer 2

容器过滤器可以在一个类中同时实现ContainerRequestFilter 和ContainerResponseFilter。客户端过滤器也是如此，ClientRequestFilter 和 ClientResponseFilter 都可以在一个过滤器实现中实现。

但据我所知，你不能混音。相反，您可以拥有两个相互通信的独立过滤器，例如使用ThreadLocal 模式：

// Container filter that stores the request context in a ThreadLocal variable
public class MyContainerRequestFilter implements ContainerRequestFilter, ContainerResponseFilter {
    public static final ThreadLocal<ContainerRequestContext> requestContextHolder;

    @Override
    public void filter(ContainerRequestContext requestContext) throws IOException {
        requestContextHolder.set(requestContext);
    }

    @Override
    public void filter(ContainerRequestContext requestContext, ContainerResponseContext responseContext) throws IOException {
        // clean up after request
        requestContextHolder.remove();
    }
}

// Client request filter that uses the info from MyContainerRequestFilter
public class MyClientRequestFilter implements ClientRequestFilter {
    @Override
    public void filter(ClientRequestContext requestContext) throws IOException {
        ContainerRequestContext containerRequestContext =
            MyContainerRequestFilter.requestContextHolder.get();
        if (containerRequestContext != null) {
            // TODO: use info from containerRequestContext to modify client request
        }
    }
}