前置知识
在学习本教程前，你需要了解的技术知识有：
- Node.js
- Fastify框架
介绍
fastify-sse是一个npm包，用于在Fastify框架中实现Server-Sent Events（服务端推送）的功能。Server-Sent Events是一种服务器端向客户端发送连续的文本事件的技术，非常适合实现一些需要实时数据更新的场景，比如实时聊天、推送通知等。
fastify-sse是一个轻量级、易用的npm包，提供了一套简单明了的API，可供开发者快速上手使用。
安装
使用npm安装fastify-sse：
npm install fastify-sse
用法
在Fastify应用中集成fastify-sse，只需要在应用启动时注册相关路由即可。
以下为一个简单的示例：
-- -------------------- ---- -------
----- ------- - --------------------
----- --- - ----------------------
---------------------- ------ ----- ----- ------ -- -
-- -------------
-------------- -- -
----------------- --------
-- -----
--
--------------------在上面的示例中，我们创建了一个Fastify应用，并注册了一个GET路由“/stream”。在该路由中，我们使用fastify-sse提供的“sse()”插件来创建一个SSE的响应对象，并使用该响应对象的“sse()”方法，向客户端推送一条消息“Hello, world!”，并且每秒钟推送一次。
启动应用后，可以通过curl命令来测试：
curl -H 'Cache-Control: no-cache' -H 'Content-Type: text/event-stream' http://localhost:3000/stream
该命令将连接到我们在应用中注册的SSE路由，并开始获取服务器端推送的消息。
指南
推送事件
要向客户端推送事件，可以使用“reply.sse(event, data)”方法，其中：
- event：可选参数，表示事件类型，默认为“message”。
- data：必选参数，表示事件数据。
示例：
fastify.get('/stream', sse(), async (req, reply) => {
// 推送自定义的事件
reply.sse('custom-event', { foo: 'bar' })
// 推送默认的事件
reply.sse('Hello, world!')
})控制事件间隔
SSE事件间隔是通过服务端向客户端发送“ping”消息来控制的，通常为了保持连接不断开，应该定时向客户端发送“ping”消息。
fastify-sse提供了一个名为“pingInterval”的选项，可以用来控制“ping”消息的发送间隔。默认情况下该选项值为30000（30秒）。
示例：
fastify.get('/stream', sse({ pingInterval: 5000 }), async (req, reply) => {
// 推送消息
setInterval(() => {
reply.sse('Hello, world!')
}, 1000)
})在上面的示例中，我们设置了“pingInterval”选项为5000毫秒（5秒）。也就是说，每5秒向客户端发送一次“ping”消息，防止连接断开。
控制重试机制
在SSE连接断开后，客户端需要重新连接。为了减少服务器端的负担，客户端会使用“retry”选项指定重新连接的时间间隔。
fastify-sse提供了一个名为“retry”的选项，可以用来控制“retry”选项的值。默认情况下，无该选项的情况下，客户端使用的默认值为3000（3秒）。
示例：
fastify.get('/stream', sse({ retry: 1000 }), async (req, reply) => {
// 推送消息
setInterval(() => {
reply.sse('Hello, world!')
}, 1000)
})在上面的示例中，我们设置了“retry”选项为1000毫秒（1秒）。也就是说，当SSE连接断开后客户端重新连接时，将尝试在1秒后重新连接。
总结
fastify-sse是一个非常实用的npm包，用于实现Fastify框架中的Server-Sent Events。本文详细讲解了fastify-sse的使用方法，希望能够帮助读者快速上手使用该npm包来实现各种实时通信场景。
来源：JavaScript中文网 ，转载请注明来源 https://www.javascriptcn.com/post/600560cd81e8991b448df10a