流式输出中okhttp的eventsource关闭问题

[StefanVam]

调用大模型接口返回的eventType一直是result，只有data中finishreason有stop或者length，代码后面会调用emitter.onComplete么，还是说这个emitter会自动关闭

[robinyeeh]

ok http的eventsouce会在链接关闭的时候调用onClosed回调方法进行关闭，这里是通过依赖了服务端的sse done事件类型来关闭flowable的emitter.

[StefanVam]

@robinyeeh 好的，谢谢，我想再问下finishreson为stop或者length之后，是不是大模型服务端就会调用sse done事件了，我在日志打印里没看到返回DONE的相关信息

[robinyeeh]

Done的信息在sdk处理掉了，不会给到调用侧

[Veitor]

@robinyeeh 客户端（也就是我编写的代码里）中如何主动关闭连接？

因为我现在有这样的情况：用户客户端C请求我的项目A，我的项目A再请求S端阿里云百炼，S通过SSE流式返回数据给A，A再SSE流式返回给C。但有一些情况下，可能因为C侧主动断开与A的连接，或者因为网络问题而断开了C与A的连接，那么此时A与S的连接也没必要保持了，所以我打算也要断开A与S的连接，但我在sdk提供的高层方法中似乎并没有找到可以实现关闭与S的连接方式。

[lzsweb]

Fixed. Implemented SSE EventSource lifecycle management: stream disposal now properly cancels the upstream connection. Also fixed thread-safety for concurrent streaming requests by using a ConcurrentHashMap-backed Set instead of a single instance variable. Will be available in v2.22.21.

[lzsweb]

Fixed in v2.22.21. The OkHttp EventSource lifecycle management has been rewritten to use a thread-safe ConcurrentHashMap-backed Set<EventSource> for tracking all active SSE streams. The close() method now properly iterates and cancels all active sources, and an AtomicBoolean double-check pattern prevents race conditions between callbacks and registration.