如何用WebSocket实现一个实时聊天应用？-js教程-PHP中文网

如何用WebSocket实现一个实时聊天应用？

幻影之瞳

发布： 2025-09-24 20:43:01

原创

647人浏览过

答案：使用WebSocket协议通过Node.js的ws库实现服务端与客户端双向通信，搭建实时聊天应用。首先创建Express服务器并集成WebSocketServer，维护客户端连接集合，接收消息后广播给其他用户；前端通过new WebSocket连接服务端，监听消息并动态更新页面内容；后续可扩展用户名、消息类型、聊天室、持久化及心跳机制；部署时注意Nginx配置WebSocket代理，高并发场景结合Redis进行跨实例消息同步。

如何用websocket实现一个实时聊天应用？

实现一个实时聊天应用，核心是建立客户端与服务器之间的双向通信。WebSocket 正是为此设计的协议，相比轮询或长连接，它能更低延迟地实现实时消息传递。下面从架构到代码，一步步说明如何用 WebSocket 实现一个基础但完整的实时聊天应用。

1. 搭建 WebSocket 服务端

选择 Node.js 配合 ws 库是最常见的方案，轻量且易于上手。

安装依赖：

npm install ws express

创建服务端代码（server.js）：

v1.1.6若依管理系统

一直想做一款后台管理系统，看了很多优秀的开源项目但是发现没有合适自己的。于是利用空闲休息时间开始自己写一套后台系统。如此有了若依管理系统。她可以用于所有的Web应用程序，如网站管理后台，网站会员中心，CMS，CRM，OA。所有前端后台代码封装过后十分精简易上手，出错效率低。同时支持移动客户端访问。系统会陆续更新一些实用功能。您是否在找一套合适后台管理系统。您是否在找一套代码易读易懂后台

885

查看详情

const express = require('express'); const { WebSocketServer } = require('ws'); const app = express(); app.use(express.static('public')); // 存放前端页面 const server = app.listen(3000, () => { console.log('服务已启动，端口 3000'); }); const wss = new WebSocketServer({ server }); // 存储所有活跃连接 const clients = new Set(); wss.on('connection', (ws) => { clients.add(ws); console.log('新用户连接'); ws.on('message', (data) => { const message = data.toString(); // 广播给所有其他客户端 clients.forEach((client) => { if (client !== ws && client.readyState === WebSocket.OPEN) { client.send(message); } }); }); ws.on('close', () => { clients.delete(ws); console.log('用户断开连接'); }); });

2. 编写前端页面和客户端逻辑

在 public 目录下创建 index.html，包含输入框和消息显示区域。

<!DOCTYPE html> <html> <head> <title>实时聊天</title> </head> <body> <div id="messages"></div> <input type="text" id="messageInput" placeholder="输入消息..." /> <button onclick="sendMessage()">发送</button> <script> const socket = new WebSocket('ws://localhost:3000'); socket.onopen = () => { console.log('已连接到服务器'); }; socket.onmessage = (event) => { const messagesDiv = document.getElementById('messages'); const msg = document.createElement('div'); msg.textContent = event.data; messagesDiv.appendChild(msg); }; function sendMessage() { const input = document.getElementById('messageInput'); if (input.value) { socket.send(input.value); input.value = ''; } } // 支持回车发送 document.getElementById('messageInput').addEventListener('keypress', (e) => { if (e.key === 'Enter') sendMessage(); }); </script> </body> </html>

3. 增强功能建议

基础版本完成后，可逐步加入以下实用功能：

用户标识：首次连接时发送用户名，服务器记录并附带在每条消息前。
消息类型区分：使用 JSON 格式传递数据，如 {type: 'message', user: 'Alice', text: '你好'}，便于处理系统通知、表情等。
房间支持：通过 URL 路径或参数区分不同聊天室，服务端按 room 分组管理 clients。
离线消息与持久化：结合数据库存储历史消息，新用户加入时拉取最近几条。
心跳机制：定期发送 ping/pong 防止连接因空闲被中断。