往期推文全新看点（文中附带全新鸿蒙5.0全栈学习笔录）

✏️ 鸿蒙应用开发与鸿蒙系统开发哪个更有前景？

✏️ 嵌入式开发适不适合做鸿蒙南向开发？看完这篇你就了解了~

✏️ 对于大前端开发来说，转鸿蒙开发究竟是福还是祸？

✏️ 鸿蒙岗位需求突增！移动端、PC端、IoT到底该怎么选？

✏️ 市场巨变，移动开发行业即将迎来“第二春”?

✏️ 记录一场鸿蒙开发岗位面试经历~

✏️ 持续更新中……

---

简介

socket.io是一个在客户端和服务器之间实现低延迟、双向和基于事件的通信的库。建立在 WebSocket 协议之上，并提供额外的保证，例如回退到 HTTP 长轮询或自动重新连接。

效果展示

下载安装

ohpm install @ohos/socketio 

使用说明

1. 导入依赖库

import { client_socket } from '@ohos/socketio';

2. 初始化socket.io客户端

client: client_socket = new client_socket();

3. 设置监听事件

this.client.set_open_listener(this.on_open.bind(this));
this.client.set_fail_listener(this.on_fail.bind(this));
this.client.set_reconnecting_listener(this.on_reconnecting.bind(this));
this.client.set_reconnect_listener(this.on_reconnect.bind(this));
this.client.set_close_listener(this.on_close.bind(this));
this.client.set_socket_open_listener(this.on_socket_open.bind(this));
this.client.set_socket_close_listener(this.on_socket_close.bind(this));

4. 连接服务器

this.client.connect(uri) //uri: socket.io服务端地址

5. 设置用户消息监听以及用户加入离开监听

• 监听事件实现

on_user_left_listener(event_json: string): void {
	//回调数据处理
}

• 设置监听

this.client.on("new message", this.on_new_message_listener.bind(this));
this.client.on("user joined", this.on_user_joined_listener.bind(this));
this.client.on("user left", this.on_user_left_listener.bind(this));
this.client.on("login", this.on_login_listener.bind(this));

6. 登录服务器，并设置登录成功回调

this.client.emit("add user", username, this.on_emit_callback.bind(this));

7. 发送消息并设置发送消息监听

this.client.emit("new message", message, this.on_emit_callback);

8. 关闭服务器链接并清理监听事件

this.client.socket_close();
this.client.clear_socket_listeners();

接口说明

• 初始化客户端

client: client_socket = new client_socket();

• 设置客户端监听器

set_open_listener(on_open: () => void)

• 设置客户端失败监听器

set_fail_listener(on_fail: () => void)

• 设置客户端正在重新连接监听器

set_reconnecting_listener(on_reconnecting: () => void)

• 设置客户端重新连接监听器

set_reconnect_listener(on_reconnect: () => void)

• 设置客户端关闭监听器

set_close_listener(on_close: (reason: string) => void)

• 设置socket打开监听

set_socket_open_listener(on_socket_open: (nsp: string) => void)

• 设置socket关闭监听

set_socket_close_listener(on_socket_close: (nsp: string) => void)

• 设置 header

set_headers(headers: string)

• 连接服务器

connect(uri: string)

• 清除所有监听器

clear_con_listeners()

• 清除所有socket监听器

clear_socket_listeners()

• 设置重连次数

set_reconnect_attempts(attempts: number)

• 设置重新连接尝试的延迟时间

set_reconnect_delay(millis: number)

• 设置重新连接的最大延迟。

set_reconnect_delay_max(millis: number)

• 关闭连接

close()

• 同步关闭

sync_close()

• 判断是否打开

opened(): boolean

• 获取sessionID

get_sessionid(): string

• 注册一个新的响应服务器事件的事件处理器

on(event_name: string, on_event_listener: (event_json: string) => void)

• 设置socket监听关闭

socket_close()

• 设置错误监听

on_error(on_error_listener: (message: string) => void)

• 关闭错误监听

off_error()

• 通过提供的name事件名称向socket标志发送事件
  说明: 响应服务器用来确认消息的应答

emit(name: string, message: string, on_emit_callback?: (emit_callback_json: string) => void)

源码下载

1. 本项目依赖 socket.io-client-cpp 库，通过git submodule引入，下载代码时需加上--recursive参数。

git clone --recursive https://gitee.com/openharmony-tpc/openharmony_tpc_samples.git

2. Linux环境无需执行该步骤，如果是windows环境下，代码下载完成后合入OHOS适配的代码，cd 进入到socketio/library/src/main/cpp/thirdModule 目录下，执行 modify.sh 脚本，将本目录下的 patch 文件合入到 socket.io-client-cpp 源码中。
3. 开始编译项目。

约束与限制

在下述版本验证通过：

• IDE：DevEco Studio 4.1.3.532; SDK: 4.1.0.67(SP3)。
• IDE：DevEco Studio Next ,Developer Beta1(5.0.3.121); SDK:API12 (5.0.0.16)。
• IDE：DevEco Studio NEXT Developer Beta2(5.0.3.500); SDK: API12 (5.0.0.31)。
• IDE：DevEco Studio NEXT Developer Beta1(5.0.3.810); SDK: API12 (5.0.0.68)。

目录结构

|---- socketio  
|     |---- entry  # 示例代码文件夹
|     |---- library  # socket.io库
|           |---- ets #对外接口目录
				  |---- client_socket.ets # 对外接口
            |---- cpp # 组件代码目录
                  |---- src # 核心类目录
                  |---- client_socket.cpp # socket.io客户端NAPI层
|     |---- README.md  # 安装使用方法