使用 HTML5 服务器事件和 Java Servlet 时如何防止 net::ERR_INCOMPLETE_CHUNKED_ENCODING？

我刚刚开始玩服务器事件，遇到了一条我想了解的 chrome 错误消息。我很快在网上搜索，但没有找到解释，所以我想我可能做了一些非常错误的事情。

在服务器端，我有一个简单的 servlet，它接受请求并创建一个虚拟事件创建器任务：

private Executor executor = Executors.newSingleThreadExecutor();

public void doGet(final HttpServletRequest request, final HttpServletResponse response)
{
  final AsyncContext asynCtx = request.startAsync(request, response);

  response.setHeader("Cache-Control", "no-cache");
  response.setContentType("text/event-stream");
  response.setCharacterEncoding("utf-8");

  executor.execute(() -> {
    boolean run = true;
    try
    {
      while (run)
      {
        final ServletResponse resp = asynCtx.getResponse();
        run = resp != null;

        if (resp != null)
        {
          System.out.println("pushing a server event.");
          final PrintWriter writer = asynCtx.getResponse().getWriter();
          writer.println("data: {time: " + System.currentTimeMillis() + "}\n");
          writer.flush();
        }
        else
        {
          System.out.println("stopping beeper, no response object available anymore.");
          break; // do not run anymore, we got no response
        }

        Thread.sleep(2000);
      }
    }
    catch (final Exception e)
    {
      e.printStackTrace();
    }
  });

}

在客户端我只是：

$(document).ready(function ()
{

   var source = new EventSource("/events");
   source.onmessage = function (event)
   {
     console.log("received event: " + JSON.stringify(event));
     document.getElementById("eventContainer").innerHTML += event.data + "<br/>";
   };

   console.log("start to receive events...")
});

当我加载 HTML 文件时，它工作正常，接收事件并将其写入控制台。但30秒后我收到一条错误消息：

GET [HttpOfLocalhost]/events net::ERR_INCOMPLETE_CHUNKED_ENCODING

why?

该请求会被终止，并立即启动一个新请求，因此它不会终止应用程序，但控制台上的错误消息并不好。

我的开发者控制台的屏幕截图：

请求/响应详细信息：

计时，这表明它总是在 30 秒后发生：

Thanks!

好吧，所以我不能站着不动，仔细看看发生了什么。

The 异步上下文 https://docs.oracle.com/javaee/6/api/javax/servlet/AsyncContext.html对象有一个设置超时(...) https://docs.oracle.com/javaee/6/api/javax/servlet/AsyncContext.html#getTimeout()方法。在我的 tomcat 版本（嵌入 Tomcat 8）中，默认值设置为 30,000 毫秒（30 秒）。这正是我得到后的持续时间净::ERR_INCOMPLETE_CHUNKED_ENCODING我的 Chrome 控制台出现错误。

我检查使用：

System.out.println("Current Timeout is: " + asynCtx.getTimeout() + " ms");

结果表明：

Current Timeout is: 30000 ms

因此，为了避免出现 net:ERR 消息，有人可以将超时设置为 0。但事件线程会永远运行（不幸的是）。 我使用的另一个解决方案是添加异步监听器 https://docs.oracle.com/javaee/6/api/javax/servlet/AsyncListener.html to the 异步上下文 https://docs.oracle.com/javaee/6/api/javax/servlet/AsyncContext.html并致电完全的（） https://docs.oracle.com/javaee/6/api/javax/servlet/AsyncContext.html#complete()里面的方法超时() https://docs.oracle.com/javaee/6/api/javax/servlet/AsyncListener.html#onTimeout(javax.servlet.AsyncEvent)方法。

来自complete()方法的API文档：

完成根据请求启动的异步操作 用于初始化此 AsyncContext，关闭响应 用于初始化此 AsyncContext。任何类型的听众 已向 ServletRequest 注册的 AsyncListener 创建的 AsyncContext 将在其 onComplete 时调用 方法。

我的监听器的源代码：

asynCtx.addListener(new AsyncListener()
{
  @Override
  public void onComplete(AsyncEvent asyncEvent) throws IOException
  {
    System.out.println("onComplete(...)");
  }

  @Override
  public void onTimeout(AsyncEvent asyncEvent) throws IOException
  {
    // this will close the request and the context gracefully
    // and the net:ERR is gone.
    asyncEvent.getAsyncContext().complete();
    System.out.println("onTimeout(...)");
  }

  @Override
  public void onError(AsyncEvent asyncEvent) throws IOException
  {
    System.out.println("onError(...)");
  }

  @Override
  public void onStartAsync(AsyncEvent asyncEvent) throws IOException
  {
    System.out.println("onStart(...)");
  }
});

所以是的，这是由于缺乏知识。我希望这对某人有帮助。