在前端开发中，WebSocket 是一种非常常见的实现实时通信的技术。在 Fastify 中，实现 WebSocket 广播消息也非常简单。
WebSocket 简介
WebSocket 是一种基于 TCP 协议的全双工通信协议，它使得浏览器和服务器之间可以进行实时的双向通信。与传统的 HTTP 请求不同，WebSocket 是一种长连接，它可以保持连接状态，并且可以发送和接收数据。
在使用 WebSocket 进行通信时，需要在客户端和服务器端分别实现 WebSocket 的连接和消息处理。
Fastify 中实现 WebSocket
Fastify 是一个高效、低开销的 Web 框架，它提供了一个简单易用的插件系统，可以方便地扩展功能。Fastify 中提供了 fastify-websocket 插件，可以方便地实现 WebSocket 功能。
安装插件
首先需要安装 fastify-websocket 插件。
npm install fastify-websocket
注册插件
在 Fastify 中注册插件，可以使用 register 方法。
const fastify = require('fastify')()
fastify.register(require('fastify-websocket'))处理 WebSocket 连接
在 Fastify 中，可以使用 websocket 方法处理 WebSocket 连接。当客户端连接时，会触发 websocket 方法的回调函数，可以在回调函数中处理连接。
// javascriptcn.com 代码示例
fastify.get('/websocket', { websocket: true }, (connection, request) => {
connection.socket.on('message', message => {
// 处理消息
})
connection.socket.on('close', () => {
// 连接关闭
})
})广播消息
在处理 WebSocket 连接时，可以使用 fastify.websocketServer.clients 获取所有连接的客户端。可以遍历所有客户端，向它们发送消息。
fastify.get('/websocket', { websocket: true }, (connection, request) => {
connection.socket.on('message', message => {
fastify.websocketServer.clients.forEach(client => {
client.send(message)
})
})
})示例代码
下面是一个完整的示例代码，可以在本地运行，实现 WebSocket 广播消息。
// javascriptcn.com 代码示例
const fastify = require('fastify')()
fastify.register(require('fastify-websocket'))
fastify.get('/', (req, res) => {
res.send('Hello World!')
})
fastify.get('/websocket', { websocket: true }, (connection, request) => {
connection.socket.on('message', message => {
fastify.websocketServer.clients.forEach(client => {
client.send(message)
})
})
connection.socket.on('close', () => {
console.log('Connection closed')
})
})
fastify.listen(3000, err => {
if (err) {
console.error(err)
process.exit(1)
}
})总结
在 Fastify 中实现 WebSocket 广播消息非常简单。通过注册 fastify-websocket 插件，可以方便地处理 WebSocket 连接和消息，使用 fastify.websocketServer.clients 可以轻松实现广播功能。希望本文对你有所帮助。
来源：JavaScript中文网 ，转载请注明来源 本文地址：https://www.javascriptcn.com/post/656026a3d2f5e1655da554e3