WebSocket 是一种基于 TCP 的协议，旨在通过持久化的双向连接在客户端和服务器之间传输数据。与传统的 HTTP 请求/响应模型不同，WebSocket 允许服务器主动向客户端推送消息，而客户端不需要反复发送请求。这样就能实现低延迟、高效的实时通信。
为什么 WebSocket 适合实时消息推送？
- 双向通信：WebSocket 允许客户端和服务器之间进行双向通信，这使得实时消息推送非常高效。服务器可以在有新消息时主动向客户端推送，而客户端无需一直轮询服务器。
- 低延迟：WebSocket 连接在初始握手后会保持打开状态，避免了每次发送数据时都需要重新建立连接的开销，因此消息传输的延迟较低，适合实时应用场景。
- 节省资源：传统的轮询需要客户端定期请求服务器，甚至在没有新消息的情况下仍然消耗带宽和服务器资源，而 WebSocket 只有在有新数据时才会传输信息，节省了资源。
- 持续连接：WebSocket 建立的连接通常是持久的，可以一直维持，直到显式关闭，这意味着服务器和客户端可以随时互相发送消息。
WebSocket 实现实时消息推送的基本步骤
- 客户端与服务器建立 WebSocket 连接：
- 客户端通过 WebSocket 客户端 API（例如 JavaScript 中的
WebSocket对象）发起连接。 - 服务器端需要支持 WebSocket 协议，可以使用如 Node.js (ws)、Python (websockets)、Java (Java WebSocket) 等库实现。
- 服务器推送消息：
- 一旦连接建立，服务器可以在任何时候向客户端发送消息。
- 客户端接收消息：
- 客户端会监听 WebSocket 的事件，接收到消息后进行处理，如更新 UI、显示通知等。
示例代码
客户端 (JavaScript)
const socket = new WebSocket('ws://yourserver.com/path'); // 连接到 WebSocket 服务器
// 连接成功
socket.onopen = function(event) {
console.log('WebSocket connection established');
socket.send('Hello, server!'); // 可选: 发送消息到服务器
};
// 接收服务器推送的消息
socket.onmessage = function(event) {
console.log('Message from server:', event.data);
// 处理接收到的消息，比如显示推送通知
};
// 处理错误
socket.onerror = function(error) {
console.error('WebSocket error:', error);
};
// 连接关闭
socket.onclose = function(event) {
console.log('WebSocket connection closed');
};服务器端 (Node.js 示例, 使用 ws 库)
const WebSocket = require('ws');
const wss = new WebSocket.Server({ port: 8080 });
wss.on('connection', function(ws) {
console.log('Client connected');
// 发送消息到客户端
ws.send('Welcome to the server!');
// 接收来自客户端的消息
ws.on('message', function(message) {
console.log('Received message from client:', message);
});
// 每隔 5 秒向客户端推送消息
setInterval(() => {
ws.send('Real-time update from server');
}, 5000);
});使用场景
- 聊天应用：可以实时发送和接收消息。
- 股票/金融应用：实时更新市场数据和股票价格。
- 多人在线游戏：实时同步游戏状态和玩家动作。
- 通知系统：实时推送通知给用户（如社交网络、新闻推送、系统报警等）。
注意事项
- 连接管理：WebSocket 连接是持久的，需要管理好连接的打开、关闭和重连。
- 负载均衡：如果有大量客户端连接，可能需要考虑 WebSocket 服务器的负载均衡问题。
- 安全性：对于 WebSocket，推荐使用
wss://（加密的 WebSocket 连接）来确保通信安全。