Worker线程核心特性：每个Worker实例对应一个独立线程，但默认情况下单个Worker内部逻辑是单线程执行的（所有onmessage回调都在同一个线程）

TCP连接处理误区：当前代码将整个TCP服务端监听逻辑都放在Worker的onmessage回调中，会导致每次主线程postMessage时重复创建服务端实例

重构服务端逻辑（MyWork.ets）

import { ThreadWorkerGlobalScope, worker } from '@kit.ArkTS';
import { socket } from '@kit.NetworkKit'
import { BusinessError } from '@kit.BasicServicesKit'

const workerPort: ThreadWorkerGlobalScope = worker.workerPort;

// 创建全局TCP服务端实例
let tcpServer: socket.TCPSocketServer = socket.constructTCPSocketServerInstance();

// 服务端初始化（只执行一次）
const initServer = () => {
    const ipAddress: socket.NetAddress = {
        address: "127.0.0.1",
        port: 8888
    } as socket.NetAddress;

    tcpServer.listen(ipAddress).then(() => {
        workerPort.postMessage("SERVER_READY");
    }).catch((err: BusinessError) => {
        workerPort.postMessage(`SERVER_ERROR:${err.message}`);
    });

    // 监听客户端连接
    tcpServer.on("connect", (client: socket.TCPSocketConnection) => {
        // 为每个客户端创建新的Worker线程
        const clientWorker = new worker.ThreadWorker('entry/ets/workers/ClientHandler.ets');
        
        // 将客户端连接对象传递给新Worker
        clientWorker.postMessage({ 
            type: "NEW_CLIENT", 
            connection: client 
        });
    });
}

// 主线程消息处理
workerPort.onmessage = (event: MessageEvents) => {
    if (event.data === 'START_SERVER') {
        initServer();
    }
};

创建客户端处理线程（ClientHandler.ets）

import { ThreadWorkerGlobalScope, worker } from '@kit.ArkTS';
import { socket } from '@kit.NetworkKit'

const workerPort: ThreadWorkerGlobalScope = worker.workerPort;

workerPort.onmessage = (event: MessageEvents) => {
    if (event.data.type === "NEW_CLIENT") {
        const client: socket.TCPSocketConnection = event.data.connection;

        // 设置客户端消息回调
        client.on("message", (value: SocketInfo) => {
            const buffer = value.message;
            // 业务处理逻辑...
            
            // 向主线程发送处理结果
            workerPort.postMessage({
                type: "CLIENT_MESSAGE",
                data: processMessage(buffer)
            });
        });

        client.on("close", () => {
            workerPort.postMessage({ 
                type: "CLIENT_DISCONNECTED",
                address: client.remoteAddress 
            });
        });
    }
};

修改主线程调用（Index.ets）

@Entry
@Component
struct Index {
    private workerInstance: worker.ThreadWorker;

    aboutToAppear(): void {
        this.workerInstance = new worker.ThreadWorker('entry/ets/workers/MyWorker.ets');
        
        this.workerInstance.onmessage = (e: MessageEvents) => {
            if (e.data === 'SERVER_READY') {
                console.log("TCP Server started successfully");
            }
        };

        this.workerInstance.postMessage('START_SERVER');
    }

    build() {
        // UI构建...
    }
}