Dart 标准 web_socket 库跨平台 WebSocket 实现解析

void sendData(WebSocket socket) {
  // 发送文本
  socket.sendText('Hello OpenHarmony!');
  // 发送二进制
  socket.sendBytes([0x01, 0x02, 0x03]);
}

3.3 关闭连接

void close(WebSocket socket) async {
  await socket.close(1000, 'Normal Closure');
  print('连接已关闭');
}

四、完整实战示例：鸿蒙实时消息接收器

本示例演示了一个健壮的消息客户端，包含连接初始化、消息分类处理以及关闭资源释放生命周期。

import 'package:web_socket/web_socket.dart';

class OhosChatClient {
  WebSocket? _socket;
  bool _isConnected = false;

  /// 启动连接
  Future<void> init() async {
    try {
      _socket = await WebSocket.connect(
        Uri.parse('wss://api.ohos-chat.com/v1'),
        timeout: Duration(seconds: 10),
      );
      _isConnected = true;
      _listen();
    } catch (e) {
      print('❌ 连接失败：$e');
    }
  }

  void _listen() {
    _socket?.events.listen((event) {
      if (event is TextDataReceived) {
        _handleText(event.text);
      } else if (event is CloseReceived) {
        _isConnected = false;
        print('🔌 服务器断开连接');
      }
    });
  }

  void _handleText(String message) {
    // 业务逻辑处理...
  }

  /// 资源回收
  void dispose() {
    _socket?.close();
  }
}

五、总结

web_socket 是 Dart 官方为了抹平平台差异而推出的标准化库。 建议所有新开发的 Flutter 项目，如果不需要使用 Socket.io 或 STOMP 等上层协议，而是直接使用原始 WebSocket，首选使用 package:web_socket 而不是直接用 dart:io。

对于 OpenHarmony 开发，它保证了你的网络层代码是未来兼容的（Future-proof），无论未来鸿蒙底层的网络栈如何演进，标准接口层都将保持稳定。