更新记录

1.0.0（2026-04-14）

新增功能

• TCP 客户端支持（基于 Kotlin NIO）
• UDP 通信支持（单播、广播、组播）
• 多实例管理
• 多种数据格式支持（String、Hex、Uint8Array）
• TCP 分包粘包处理
• 心跳机制
• 自动重连（指数退避算法）
• 完整的事件回调系统
• 并发控制和线程安全

平台兼容性

uni-app(4.41)

uni-app x(4.41)

Changbi Network 插件

功能完善的 TCP/UDP 网络通信 UTS 插件，支持安卓平台。

核心特性

基础连接管理

• 多实例支持：允许同时创建多个 TCP 或 UDP 实例
• 唯一 ID 区分：每个实例通过唯一 ID 管理

TCP 客户端功能

• connect(host, port, timeout) - 异步连接，支持超时配置
• disconnect() - 安全断开连接
• 自动重连机制（可配置）

UDP 通信功能

• bind(port) - 绑定本地端口
• send(data, host, port) - 单播发送
• setBroadcast(boolean) - 开启/关闭广播
• setMulticast(groupAddr) - 加入组播组

数据格式支持

• String（支持 UTF-8, GBK 等编码）
• Hex（十六进制字符串）
• Uint8Array / ArrayBuffer（零拷贝）

TCP 分包与粘包处理

• 定界符解析（\n, \r\n 等）
• 固定包头长度解析

心跳机制

• 自动发送心跳包
• 维持长连接活跃

事件回调

• onConnect - TCP 连接成功
• onMessage - 收到数据
• onClose - 连接关闭
• onError - 发生错误
• onSend - 数据发送确认

健壮性特性

• 自动重连（指数退避算法）
• 并发控制
• 线程安全

快速开始

import * as network from '@/uni_modules/changbi-network'

// 创建 TCP 客户端
const tcpId = network.createTcpClient({
  onConnect: () => {
    console.log('TCP 连接成功')
  },
  onMessage: (data) => {
    console.log('收到数据:', data)
  },
  onClose: () => {
    console.log('连接关闭')
  },
  onError: (error) => {
    console.error('错误:', error)
  }
})

// 连接服务器
await network.connect(tcpId, {
  host: '192.168.1.100',
  port: 8080,
  timeout: 5000,
  autoReconnect: true,
  reconnectInterval: 3000,
  maxReconnectAttempts: 5
})

// 发送数据
await network.send(tcpId, 'Hello Server', 'string')

// 断开连接
await network.disconnect(tcpId)

详细文档

• API 文档
• 使用指南
• 示例代码

技术实现

• 使用 Kotlin NIO (SocketChannel) 实现 TCP
• 使用 DatagramChannel 实现 UDP
• 协程处理异步操作
• 线程安全的实例管理

许可证

MIT License