<?php

namespace process;

use Workerman\Worker;

class WorkermanTcpService
{
    public function onWorkerStart()
    {
        // 創(chuàng)建一個 TCP Worker 監(jiān)聽指定端口
        $tcp_worker = new Worker('tcp://0.0.0.0:2345');
        $tcp_worker->onWorkerStart = function (Worker $worker) {
            echo "Worker {$worker->id} starting...\n";
        };
        // 當有客戶端連接時觸發(fā)
        $tcp_worker->onConnect = function ($connection) {
            echo "New connection\n";
        };

        // 當接收到數據時觸發(fā)
        $tcp_worker->onMessage = function ($connection, $data) {
            // 處理接收到的數據
            $connection->send('Received: ' . $data);
        };

        // 當連接關閉時觸發(fā)
        $tcp_worker->onClose = function ($connection) {
            echo "Connection closed\n";
        };

        Worker::runAll();
    }
}

啟動后一直狂閃，