有一个疑问为什么不用 SSE 而是 NDJSON 呢？

[limboinf]

我看后端使用 chuned ndjson 的方式，而非 SSE：

def make_chunk(content=None, **kwargs):
        return (
            json.dumps(
                {"request_id": meta.get("request_id"), "response": content, **kwargs}, ensure_ascii=False
            ).encode("utf-8") + b"\n"
        )

...
yield make_chunk(status="finished", meta=meta)
...
return StreamingResponse(stream_messages(), media_type="application/json")

前端自定义解析逻辑：

buffer += decoder.decode(value, { stream: true });  // 累积数据
const lines = buffer.split('\n');                    // 按换行分割
buffer = lines.pop() || '';                          // 最后不完整的留着
for (const line of lines) {
  const chunk = JSON.parse(line.trim());             // 解析完整行
  _processStreamChunk(chunk);
}

这种会容易出 bug（buffer 边界处理）吧？

没有想明白为什么不用 SSE 的方式呢？更加规范、库自动处理，前端也有@microsoft/fetch-event-source 来自动解析。

[xerrors]

因为不会😂😂…… 你不说我都不知道，我是前端泥腿子

[limboinf]

哈哈哈，我也是，只是提出疑问，后面我觉得可以再优化下