如何在 SvelteKit 中实现服务器发送事件 (SSE)？

Question

如果不使用自定义 Express 服务器，我找不到 SvelteKit 的教程。有 API 端点的替代方案吗？

我尝试自己设置 API 端点，但无法让它在数据更改时发送更新。

Answer 1

您可能必须返回一个ReadableStream可以写入更新的文件。这样连接就不会关闭。

截至目前，还有一个关于更多相关文档的悬而未决的问题。

Answer 2

感谢@Paolo 的想法。这是一个更具体的例子：

在您的+server.js文件中，实现以下代码：

// SSE only supports GET request
export async function GET({ url }) {
    const stream = new ReadableStream({
        start(controller) {
            // You can enqueue multiple data asynchronously here.
            const myData = ["abc", "def"]
            myData.forEach(data => {
                controller.enqueue(`data: ${data}\n\n`)
            })
            controller.close() 
        },
        cancel() {
            // cancel your resources here
        }
    });

    return new Response(stream, {
        headers: {
            // Denotes the response as SSE
            'Content-Type': 'text/event-stream', 
            // Optional. Request the GET request not to be cached.
            'Cache-Control': 'no-cache', 
        }
    })
}