0

0

HTML5WebSocket怎么建立_WebSocket实时通信实现教程

看不見的法師

看不見的法師

发布时间:2025-09-22 21:57:01

|

774人浏览过

|

来源于php中文网

原创

答案:WebSocket通过HTTP握手升级为持久双向TCP连接,实现全双工通信。客户端用JavaScript API建立连接,服务器端如Node.js配合ws库处理连接、消息广播与事件响应。相比HTTP轮询和长轮询的频繁请求与高延迟,WebSocket支持实时“推”模式,显著提升效率。实际应用中需实现断线重连(如指数退避)和心跳机制(ping/pong检测)保障连接稳定。数据格式常用JSON,高性能场景可用Protobuf等二进制格式。安全方面须使用WSS加密、源站验证、输入净化、身份认证(如JWT)、授权及速率限制,确保通信可靠与系统安全。

html5websocket怎么建立_websocket实时通信实现教程

建立HTML5 WebSocket连接,核心在于客户端发起一个特殊的HTTP请求,通过“握手”过程,将HTTP协议升级为一个持久的、双向的TCP连接。一旦升级成功,客户端和服务器就能在任意时间点互相发送数据,实现真正的实时通信,而不再受HTTP请求-响应模式的限制。

解决方案

要实现WebSocket实时通信,我们需要客户端和服务器两端的配合。

客户端通常使用JavaScript的

WebSocket
API。创建一个
WebSocket
实例,指向你的服务器地址,连接就此尝试建立。

// 假设你的WebSocket服务器运行在 localhost:8080
const ws = new WebSocket('ws://localhost:8080');

ws.onopen = (event) => {
    console.log('WebSocket 连接已建立!', event);
    ws.send('Hello from client!'); // 连接建立后可以发送数据
};

ws.onmessage = (event) => {
    console.log('收到服务器消息:', event.data);
};

ws.onerror = (event) => {
    console.error('WebSocket 错误:', event);
};

ws.onclose = (event) => {
    console.log('WebSocket 连接已关闭:', event.code, event.reason);
    // 可以在这里尝试重连
};

// 客户端主动关闭连接
// ws.close();

服务器端则需要一个支持WebSocket协议的库或框架。以Node.js为例,使用

ws
库非常常见且高效:

立即学习前端免费学习笔记(深入)”;

// server.js
const WebSocket = require('ws');

const wss = new WebSocket.Server({ port: 8080 });

wss.on('connection', (ws) => {
    console.log('有新的客户端连接了!');

    ws.on('message', (message) => {
        console.log(`收到客户端消息: ${message}`);
        // 将收到的消息广播给所有连接的客户端
        wss.clients.forEach((client) => {
            if (client !== ws && client.readyState === WebSocket.OPEN) {
                client.send(`有人说: ${message}`);
            }
        });
        // 或者直接回复给发送者
        ws.send(`服务器已收到你的消息: ${message}`);
    });

    ws.on('close', () => {
        console.log('客户端已断开连接。');
    });

    ws.on('error', (error) => {
        console.error('WebSocket 错误:', error);
    });

    ws.send('Hello from server!'); // 连接建立后服务器也可以主动发送数据
});

console.log('WebSocket 服务器已启动,监听端口 8080。');

运行这个

server.js
文件(
node server.js
),然后打开浏览器控制台运行客户端代码,你就能看到客户端和服务器之间的双向通信了。这套流程,在我看来,比传统HTTP请求来回拉扯的效率高了不止一点半点,尤其是在需要低延迟交互的场景。

WebSocket与传统HTTP轮询/长轮询有何本质区别?

在我刚开始接触实时通信时,也曾纠结过HTTP轮询、长轮询和WebSocket到底该选哪个。说白了,它们之间最大的区别在于“连接”和“效率”。传统的HTTP轮询,就是客户端傻傻地每隔一段时间(比如1秒)就去问服务器“有新消息吗?”服务器有就给,没有就说“没有”。这种方式的缺点很明显:大量的无效请求、高延迟,而且服务器资源消耗也大,因为每次请求都要经历完整的HTTP握手和关闭过程。

长轮询稍微聪明一些,客户端发请求后,服务器如果没新消息,就先“hold”住这个请求,直到有新消息或者达到超时时间才响应。这样能减少无效请求,但一旦响应了,连接就断了,客户端还得立即发起下一个请求。它仍然是单向的、基于请求-响应模式的,而且服务器端维护这些挂起的请求也需要额外的开销。

WebSocket则完全不同。它通过一个初始的HTTP握手后,将连接升级为一种持久的、全双工的TCP连接。这意味着一旦连接建立,客户端和服务器可以随时随地互相发送数据,就像打电话一样,双方都可以主动说话,而不需要一方先问。这种“推”的机制,彻底消除了轮询带来的延迟和冗余请求,显著提升了实时性,也降低了网络和服务器的负担。在我看来,这才是WebSocket真正迷人的地方,它把通信从“问答”模式升级到了“对话”模式。

如何在实际项目中优雅地处理WebSocket的连接管理与心跳机制?

实际项目里,WebSocket连接可不是建立起来就万事大吉了。网络波动、服务器重启、客户端休眠等等,都可能导致连接意外中断。处理这些情况,连接管理和心跳机制就显得尤为重要,这块儿我踩过不少坑。

In3D
In3D

把真人变成化身,创建逼真且可自定义的虚拟角色

下载

一个健壮的WebSocket客户端,首先得有断线重连的机制。当

onclose
事件触发时,不应该直接放弃,而是应该在一定延迟后尝试重新建立连接,并且最好采用指数退避(exponential backoff)策略,比如第一次等1秒,第二次等2秒,第三次等4秒,避免短时间内大量重连请求冲击服务器。同时,要设置一个最大重连次数或总时长,防止无限重连。

// 客户端重连示例伪代码
let reconnectAttempts = 0;
const maxReconnectAttempts = 10;
const reconnectInterval = 1000; // 初始重连间隔1秒

function connectWebSocket() {
    const ws = new WebSocket('ws://localhost:8080');

    ws.onopen = () => {
        console.log('WebSocket 连接已建立!');
        reconnectAttempts = 0; // 成功连接后重置尝试次数
    };

    ws.onclose = () => {
        console.log('WebSocket 连接已关闭,尝试重连...');
        if (reconnectAttempts < maxReconnectAttempts) {
            reconnectAttempts++;
            const delay = reconnectInterval * Math.pow(2, reconnectAttempts - 1); // 指数退避
            setTimeout(connectWebSocket, Math.min(delay, 30000)); // 最大延迟30秒
        } else {
            console.error('达到最大重连次数,放弃重连。');
        }
    };
    // ... 其他事件处理
    return ws;
}

let currentWs = connectWebSocket();

心跳机制则是为了检测连接是否真正“活”着。TCP连接虽然是持久的,但如果长时间没有数据传输,中间的网络设备可能会因为空闲而断开连接,而客户端和服务器可能并不知道。心跳机制就是定时发送小数据包(比如

ping
帧),服务器收到后回复
pong
帧。如果在一定时间内没有收到
pong
回复,就认为连接已死,主动断开并触发重连。

客户端可以设置一个定时器,每隔一段时间发送

ping

let heartbeatInterval;
const pingInterval = 30000; // 每30秒发送一次ping

ws.onopen = () => {
    // ...
    heartbeatInterval = setInterval(() => {
        if (ws.readyState === WebSocket.OPEN) {
            ws.send(JSON.stringify({ type: 'ping' })); // 发送一个自定义的ping消息
            // 也可以使用WebSocket API原生的ping帧,但通常需要服务器端配合处理
        }
    }, pingInterval);
};

ws.onclose = () => {
    clearInterval(heartbeatInterval); // 关闭连接时清除心跳
    // ... 尝试重连
};

// 客户端收到服务器的pong回复时,可以重置一个timeout,确保连接活跃
let serverTimeout;
const serverTimeoutDuration = pingInterval * 2; // 比如ping间隔的两倍
ws.onmessage = (event) => {
    const data = JSON.parse(event.data);
    if (data.type === 'pong') {
        clearTimeout(serverTimeout);
        serverTimeout = setTimeout(() => {
            console.warn('长时间未收到服务器心跳,连接可能已断开。');
            ws.close(); // 主动关闭,触发重连
        }, serverTimeoutDuration);
    }
    // ... 处理其他消息
};

服务器端也应该有类似的心跳处理逻辑,定时向客户端发送

ping
,并监听客户端的
pong
回复,如果客户端长时间无响应,则断开连接。这套机制能够有效提升通信的稳定性和可靠性。

WebSocket通信中常见的数据格式与安全性考量有哪些?

数据格式和安全性,这是任何网络通信都绕不开的话题,WebSocket也不例外。

在数据格式方面,最常见也最方便的当然是JSON。JavaScript原生支持,前后端解析起来都非常简单。我们通常会约定一个数据结构,比如包含

type
字段表示消息类型,
payload
字段承载具体数据:

// 客户端发送消息
{
    "type": "chatMessage",
    "payload": {
        "sender": "Alice",
        "message": "Hello, everyone!"
    }
}

// 服务器发送通知
{
    "type": "userJoined",
    "payload": {
        "username": "Bob",
        "timestamp": 1678886400
    }
}

除了JSON,对于追求极致性能和带宽优化的场景,Protocol Buffers (Protobuf)MessagePack或者FlatBuffers也是不错的选择。它们能将数据序列化成更紧凑的二进制格式,减少传输量,提高解析速度。当然,这会增加前后端的开发复杂度,需要引入额外的库来处理序列化和反序列化。我个人觉得,对于大多数Web应用,JSON的便利性往往优于二进制格式带来的微小性能提升。

至于安全性,这是个大问题,绝对不能掉以轻心。

  1. 使用WSS (WebSocket Secure):这是最基本也是最重要的。
    ws://
    是明文传输,容易被窃听和篡改。务必使用
    wss://
    ,它基于TLS/SSL,提供了加密和身份验证,就像HTTPS一样。这意味着你的WebSocket服务器需要配置有效的SSL证书。
  2. 源站验证 (Origin Check):服务器端应该验证连接请求的
    Origin
    头部。只允许来自你信任的域名发起WebSocket连接。这能有效防止跨站WebSocket劫持(CSRF for WebSockets)。例如,在Node.js
    ws
    库中,你可以在
    verifyClient
    选项中进行判断:
    const wss = new WebSocket.Server({
        port: 8080,
        verifyClient: function(info, done) {
            const allowedOrigins = ['https://your-domain.com', 'https://another-trusted-domain.com'];
            if (allowedOrigins.includes(info.origin)) {
                done(true); // 允许连接
            } else {
                console.warn(`阻止来自未知源的连接: ${info.origin}`);
                done(false, 401, 'Unauthorized'); // 拒绝连接
            }
        }
    });
  3. 输入验证和净化:任何从客户端接收到的数据,都必须在服务器端进行严格的验证和净化,防止注入攻击(如XSS、SQL注入,如果消息内容存储到数据库)。永远不要相信来自客户端的任何数据。
  4. 身份验证与授权:WebSocket连接建立后,服务器需要知道是谁连接上来了,以及他们是否有权限执行某些操作。这通常通过在WebSocket握手时传递认证令牌(如JWT)来实现。客户端可以在连接URL中附带token(
    ws://localhost:8080?token=your_jwt_token
    ),或者在握手阶段通过自定义头部传递。服务器收到token后进行验证,并为该连接关联一个用户身份。之后的所有消息发送,都应根据这个身份进行授权检查。
  5. 速率限制:防止客户端发送过多的消息,造成服务器过载或DDoS攻击。对每个连接或每个用户设置消息发送频率限制。

这些安全措施,有些是基础设施层面的,有些是应用逻辑层面的,但都缺一不可。忽视它们,就像在家里装了扇不带锁的门,迟早会出问题。

热门AI工具

更多
DeepSeek
DeepSeek

幻方量化公司旗下的开源大模型平台

豆包大模型
豆包大模型

字节跳动自主研发的一系列大型语言模型

WorkBuddy
WorkBuddy

腾讯云推出的AI原生桌面智能体工作台

腾讯元宝
腾讯元宝

腾讯混元平台推出的AI助手

文心一言
文心一言

文心一言是百度开发的AI聊天机器人,通过对话可以生成各种形式的内容。

讯飞写作
讯飞写作

基于讯飞星火大模型的AI写作工具,可以快速生成新闻稿件、品宣文案、工作总结、心得体会等各种文文稿

即梦AI
即梦AI

一站式AI创作平台,免费AI图片和视频生成。

ChatGPT
ChatGPT

最最强大的AI聊天机器人程序,ChatGPT不单是聊天机器人,还能进行撰写邮件、视频脚本、文案、翻译、代码等任务。

相关专题

更多
数据分析工具有哪些
数据分析工具有哪些

数据分析工具有Excel、SQL、Python、R、Tableau、Power BI、SAS、SPSS和MATLAB等。详细介绍:1、Excel,具有强大的计算和数据处理功能;2、SQL,可以进行数据查询、过滤、排序、聚合等操作;3、Python,拥有丰富的数据分析库;4、R,拥有丰富的统计分析库和图形库;5、Tableau,提供了直观易用的用户界面等等。

1135

2023.10.12

SQL中distinct的用法
SQL中distinct的用法

SQL中distinct的语法是“SELECT DISTINCT column1, column2,...,FROM table_name;”。本专题为大家提供相关的文章、下载、课程内容,供大家免费下载体验。

340

2023.10.27

SQL中months_between使用方法
SQL中months_between使用方法

在SQL中,MONTHS_BETWEEN 是一个常见的函数,用于计算两个日期之间的月份差。想了解更多SQL的相关内容,可以阅读本专题下面的文章。

381

2024.02.23

SQL出现5120错误解决方法
SQL出现5120错误解决方法

SQL Server错误5120是由于没有足够的权限来访问或操作指定的数据库或文件引起的。想了解更多sql错误的相关内容,可以阅读本专题下面的文章。

2235

2024.03.06

sql procedure语法错误解决方法
sql procedure语法错误解决方法

sql procedure语法错误解决办法:1、仔细检查错误消息;2、检查语法规则;3、检查括号和引号;4、检查变量和参数;5、检查关键字和函数;6、逐步调试;7、参考文档和示例。想了解更多语法错误的相关内容,可以阅读本专题下面的文章。

380

2024.03.06

oracle数据库运行sql方法
oracle数据库运行sql方法

运行sql步骤包括:打开sql plus工具并连接到数据库。在提示符下输入sql语句。按enter键运行该语句。查看结果,错误消息或退出sql plus。想了解更多oracle数据库的相关内容,可以阅读本专题下面的文章。

1723

2024.04.07

sql中where的含义
sql中where的含义

sql中where子句用于从表中过滤数据,它基于指定条件选择特定的行。想了解更多where的相关内容,可以阅读本专题下面的文章。

586

2024.04.29

sql中删除表的语句是什么
sql中删除表的语句是什么

sql中用于删除表的语句是drop table。语法为drop table table_name;该语句将永久删除指定表的表和数据。想了解更多sql的相关内容,可以阅读本专题下面的文章。

441

2024.04.29

TypeScript类型系统进阶与大型前端项目实践
TypeScript类型系统进阶与大型前端项目实践

本专题围绕 TypeScript 在大型前端项目中的应用展开,深入讲解类型系统设计与工程化开发方法。内容包括泛型与高级类型、类型推断机制、声明文件编写、模块化结构设计以及代码规范管理。通过真实项目案例分析,帮助开发者构建类型安全、结构清晰、易维护的前端工程体系,提高团队协作效率与代码质量。

69

2026.03.13

热门下载

更多
网站特效
/
网站源码
/
网站素材
/
前端模板

精品课程

更多
相关推荐
/
热门推荐
/
最新课程
极客学院HTML5新特性基础视频教程
极客学院HTML5新特性基础视频教程

共18课时 | 3.6万人学习

HTML5新特性基础视频教程
HTML5新特性基础视频教程

共18课时 | 3.3万人学习

一天学会DIV+CSS布局(五大实战)
一天学会DIV+CSS布局(五大实战)

共9课时 | 1.3万人学习

关于我们 免责申明 举报中心 意见反馈 讲师合作 广告合作 最新更新
php中文网:公益在线php培训,帮助PHP学习者快速成长!
关注服务号 技术交流群
PHP中文网订阅号
每天精选资源文章推送

Copyright 2014-2026 https://www.php.cn/ All Rights Reserved | php.cn | 湘ICP备2023035733号