实时应用已经成为现代web应用程序中的重要组成部分。它允许服务器向客户端发送实时更新，并允许客户端与服务器进行实时通信。在本博客中，我们将学习如何使用Express.js框架构建实时应用，并集成WebSocket、Server-Sent Events（SSE）等技术。
WebSocket
WebSocket是一种双向通信协议，可以在单个TCP连接上全双工通信。它允许服务器主动向客户端推送消息，并且可以通过客户端发送消息给服务器。使用WebSocket，我们可以实现实时聊天应用、实时博客评论等功能。
要在Express.js中使用WebSocket，我们可以使用ws库。首先，我们需要安装该库：
npm install ws
然后，我们可以创建一个WebSocket服务器：
const express = require('express');
const http = require('http');
const WebSocket = require('ws');
const app = express();
const server = http.createServer(app);
const wss = new WebSocket.Server({ server });
wss.on('connection', (ws) => {
// 监听连接事件
console.log('Client connected');
// 监听消息事件
ws.on('message', (message) => {
console.log('Received message:', message);
// 向所有客户端广播消息
wss.clients.forEach((client) => {
client.send(message);
});
});
// 监听关闭事件
ws.on('close', () => {
console.log('Client disconnected');
});
});
server.listen(3000, () => {
console.log('Server started on http://localhost:3000');
});
Server-Sent Events (SSE)
Server-Sent Events（SSE）是一种用于实时更新的HTTP流协议。与WebSocket不同，SSE是单向通信，只允许服务器向客户端发送消息。它适用于类似新闻推送、实时股票报价等应用。
要在Express.js中使用SSE，我们可以使用express-sse库。首先，我们需要安装该库：
npm install express-sse
然后，我们可以创建一个SSE服务器：
const express = require('express');
const SSE = require('express-sse');
const app = express();
const sse = new SSE();
app.get('/stream', sse.init);
app.get('/message/:message', (req, res) => {
const message = req.params.message;
// 向客户端发送消息
sse.send(message);
res.send('Message sent');
});
app.listen(3000, () => {
console.log('Server started on http://localhost:3000');
});
然后，我们可以从客户端监听SSE事件：
const source = new EventSource('/stream');
source.addEventListener('message', (event) => {
const message = event.data;
console.log('Received message:', message);
});
总结
在本博客中，我们学习了如何使用Express.js构建实时应用，并集成WebSocket、SSE等技术。WebSocket提供了双向通信功能，适用于需要客户端与服务器之间实时通信的应用。而SSE则提供了单向通信功能，适用于只需要服务器向客户端发送实时更新的应用。
希望本博客能帮助你了解如何使用Express.js构建实时应用，并集成WebSocket、SSE等技术。祝你在构建实时应用中取得成功！
本文来自极简博客，作者：算法架构师，转载请注明原文链接：使用Express.js构建实时应用：WebSocket、SSE和Server-Sent Events的集成
