我需要将某些 HTTP 请求重定向到 Spring Boot Web 应用程序/服务，但在请求端，Spring 应用程序什么也不做，而是充当 HTTP 客户端(另一个服务)和请求的真实目的地。但是当响应返回到 Spring 应用程序(从该目的地)时，我需要 Spring 应用程序能够检查响应并可能在需要时对其采取措施。所以:

1. HTTP 客户端向 http://someapi.example.com 发出请求
2. 网络魔术将请求路由到我的 Spring 应用程序，例如 http://myproxy.example.com
3. 在请求时，此应用程序/代理不执行任何操作，因此请求在 http://someapi.example.com 上转发
4. http://someapi.example.com 的服务端点向代理返回 HTTP 响应
5. http://myproxy.example.com 上的代理检查此响应，并可能在将响应返回给原始客户端之前发送警报

本质上，过滤器充当请求的传递，并且仅在远程服务执行并返回响应之后真正执行任何操作。

到目前为止，我最好的尝试是设置一个 servlet 过滤器:

@Override
void doFilter(ServletRequest request, ServletResponse response, FilterChain chain)
        throws IOException, ServletException {
    chain.doFilter(request, response)

    // How and where do I put my code?
    if(responseContainsFizz(response)) {
        // Send an alert (don't worry about this code)
    }
}

java.lang.IllegalStateException: STREAM
    at org.eclipse.jetty.server.Response.getWriter(Response.java:910) ~[jetty-server-9.2.16.v20160414.jar:9.2.16.v20160414]
    at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) ~[na:1.8.0_92]
  rest of stack trace omitted for brevity

最佳答案

根据 Servlet API 文档，您收到 IllegalStateException 的原因是您尝试在 ServletResponse.getOutputStream 之后调用 ServletResponse.getWriter > 已经被要求响应。所以看来你需要调用的方法是ServletResponse.getOutputStream()。

但是，如果您尝试访问响应的正文，最好的解决方案是将响应包装在 ServletResponseWrapper 中，以便您可以捕获数据:

public class MyFilter implements Filter
{
    @Override
    public void init(FilterConfig filterConfig) throws ServletException
    {

    }

    @Override
    public void destroy()
    {

    }

    @Override
    public void doFilter(ServletRequest request, ServletResponse response, FilterChain chain) throws IOException, ServletException
    {
        MyServletResponseWrapper responseWrapper = new MyServletResponseWrapper((HttpServletResponse) response);
        chain.doFilter(request, responseWrapper);
        if (evaluateResponse(responseWrapper)) {
            // Send an alert
        }
    }

    private boolean evaluateResponse(MyServletResponseWrapper responseWrapper) throws IOException
    {
        String body = responseWrapper.getResponseBodyAsText();

        // Perform business logic on the body text

        return true;
    }

    private static class MyServletResponseWrapper extends HttpServletResponseWrapper
    {
        private ByteArrayOutputStream copyOutputStream;
        private ServletOutputStream wrappedOutputStream;

        public MyServletResponseWrapper(HttpServletResponse response)
        {
            super(response);
        }

        public String getResponseBodyAsText() throws IOException
        {
            String encoding = getResponse().getCharacterEncoding();
            return copyOutputStream.toString(encoding);
        }


        @Override
        public ServletOutputStream getOutputStream() throws IOException
        {
            if (wrappedOutputStream == null) {
                wrappedOutputStream = getResponse().getOutputStream();
                copyOutputStream = new ByteArrayOutputStream();
            }
            return new ServletOutputStream()
            {
                @Override
                public boolean isReady()
                {
                    return wrappedOutputStream.isReady();
                }

                @Override
                public void setWriteListener(WriteListener listener)
                {
                    wrappedOutputStream.setWriteListener(listener);
                }

                @Override
                public void write(int b) throws IOException
                {
                    wrappedOutputStream.write(b);
                    copyOutputStream.write(b);
                }

                @Override
                public void close() throws IOException
                {
                    wrappedOutputStream.close();
                    copyOutputStream.close();
                }
            };
        }
    }
}

关于java - 仅对来自远程端点的响应起作用的 Servlet 过滤器 "proxy"，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/41717087/