HarmonyOS 鸿蒙Next使用ArkTS TCP Socket接收数据不全

RT。

目前基于API9开发TCP socket的数据收发功能，但是数据总是收不全（大概就几K的数据），应该有一半的数据没发过来。

同样的服务器环境，Android就没问题，有谁知道什么原因吗？

以下是代码参考开源的例子：

import socket from ‘@ohos.net.socket’;
import Logger from ‘…/utils/Logger’;

const TAG = ‘TcpSocket’;
export default class TcpSocket {
private tcpSocket: socket.TCPSocket | null = null;
/**


创建Socket


@param localIp


@param port
*/
async createSocket(localIp: string, port: number): Promise<boolean> {
Logger.info(${TAG} tcp bind localIp: ${localIp});
try {
if (this.tcpSocket) {
this.tcpSocket.close();
this.tcpSocket = null;
}
this.tcpSocket = socket.constructTCPSocketInstance();
await this.tcpSocket.bind({
address: localIp,
port: port,
family: 1
});
Logger.info(${TAG} tcp bind sucess);
return true;
} catch (e) {
Logger.error(${TAG} tcp bind error ${<span class="hljs-built_in"><span class="hljs-built_in">JSON</span></span>.stringify(e)}});
}
return false;
}


/**


连接Socket


@param address


@param port
*/
async connectSocket(address: string, port: number): Promise<boolean> {
Logger.info(${TAG} tcp connectSocket address: ${address});
try {
if (!this.tcpSocket) {
return false;
}
if (await this.isConnected()) {
Logger.info(${TAG} tcp connectSocket sucess);
return true;
}
await this.tcpSocket.connect({
address: {
address: address,
port: port,
family: 1,
},
timeout: 6000,
});
await this.tcpSocket.setExtraOptions({});
Logger.info(${TAG} tcp connectSocket sucess);
return true;
} catch (e) {
Logger.error(${TAG} tcp connectSocket error ${<span class="hljs-built_in"><span class="hljs-built_in">JSON</span></span>.stringify(e)}});
}
return false;
}


/**

关闭Socket
*/
async closeSocket(): Promise<void> {
if (!this.tcpSocket) {
return;
}
await this.tcpSocket.close();
this.tcpSocket.off(‘connect’);
this.tcpSocket.off(‘message’);
this.tcpSocket = null;
}

/**

发送数据
@param data
*/
async sendData(data: string): Promise<void> {
if (!this.tcpSocket) {
return;
}
Logger.info(${TAG} tcp sendData data ${<span class="hljs-built_in"><span class="hljs-built_in">JSON</span></span>.stringify(data)});
try {
await this.tcpSocket.send({
data: data,
});
} catch (e) {
Logger.error(${TAG} tcp sendData error ${<span class="hljs-built_in"><span class="hljs-built_in">JSON</span></span>.stringify(e)}});
}
}

/**

判断是否连接
*/
async isConnected(): Promise<boolean> {
if (!this.tcpSocket) {
return false;
}

<span class="hljs-keyword"><span class="hljs-keyword">try</span></span> {
  <span class="hljs-keyword"><span class="hljs-keyword">let</span></span> state = await <span class="hljs-keyword"><span class="hljs-keyword">this</span></span>.tcpSocket.getState();
  <span class="hljs-keyword"><span class="hljs-keyword">if</span></span> (state.isConnected) {
    <span class="hljs-keyword"><span class="hljs-keyword">return</span></span> <span class="hljs-literal"><span class="hljs-literal">true</span></span>;
  }
} <span class="hljs-keyword"><span class="hljs-keyword">catch</span></span> (e) {
  Logger.error(`${TAG} tcp getState error ${<span class="hljs-built_in"><span class="hljs-built_in">JSON</span></span>.stringify(e)}}`);
}
<span class="hljs-keyword"><span class="hljs-keyword">return</span></span> <span class="hljs-literal"><span class="hljs-literal">false</span></span>;
}
/**

订阅消息
@param callback
*/
setOnMessageReceivedListener(callback: (buffer: ArrayBuffer) => void): void {
if (!this.tcpSocket) {
return;
}

<span class="hljs-keyword"><span class="hljs-keyword">this</span></span>.tcpSocket.on(<span class="hljs-string"><span class="hljs-string">'message'</span></span>, (data) =&gt; {
  Logger.info(`${TAG} TCP data: ` + <span class="hljs-built_in"><span class="hljs-built_in">JSON</span></span>.stringify(data));
  <span class="hljs-keyword"><span class="hljs-keyword">let</span></span> buffer = data.message;
  callback(buffer);
});
}
/**

TCP 关闭事件订阅
@param callback
*/
setOnCloseListener(callback: () => void): void {
Logger.info(${TAG} TCP setOnCloseListener into);
this.tcpSocket?.on(‘close’, () => {
Logger.info(${TAG} TCP setOnCloseListener onClose：);
callback();
this.closeSocket();
});

<span class="hljs-keyword"><span class="hljs-keyword">this</span></span>.tcpSocket?.on(<span class="hljs-string"><span class="hljs-string">'error'</span></span>, (data) =&gt; {
  Logger.info(
    `${TAG} TCP setOnCloseListener onClose：` + <span class="hljs-built_in"><span class="hljs-built_in">JSON</span></span>.stringify(data)
  );
  callback();
  <span class="hljs-keyword"><span class="hljs-keyword">this</span></span>.closeSocket();
});
}
}
<button style="position: absolute; padding: 4px 8px 0px; cursor: pointer; top: 8px; right: 8px; font-size: 14px;">复制</button>