HarmonyOS 鸿蒙Next中求助：使用TCP连接服务器报错 Operation in progress

开发者您好，
本地测试暂未复现，能否提供可以复现的demo、SDK、IDE版本，
code为0一般为正常的标志，但是error中暂时未复现该问题
测试SDK 6.1.0，测试代码：

import { socket } from '@kit.NetworkKit';
import { BusinessError } from '@kit.BasicServicesKit';
import { hilog } from '@kit.PerformanceAnalysisKit';

const TAG = 'TCP_CLIENT';
const DOMAIN = 0x0000;

class SocketInfo {
  public message: ArrayBuffer = new ArrayBuffer(1);
  public remoteInfo: socket.SocketRemoteInfo = {} as socket.SocketRemoteInfo;
}

@Entry
@Component
struct Index {
  // 持有 tcp 实例
  private tcpClient: socket.TCPSocket | null = null;

  // 初始化并连接 TCP
  private connectToServer() {
    // 创建 TCPSocket 实例
    this.tcpClient = socket.constructTCPSocketInstance();

    // 订阅相关事件（接收数据、连接关闭、错误回调）
    this.bindEvents();

    // 绑定本地地址和端口（必须先绑定，可以绑定 0 端口让系统自动分配）
    let bindAddress: socket.NetAddress = {
      address: '0.0.0.0',
      port: 0,
      family: 1
    };

    this.tcpClient.bind(bindAddress).then(() => {
      hilog.info(DOMAIN, TAG, 'Bind success. Connecting...');

      // 连接远端服务器（请替换为你的服务器 IP 和端口）
      let connectAddress: socket.NetAddress = {
        address: '127.0.0.1', // 服务器 IP
        port: 8888,               // 服务器端口
        family: 1
      };

      return this.tcpClient?.connect({ address: connectAddress, timeout: 6000 });
    }).then(() => {
      hilog.info(DOMAIN, TAG, 'Connect success.');
    }).catch((err: BusinessError) => {
      hilog.error(DOMAIN, TAG, `Connect failed. Code: ${err.code}, Message: ${err.message}`);
    });
  }

  // 绑定事件监听
  private bindEvents() {
    if (!this.tcpClient) return;

    this.tcpClient.on('message', (value: SocketInfo) => {
      hilog.info(0x0000, 'testTag', 'on message');
      let buffer = value.message;
      let dataView = new DataView(buffer);
      let str = '';
      for (let i = 0; i < dataView.byteLength; ++i) {
        str += String.fromCharCode(dataView.getUint8(i));
      }
      hilog.info(0x0000, 'testTag', 'on connect received:' + str);
    });

    // 监听连接关闭事件
    this.tcpClient.on('close', () => {
      hilog.info(DOMAIN, TAG, 'Connection closed.');
    });

    // 监听错误事件
    this.tcpClient.on('error', (err: BusinessError) => {
      hilog.error(DOMAIN, TAG, `Socket error: ${err.message}`);
    });
  }

  // 发送数据方法
  private sendData(message: string) {
    if (!this.tcpClient) {
      hilog.error(DOMAIN, TAG, 'Socket is not initialized.');
      return;
    }

    this.tcpClient.send({ data: "123" }).then(() => {
      hilog.info(DOMAIN, TAG, 'Send data success.');
    }).catch((err: BusinessError) => {
      hilog.error(DOMAIN, TAG, `Send failed: ${err.message}`);
    });
  }

  build() {
    Column({ space: 20 }) {
      Button("Connect to Server").onClick(() => {
          this.connectToServer();
        })

      Button("Send Message")
        .onClick(() => {
          this.sendData("Hello HarmonyOS NEXT");
        })
    }
    .width('100%')
    .height('100%')
    .justifyContent(FlexAlign.Center)
  }
}

服务端代码：

import socket


def start_server(host='127.0.0.1', port=8888):
    with socket.socket(socket.AF_INET, socket.SOCK_STREAM) as s:
        # 绑定地址和端口
        s.bind((host, port))

        # 开始监听 (backlog=5 表示最多等待 5 个排队连接)
        s.listen(5)
        print(f"服务端已启动，正在监听 {host}:{port} ...")

        # 接受连接
        conn, addr = s.accept()
        with conn:
            print(f"已连接到客户端: {addr}")

            while True:
                # 接收数据 (最大接收 1024 字节)
                data = conn.recv(1024)
                if not data:
                    print("客户端已断开连接。")
                    break

                message = data.decode('utf-8')
                print(f"收到消息: {message}")

                # 回显消息
                response = f"服务端收到: {message}"
                conn.sendall(response.encode('utf-8'))


if __name__ == "__main__":
    try:
        start_server()
    except KeyboardInterrupt:
        print("\n服务端已停止。")
    except Exception as e:
        print(f"发生错误: {e}")

排查方案：

• 远端服务器的ip和端口是否正确设置
• 是否重复调用了 connect
• 路由器是否存在网络隔离
• 更新最新版本
• 提高超时时间

可以试试调整 timeout 连接超时，我调用AI的接口也是经常因为返回时间太长出错，30秒不够就调到1分钟。特别是生图的模型API

鸿蒙Socket的默认连接超时时间可能较短，如果网络环境稍有延迟，就会触发 EINPROGRESS 错误。

tcp.connect({
    address: connectAddress,
    timeout: 30000 // 将超时时间提高到30秒，给连接更多时间
}, (err: BusinessError) => {
    // ...
});