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

Smodin AI Content Detector
Smodin AI Content Detector

多语种AI内容检测工具

下载

一个健壮的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攻击。对每个连接或每个用户设置消息发送频率限制。

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

相关专题

更多
js获取数组长度的方法
js获取数组长度的方法

在js中,可以利用array对象的length属性来获取数组长度,该属性可设置或返回数组中元素的数目,只需要使用“array.length”语句即可返回表示数组对象的元素个数的数值,也就是长度值。php中文网还提供JavaScript数组的相关下载、相关课程等内容,供大家免费下载使用。

536

2023.06.20

js刷新当前页面
js刷新当前页面

js刷新当前页面的方法:1、reload方法,该方法强迫浏览器刷新当前页面,语法为“location.reload([bForceGet]) ”;2、replace方法,该方法通过指定URL替换当前缓存在历史里(客户端)的项目,因此当使用replace方法之后,不能通过“前进”和“后退”来访问已经被替换的URL,语法为“location.replace(URL) ”。php中文网为大家带来了js刷新当前页面的相关知识、以及相关文章等内容

372

2023.07.04

js四舍五入
js四舍五入

js四舍五入的方法:1、tofixed方法,可把 Number 四舍五入为指定小数位数的数字;2、round() 方法,可把一个数字舍入为最接近的整数。php中文网为大家带来了js四舍五入的相关知识、以及相关文章等内容

706

2023.07.04

js删除节点的方法
js删除节点的方法

js删除节点的方法有:1、removeChild()方法,用于从父节点中移除指定的子节点,它需要两个参数,第一个参数是要删除的子节点,第二个参数是父节点;2、parentNode.removeChild()方法,可以直接通过父节点调用来删除子节点;3、remove()方法,可以直接删除节点,而无需指定父节点;4、innerHTML属性,用于删除节点的内容。

470

2023.09.01

JavaScript转义字符
JavaScript转义字符

JavaScript中的转义字符是反斜杠和引号,可以在字符串中表示特殊字符或改变字符的含义。本专题为大家提供转义字符相关的文章、下载、课程内容,供大家免费下载体验。

388

2023.09.04

js生成随机数的方法
js生成随机数的方法

js生成随机数的方法有:1、使用random函数生成0-1之间的随机数;2、使用random函数和特定范围来生成随机整数;3、使用random函数和round函数生成0-99之间的随机整数;4、使用random函数和其他函数生成更复杂的随机数;5、使用random函数和其他函数生成范围内的随机小数;6、使用random函数和其他函数生成范围内的随机整数或小数。

989

2023.09.04

如何启用JavaScript
如何启用JavaScript

JavaScript启用方法有内联脚本、内部脚本、外部脚本和异步加载。详细介绍:1、内联脚本是将JavaScript代码直接嵌入到HTML标签中;2、内部脚本是将JavaScript代码放置在HTML文件的`<script>`标签中;3、外部脚本是将JavaScript代码放置在一个独立的文件;4、外部脚本是将JavaScript代码放置在一个独立的文件。

652

2023.09.12

Js中Symbol类详解
Js中Symbol类详解

javascript中的Symbol数据类型是一种基本数据类型,用于表示独一无二的值。Symbol的特点:1、独一无二,每个Symbol值都是唯一的,不会与其他任何值相等;2、不可变性,Symbol值一旦创建,就不能修改或者重新赋值;3、隐藏性,Symbol值不会被隐式转换为其他类型;4、无法枚举,Symbol值作为对象的属性名时,默认是不可枚举的。

535

2023.09.20

苹果官网入口直接访问
苹果官网入口直接访问

苹果官网直接访问入口是https://www.apple.com/cn/,该页面具备0.8秒首屏渲染、HTTP/3与Brotli加速、WebP+AVIF双格式图片、免登录浏览全参数等特性。本专题为大家提供相关的文章、下载、课程内容,供大家免费下载体验。

7

2025.12.24

热门下载

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

精品课程

更多
相关推荐
/
热门推荐
/
最新课程
Django 教程
Django 教程

共28课时 | 2.4万人学习

Go语言实战之 GraphQL
Go语言实战之 GraphQL

共10课时 | 0.8万人学习

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

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