Flutter for OpenHarmony:web_socket 纯 Dart 标准 WebSocket 客户端(跨平台兼容性之王) 深度解析与鸿蒙

Flutter for OpenHarmony:web_socket 纯 Dart 标准 WebSocket 客户端(跨平台兼容性之王) 深度解析与鸿蒙

欢迎加入开源鸿蒙跨平台社区:https://openharmonycrossplatform.ZEEKLOG.net

请添加图片描述

前言

虽然 dart:io 提供了 WebSocket 类,dart:html 也提供了 WebSocket 类,但这种“分裂”的 API 设计让编写跨平台(同时支持 Mobile/Web/Desktop)的代码变得异常痛苦。你需要使用条件导入 (if (dart.library.io) ...) 来分别处理。

web_socket 库就是为了解决这个问题而诞生的。它提供了一个统一的、平台无关的WebSocket 接口。
无论你的代码运行在 Android、iOS、Web 还是 OpenHarmony 上,它都会自动选择最底层的实现(在鸿蒙上通常是 dart:io),而从上层看代码完全一致。

对于 OpenHarmony 开发者,这意味着你可以直接复用现有 Flutter 项目中的 WebSocket 逻辑,无需为鸿蒙单独写条件编译分支。

一、核心原理

web_socket 本质上是一个 Facade(外观模式)。

调用

自动检测

Native/OpenHarmony

Web

你的业务代码

web_socket 统一接口

平台分发

dart:io WebSocket

HTML5 WebSocket API

二、OpenHarmony 适配说明

OpenHarmony 上,Dart 运行时完全支持 dart:io
因此,web_socket 库会透明地回退到基于 dart:io 的实现。

权限配置
同样,别忘了在 module.json5 中申请 ohos.permission.INTERNET

HTTPS/WSS 证书问题
鸿蒙系统对 SSL 证书校验较为严格。如果连接开发环境的自签名 WSS 服务,可能会抛出 HandshakeException。在开发阶段,你可能需要重写 SecurityContext 来信任所有证书(仅限 Debug 模式)。

三、基础用例

3.1 建立连接

import'package:web_socket/web_socket.dart';voidconnect()async{final uri =Uri.parse('wss://echo.websocket.org');// 💡 统一接口:会自动根据 Platform 选择最底层的端侧实现final socket =awaitWebSocket.connect(uri);print('✅ 握手成功');// 💡 监听消息:基于 Stream 的响应式处理 socket.events.listen((event){if(event isTextDataReceived){print('收到文本: ${event.text}');}elseif(event isBinaryDataReceived){print('收到二进制: ${event.data.length} 字节');}});}
在这里插入图片描述

3.2 发送数据

voidsendData(WebSocket socket){// 发送文本 socket.sendText('Hello OpenHarmony!');// 发送二进制 socket.sendBytes([0x01,0x02,0x03]);}
在这里插入图片描述

3.3 关闭连接

voidclose(WebSocket socket)async{await socket.close(1000,'Normal Closure');print('连接已关闭');}
在这里插入图片描述

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

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

import'package:web_socket/web_socket.dart';classOhosChatClient{WebSocket? _socket; bool _isConnected =false;/// 启动连接Future<void>init()async{try{ _socket =awaitWebSocket.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 isTextDataReceived){_handleText(event.text);}elseif(event isCloseReceived){ _isConnected =false;print('🔌 服务器断开连接');}});}void_handleText(String message){// 业务逻辑处理...}/// 资源回收voiddispose(){ _socket?.close();}}
在这里插入图片描述

五、总结

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

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

Read more

实战篇:Python开发monogod数据库mcp server看完你就会了

实战篇:Python开发monogod数据库mcp server看完你就会了

原创不易,请关注公众号:【爬虫与大模型开发】,大模型的应用开发之路,整理了大模型在现在的企业级应用的实操及大家需要注意的一些AI开发的知识点!持续输出爬虫与大模型的相关文章。 前言 目前mcp协议是给deepseek大模型插上工具链的翅膀,让大模型不仅拥有超高的推理和文本生成能力,还能具备执行大脑意识的工具能力! 如何开发一个mcp? mcp是一种协议,指的是模型上下文协议 (Model Context Protocol)。 官方结成的mcp https://github.com/modelcontextprotocol/python-sdk mcp库 pip install mcp from mcp.server.fastmcp import FastMCP 我们先来做一个简单的案例 from mcp.server.fastmcp import FastMCP import requests mcp = FastMCP("spider") @mcp.tool() def crawl(

By Ne0inhk
【大模型实战篇】基于Claude MCP协议的智能体落地示例

【大模型实战篇】基于Claude MCP协议的智能体落地示例

1. 背景         之前我们在《MCP(Model Context Protocol) 大模型智能体第一个开源标准协议》一文中,介绍了MCP的概念,虽然了解了其概念、架构、解决的问题,但还缺少具体的示例,来帮助进一步理解整套MCP框架如何落地。         今天我们基于claude的官方例子--获取天气预报【1】,来理解MCP落地的整条链路。 2. MCP示例         该案例是构建一个简单的MCP天气预报服务器,并将其连接到主机,即Claude for Desktop。从基本设置开始,然后逐步发展到更复杂的使用场景。         大模型虽然能力非常强,但其弊端就是内容是过时的,这里的过时不是说内容很旧,只是表达内容具有非实时性。比如没有获取天气预报和严重天气警报的能力。因此我们将使用MCP来解决这一问题。         构建一个服务器,该服务器提供两个工具:获取警报(get-alerts)和获取预报(get-forecast)。然后,将该服务器连接到MCP主机(在本例中为Claude for Desktop)。         首先我们配置下环

By Ne0inhk
AI Agent新范式:FastGPT+MCP协议实现工具增强型智能体构建

AI Agent新范式:FastGPT+MCP协议实现工具增强型智能体构建

AI Agent新范式:FastGPT+MCP协议实现工具增强型智能体构建 作者:高瑞冬 本文目录 * AI Agent新范式:FastGPT+MCP协议实现工具增强型智能体构建 * 一、MCP协议简介 * 二、创建MCP工具集 * 1. 获取MCP服务地址 * 2. 在FastGPT中创建MCP工具集 * 三、测试MCP工具 * 四、AI模型调用MCP工具 * 1. 调用单个工具 * 2. 调用整个工具集 * 五、私有化部署支持 * 1. 环境准备 * 2. 修改docker-compose.yml文件 * 3. 修改FastGPT配置 * 4. 重启服务 * 六、使用MCP-Proxy集成多个MCP服务 * 1. MCP-Proxy简介 * 2. 安装MCP-Proxy * 3. 配置MCP-Proxy * 4. 将MCP-Proxy与FastGPT集成 * 5. 高级配置

By Ne0inhk
基于腾讯云HAI + DeepSeek快速设计自己的个人网页

基于腾讯云HAI + DeepSeek快速设计自己的个人网页

前言:通过结合腾讯云HAI 强大的云端运算能力与DeepSeek先进的 AI技术,本文介绍高效、便捷且低成本的设计一个自己的个人网页。你将了解到如何轻松绕过常见的技术阻碍,在腾讯云HAI平台上快速部署DeepSeek模型,仅需简单几步,就能获取一个包含个人简介、技能特长、项目经历及联系方式等核心板块的响应式网页。 目录 一、DeepSeek模型部署在腾讯云HAI 二、设计个人网页 一、DeepSeek模型部署在腾讯云HAI 把 DeepSeek 模型部署于腾讯云 HAI,用户便能避开官网访问限制,直接依托腾讯云 HAI 的超强算力运行 DeepSeek-R1 等模型。这一举措不仅降低了技术门槛,还缩短了部署时间,削减了成本。尤为关键的是,凭借 HAI 平台灵活且可扩展的特性,用户能够依据自身特定需求定制专属解决方案,进而更出色地适配特定业务场景,满足各类技术要求 。 点击访问腾讯云HAI控制台地址: 算力管理 - 高性能应用服务 - 控制台 腾讯云高性能应用服务HAI已支持DeepSeek-R1模型预装环境和CPU算力,只需简单的几步就能调用DeepSeek - R1

By Ne0inhk