👋 你好，欢迎来到我的博客！我是【菜鸟不学编程】
   我是一个正在奋斗中的职场码农，步入职场多年，正在从“小码农”慢慢成长为有深度、有思考的技术人。在这条不断进阶的路上，我决定记录下自己的学习与成长过程，也希望通过博客结识更多志同道合的朋友。
  
  🛠️ 主要方向包括 Java 基础、Spring 全家桶、数据库优化、项目实战等，也会分享一些踩坑经历与面试复盘，希望能为还在迷茫中的你提供一些参考。
  💡 我相信：写作是一种思考的过程，分享是一种进步的方式。
  
   如果你和我一样热爱技术、热爱成长，欢迎关注我，一起交流进步！

前言

在现代应用中，实时通信（RTC）已经成为了很多场景下的核心需求。例如，在线聊天系统、股票行情订阅、实时通知等应用都依赖于实时数据的推送。WebSocket 是一种在客户端和服务器之间建立持久化连接的协议，适合于这种实时通信需求。与传统的 HTTP 请求不同，WebSocket 协议在建立连接后，客户端和服务器之间能够进行双向、持久化的通信，这使得它非常适用于实时数据流传输。

本文将深入探讨如何在 鸿蒙系统 中使用 WebSocket 协议实现实时通信系统，具体涵盖 WebSocket 客户端实现方式（ArkTS）、连接管理、心跳机制、重连策略、二进制与文本数据传输的选择，并通过一个实例来演示如何实现一个聊天系统或股票行情订阅功能，最后还将对比 WebSocket 与传统 HTTP 轮询的优缺点。

1. WebSocket 客户端实现方式（ArkTS）

ArkTS 简介

ArkTS（Ark TypeScript）是鸿蒙系统中提供的类型化 JavaScript 语言，类似于 TypeScript，专门为鸿蒙系统的开发进行优化。它不仅支持类型检查和现代 JavaScript 特性，还能够与鸿蒙特有的组件和 API 进行无缝集成。

WebSocket 客户端在 ArkTS 中的实现非常简洁，鸿蒙操作系统本身也为开发者提供了强大的 WebSocket 支持。

ArkTS 中 WebSocket 客户端实现

鸿蒙系统中的 WebSocket 客户端实现基于 WebSocket API，可以使用 ArkTS 来轻松实现 WebSocket 的连接、消息收发等操作。

示例：WebSocket 客户端实现

import { WebSocket } from '@ohos.websocket';

class WebSocketClient {
    private ws: WebSocket | null = null;

    // 连接服务器
    public connect(url: string): void {
        this.ws = new WebSocket(url);
        
        // 监听连接打开事件
        this.ws.onopen = () => {
            console.log("WebSocket connected!");
            this.sendMessage("Hello, server!");
        };

        // 监听消息接收事件
        this.ws.onmessage = (event: MessageEvent) => {
            console.log("Received message:", event.data);
        };

        // 监听错误事件
        this.ws.onerror = (event: Event) => {
            console.error("WebSocket error:", event);
        };

        // 监听连接关闭事件
        this.ws.onclose = (event: CloseEvent) => {
            console.log("WebSocket connection closed:", event.code);
        };
    }

    // 发送消息
    public sendMessage(message: string): void {
        if (this.ws && this.ws.readyState === WebSocket.OPEN) {
            this.ws.send(message);
            console.log("Sent message:", message);
        } else {
            console.error("WebSocket is not connected.");
        }
    }

    // 关闭连接
    public close(): void {
        if (this.ws) {
            this.ws.close();
        }
    }
}

在这个示例中，我们定义了一个 WebSocketClient 类，它能够连接到指定的 WebSocket 服务器，并支持发送和接收消息。通过监听 onopen、onmessage、onerror 和 onclose 事件，可以处理 WebSocket 的生命周期。

2. 连接管理、心跳机制、重连策略

连接管理

在实际的 WebSocket 使用场景中，保持连接的稳定性至关重要。为了实现稳定可靠的通信，需要处理 WebSocket 连接的管理，包括连接建立、断开、重连等操作。

心跳机制

为了避免 WebSocket 连接超时和掉线，通常需要实现 心跳机制。心跳机制通过定期向服务器发送空的消息或 ping 请求，保持连接的活跃状态，防止服务器主动断开连接。

示例：心跳机制

class WebSocketClientWithHeartbeat extends WebSocketClient {
    private heartbeatInterval: any = null;

    // 启动心跳机制
    public startHeartbeat(): void {
        this.heartbeatInterval = setInterval(() => {
            if (this.ws && this.ws.readyState === WebSocket.OPEN) {
                this.ws.send("ping");
                console.log("Sent heartbeat (ping)");
            }
        }, 30000); // 每30秒发送一次心跳
    }

    // 停止心跳机制
    public stopHeartbeat(): void {
        if (this.heartbeatInterval) {
            clearInterval(this.heartbeatInterval);
            console.log("Heartbeat stopped");
        }
    }
}

在上面的代码中，startHeartbeat 方法每 30 秒向服务器发送一次 ping 消息，stopHeartbeat 方法停止心跳机制。

重连策略

在网络不稳定或者 WebSocket 连接被意外关闭时，自动重连是确保服务可靠性的关键。重连策略通常包括：尝试重新连接、增加重连间隔、最大重连次数等。

示例：重连策略

class WebSocketClientWithReconnect extends WebSocketClient {
    private reconnectAttempts: number = 0;
    private maxReconnectAttempts: number = 5;
    private reconnectInterval: number = 2000; // 重连间隔2秒

    // 重新连接
    public reconnect(): void {
        if (this.reconnectAttempts < this.maxReconnectAttempts) {
            setTimeout(() => {
                console.log("Reconnecting...");
                this.connect("ws://example.com");
                this.reconnectAttempts++;
            }, this.reconnectInterval);
        } else {
            console.log("Max reconnect attempts reached.");
        }
    }

    // 监听 WebSocket 关闭事件，并尝试重连
    public onClose(event: CloseEvent): void {
        console.log("WebSocket connection closed:", event.code);
        this.reconnect();
    }
}

在这个示例中，当 WebSocket 连接关闭时，onClose 方法会触发，并尝试重新连接。最大重连次数和重连间隔可以根据需求进行调整。

3. 二进制 vs 文本数据传输场景分析

WebSocket 支持两种数据传输方式：二进制 和 文本。选择哪种传输方式取决于应用场景。

文本数据传输

文本数据通常以字符串的形式进行传输，适用于消息内容较简单，传输的是 JSON 或 XML 等格式的数据。

• 优点：易于调试和阅读，适用于轻量级的数据传输。
• 缺点：当数据量较大时，性能会有所下降，尤其是在高频率的消息传输中。

二进制数据传输

二进制数据适合传输较大、复杂的数据，例如文件上传、视频流、图片数据等。WebSocket 通过 Blob 或 ArrayBuffer 来支持二进制数据传输。

• 优点：高效、节省带宽，适合传输大数据量的文件、音视频流等。
• 缺点：不如文本数据易于调试和阅读。

示例：二进制数据传输

// 发送二进制数据
const sendBinaryData = (data: ArrayBuffer) => {
    if (this.ws && this.ws.readyState === WebSocket.OPEN) {
        this.ws.send(data);
    }
};

// 接收二进制数据
this.ws.onmessage = (event: MessageEvent) => {
    if (event.data instanceof ArrayBuffer) {
        console.log("Received binary data:", event.data);
    }
};

在这个示例中，ArrayBuffer 被用于发送和接收二进制数据。可以用于发送文件、图片、音视频流等数据。

4. 实例：聊天系统或股票行情订阅实现

聊天系统

使用 WebSocket 可以非常高效地实现实时聊天功能。通过 WebSocket，聊天系统可以保持持久连接，实时接收消息。

示例：聊天系统

class ChatSystem extends WebSocketClient {
    private userId: string;

    constructor(userId: string) {
        super();
        this.userId = userId;
    }

    public sendMessage(message: string): void {
        const msg = JSON.stringify({
            userId: this.userId,
            message: message,
        });
        this.sendMessage(msg);
    }

    public receiveMessage(event: MessageEvent): void {
        const message = JSON.parse(event.data);
        console.log(`${message.userId}: ${message.message}`);
    }
}

在这个示例中，sendMessage 方法通过 WebSocket 发送聊天信息，receiveMessage 方法处理接收到的消息并显示。

股票行情订阅

在股票行情系统中，使用 WebSocket 可以实现实时推送股票数据，客户端通过 WebSocket 订阅实时数据，服务器推送最新的行情信息。

示例：股票行情订阅

class StockTicker extends WebSocketClient {
    public subscribeToStock(stockSymbol: string): void {
        const message = JSON.stringify({
            action: "subscribe",
            symbol: stockSymbol,
        });
        this.sendMessage(message);
    }

    public receiveStockData(event: MessageEvent): void {
        const stockData = JSON.parse(event.data);
        console.log(`Stock: ${stockData.symbol}, Price: ${stockData.price}`);
    }
}

在这个例子中，subscribeToStock 方法订阅某个股票的实时数据，receiveStockData 方法接收并处理行情数据。

5. 与传统 HTTP 轮询对比

WebSocket 与传统的 HTTP 轮询 方法相比，具有明显的优势。

HTTP 轮询

在 HTTP 轮询中，客户端定期发送 HTTP 请求来查询数据。这种方法存在以下缺点：

1. 频繁的请求：即使没有新的数据，客户端也会不断发送请求，浪费带宽。
2. 延迟较高：由于请求和响应之间的间隔，实时性较差。
3. 服务器负担重：每个客户端都需要发送请求，增加了服务器的压力。

WebSocket 优势

1. 持久连接：WebSocket 建立一个持久的连接，客户端和服务器可以随时互相发送消息。
2. 实时性：数据能够即时推送到客户端，延迟低。
3. 带宽节省：只有在数据发生变化时，才会发送数据，不会像 HTTP 轮询那样浪费带宽。

总结

通过使用 WebSocket 协议，鸿蒙系统能够实现高效、低延迟的实时通信。本文通过分析 WebSocket 客户端的实现方式、连接管理、心跳机制、重连策略等，展示了如何使用 WebSocket 构建实时通信系统。通过对比二进制与文本数据的传输场景，以及 WebSocket 与传统 HTTP 轮询的优缺点，开发者能够根据具体需求选择合适的解决方案。在实际应用中，结合这些技术实现实时聊天系统、股票行情订阅等功能，可以大大提升用户体验和系统性能。

📝 写在最后

如果你觉得这篇文章对你有帮助，或者有任何想法、建议，欢迎在评论区留言交流！你的每一个点赞 👍、收藏 ⭐、关注 ❤️，都是我持续更新的最大动力！

我是一个在代码世界里不断摸索的小码农，愿我们都能在成长的路上越走越远，越学越强！

感谢你的阅读，我们下篇文章再见～👋

✍️ 作者：某个被流“治愈”过的 Java 老兵
📅 日期：2025-07-25
🧵 本文原创，转载请注明出处。