java - 如何创建多个异步 java 过滤器？

Question

我正在尝试创建一个具有多个异步过滤器的 Java 应用程序，但似乎无法让它们很好地协同工作。我认为主要问题出在 run() 方法中，我不知道如何将请求传递到链中的下一个过滤器。我试过chain.doFilter(request, response)，但是好像不行，还有dispatch()和complete() API 在 AsyncContext 上可用，但那些似乎关闭了整个 AsyncContext。似乎必须有另一种方法才能让它发挥作用。下面是我正在使用的过滤器的一个片段 - 第二个过滤器看起来几乎相同。

注意:我正在添加 header 以尝试找出正在调用的内容。

    @Override
    public void doFilter(final ServletRequest request, final ServletResponse response, final FilterChain chain) throws IOException, ServletException {
        final AsyncContext asyncContext = request.startAsync();
        final HttpServletResponse res = (HttpServletResponse) response;
        asyncContext.addListener(new AsyncListener() {
            @Override
            public void onComplete(AsyncEvent event) throws IOException {
                res.addHeader("S-AST2", "onComplete");
            }

            @Override
            public void onTimeout(AsyncEvent event) throws IOException {
                res.addHeader("S-AST3", "onTimeout");
            }

            @Override
            public void onError(AsyncEvent event) throws IOException {
                res.addHeader("S-AST4", "onError");
            }

            @Override
            public void onStartAsync(AsyncEvent event) throws IOException {
                res.addHeader("S-AST0", "onStartAsync");
            }
        });

        asyncContext.start(new Runnable() {
            @Override
            public void run() {
                res.addHeader("S-AST1", "before");
                // This doesn't seem to work...
                asyncContext.dispatch();
                // ... or this ...
                asyncContext.complete();
                // ... or this ...
                chain.doFilter(request, response);
            }
        });
    }

感谢您的任何见解!

Answer 1

这个答案有两个部分。

1) chain.doFilter(request, response); 仍然是必需的。

2) 这不起作用的原因是在每个过滤器和 servlet 中我调用了 request.startAsync()，它启动了一个新异步进程，而不是使用现有的。因此，如果过滤器启动了一个异步进程，而 servlet 也启动了一个，它将覆盖/忽略过滤器中启动的进程。要解决此问题，您必须通过调用 request.isAsyncStarted() 检查异步进程是否已启动，如果已启动，您应该获取现有异步进程，而不是启动新的异步上下文使用 request.getAsyncContext()。下面是我为每个 servlet 和过滤器创建的帮助程序类，这样我就可以调用 AsyncHelper.getAsyncContext(request, response)，它将检索现有的 AsyncContext，或者创建一个新的一个。

public class AsyncHelper {
    public static AsyncContext getAsyncContext(ServletRequest request, ServletResponse response) {
        AsyncContext asyncContext = null;
        if (request.isAsyncStarted()) {
            asyncContext = request.getAsyncContext();
        }
        else {
            asyncContext = request.startAsync(request, response);
            asyncContext.setTimeout(2000);
        }
        return asyncContext;
    }
}