如何断开OkHttp3 sse连接？

Question

我试图创建一个客户机，该客户机可以使用SSE（服务器发送的事件）从服务器接收事件，我使用OkHttp3和OkHttp3-sse库(com.squareup.OkHttp3:OKHTTP:4.1.0&com.squareup.OkHttp3:OKHTTP-SSE:4.1.0)来实现这一点。我可以连接到服务器并接收事件，但在某个时候，我想断开客户端并关闭我的应用程序。这就是问题所在。连接被关闭，但应用程序没有关闭，这可能是由于ConnectionPool没有关闭。

由于几乎没有任何关于OkHttp3-sse库使用的文档，我试图从代码中反向工程操作。我试过：

• 调用realeventsource.cancel()，它正在断开连接，但挂在线程上
• 调用OKHttpClient.dispatcher().CancelAll()，它也正在断开连接，但仍然挂在线程上
• 调用response.close()，并将其传递给eventsourcelistener.onopen()

作为另一种选择，我查看了https://github.com/heremaps/oksse，其中有realserversentevent.close()调用，它正在执行我所期望的操作。它关闭连接并停止所有线程，从而使应用程序完全关闭。我查看了RealServersentEvent类的实现，以了解该实现与RealEventSource有何不同。我认为区别在于读取循环的条件：

realeventsource行https://github.com/square/okhttp/blob/master/okhttp-sse/src/main/java/okhttp3/internal/sse/realeventsource.kt#l75:

      try {
        listener.onOpen(this, response)
        while (reader.processNextEvent()) {
        }
      } catch (e: Exception) {
        listener.onFailure(this, e, response)
        return
      }

与realserversentevent行https://github.com/heremaps/oksse/blob/master/src/main/java/com/here/oksse/realserversentevent.java#l94:

            listener.onOpen(this, response);

            //noinspection StatementWithEmptyBody
            while (call != null && !call.isCanceled() && sseReader.read()) {
            }

OKSSE实现包括如果在循环中调用.iscanceled()的条件，其中OKHTTP3-SSE不调用。我怀疑这导致OKHTTP3-SSE无法退出，但我可能错了。

或者，我是在监督预定的断开方式吗？

Answer 1

您正确地使用了API，当调用被取消时，OkHttp应该会导致读取失败，并出现IOException。显然，这种情况并没有发生，我认为这是OKHTTP中的一个bug。

下一步：向OKHTTP报告bug。如果你能用一个可执行的测试用例这样做，我会确保这个问题很快得到修复。