使用fetch请求streams api的,当请求开始响应的时候,使用read()将返回的流式数据转成可展示的数据,然后通过while循环重复以上过程达到流式展示的效果;
问题:
第一次使用read()解析返回数据的时候,会执行很长时间,阻塞了后续执行;之后会将请求每次返回的数据一次性处理执行;造成的实际页面效果是:页面会空白很长时间,然后突然把所有的数据展示出来了,失去了流式的效果;
const response = await fetch(url, {
method: 'POST',
headers: {
[Authorization]: getAuthorization(),
'Content-Type': 'application/json',
},
body: JSON.stringify(body),
});
const reader = response.body
?.pipeThrough(new TextDecoderStream())
.pipeThrough(new EventSourceParserStream())
.getReader();
while (true) {
// 第一次console时间
console.log(new Date().getTime());
const x = await reader?.read();
// 第二次console时间
console.log(new Date().getTime());
if (x) {
const { done, value } = x;
console.log('value', value)
try {
// 处理展示streams数据
} catch (e) {
console.warn(e);
}
if (done) {
console.info('done');
break;
}
}
}
第一次和第二次时间打印之间间隔了几十s,是因为await reader?.read();语句导致的,但不知道什么原因导致的;
之后循环的每一次过程2此时间打印间隔都很小且都为流式数据正确的结果,从循环第二次开始到循环结束大概只有几十ms的时间;
造成的影响就是页面空白了几十s,然后所有的数据就突然展示出来,并不是每个字轮流出现的效果;
有没有大佬能帮忙,是因为第一次的read()执行将之后所有的返回数据都处理了并等待streams api达到done状态后才执行后面的内容造成了阻塞效果,还是因为其它原因。
同一个服务接口用在其它页面上是能展示正确的流式输出效果的;
问题已解决。
该问题所在的开源项目使用了umijs框架,老版本会默认阻塞SSE特性的流式请求,切换到新版本并关闭dev server压缩即可。
其它参考内容:
https://github.com/umijs/umi/issues/12144
https://github.com/umijs/umi/releases/tag/v4.1.5
https://stackoverflow.com/questions/76544408/is-fetch-read-stream-data-after-all-chunk-received-but-not-read-once-a-chunk-rec/76545425#76545425
https://blog.csdn.net/weixin_45501219/article/details/135879885