使用okHttp3发送sse请求,当事件为finish的时候,如何接收附加的数据?-灵析社区

我是张工你呢

### 问题描述 当前需要调用一个AI的接口,使用的工具是okHttp3,请求的方式是SSE。当事件状态是finish的时候,对方的响应事件中会携带一个附加的数据(meta)。结构如图: ![image.png](https://wmprod.oss-cn-shanghai.aliyuncs.com/images/20241117/e7c27ff25a4e759fd993fe15aa308d4a.png) 在传入的监听器中,onEvent()方法打印响应的data当状态是finish是,打印到的数据是空的,如下图:![image.png](https://wmprod.oss-cn-shanghai.aliyuncs.com/images/20241117/dee74748799e290c44846523672e6c92.png) 第一张图的来源是在初始化htttp客户端的时候加的一个网络请求拦截器打印出的信息,第二张图是代码中打印的log日志。 我的问题是为什么在onEvent()中接收不到meta的数据呢?应该如何接收呢? ### 问题出现的环境背景及自己尝试过哪些方法 1.首先确定了对方服务在finish状态的时候是一定响应了meta数据的。 2.查询过一些资料,尝试从将data转变为对象,取获取meta,但是也没有结果,是空的。 3.查询过一些其他的系统的源码,发现他们就是从data中获取的meta的数据,我也做同样的尝试,但是没有获取到。 ### 相关代码 发送请求的代码: public void chat(ModelEnum model, String content, WebSocketEventSourceListener listener) { // 初始化客户端 OkHttpClient okHttpClient = initOkHttpClient(); RequestBody requestBody = getRequestBody("你只需要回答'收到'两个字就可以了"); Request request = new Request.Builder() .url(getRequestUrl(model)) .header("Authorization", createToken()) .header("Accept", "text/event-stream") .post(requestBody) .build(); RealEventSource eventSource = new RealEventSource(request, listener); eventSource.connect(okHttpClient); } private OkHttpClient initOkHttpClient() { // 初始化客户端 return new OkHttpClient .Builder() .connectTimeout(30, TimeUnit.SECONDS) .writeTimeout(600, TimeUnit.SECONDS) .readTimeout(600, TimeUnit.SECONDS) .addInterceptor(new HttpLoggingInterceptor().setLevel(HttpLoggingInterceptor.Level.BODY)) .build(); } 监听器代码: public class WebSocketEventSourceListener extends EventSourceListener { @Override public void onOpen(EventSource eventSource, Response response) { log.info("ListenerOnOpen============={}", "建立sse连接"); } @Override public void onEvent(EventSource eventSource, String id, String type, String data) { log.info("ListenerOnEvent========== id:{}, type: {}, data: {}", id, type, data); } @Override public void onClosed(EventSource eventSource) { log.info("ListenerOnClose========== {}", "连接sse关闭"); } @Override public void onFailure(EventSource eventSource, Throwable t, Response response) { } } 在此段代码中onEvent()会接收响应的数据。单是在状态是finish的时候却收不到附加的数据。 ### 你期待的结果是什么?实际看到的错误信息又是什么? 能够在onEvent()中收到meta的数据,实际并没有收到。

阅读量:28

点赞量:0

问AI
SSE 的规范中明确指出,每个事件的结构中的 field 只能是以下几个取值: * event * data * id * retry 所有其他的字段名都会被忽略。 «"https://developer.mozilla.org/zh-CN/docs/Web/API/Server-> sent_..." (https://link.segmentfault.com/?enc=QB7pmkpN%2BIRpe8ly4Ih0Qw%3D%3D.m8g%2B7EsFQowdp0l99Hz1zJUDQPuwzioGa1LjO3SB66ZKuMOHKK5YaPkrbMV3a2LVUlkR4s9jDeVBKhrwI6Ewjgx99ckFHHzK6pdMi%2BNzgd5cO9PcNZuDs%2BPPJDp3rwD78u8HsTHJhAes05bV%2Fftsbg%3D%3D)» 显然 OkHttp 在解析事件时遵守了此规范。从源码中我们也可以看出这一点: «"https://github.com/square/okhttp/blob/okhttp_3.14.x/okhttp-> sse/src/main/java/okhttp3/internal/sse/ServerSentEventReader.java#L55-L102" (https://link.segmentfault.com/?enc=gQoLM7mvNymzm%2FDk%2BCo%2BWg%3D%3D.j9UuypYX19or6Equq9X7o0gbfLamO3DXTUV70R%2F%2F0lq8qs3z3uFKQni5Ft9S1iNwXB4qXo7lxPHN%2F2RcvNdTgw%2FL%2FcbaOhs%2FoeOjwKPVkHBPUoB9H%2FK2QNkDQdKuNgEaI6FHgCrhom13gqyhgBQUbMFKnZrqxcrkY7%2BhThK9OrD8vMcEmvV0QwoPhv6zQYmq)» 所以你这里的问题是上游系统使用了非标准的 SSE 协议。如果上游服务不做修改的话,你只能从底层的 HttpClient 自己动手撸一个 Parser 来处理这种特殊场景了。