### 1.**服務端代碼** 創建一個 TCP 服務端，監聽指定端口并處理客戶端連接和消息。 ``` use Workerman\Worker; use Workerman\Connection\TcpConnection; require_once __DIR__ . '/vendor/autoload.php'; // 創建一個 Worker，時時監聽 2347 端口（new Worker的過程中會調用一個listen方法） $worker = new Worker('tcp://0.0.0.0:2347'); // 設置進程數 $worker->count = 4; // 當客戶端連接時 $worker->onConnect = function (TcpConnection $connection) { echo "新的鏈接: {$connection->getRemoteIp()}:{$connection->getRemotePort()}\n"; $connection->send("歡迎來到服務端!\n"); }; // 當客戶端發送消息時 $worker->onMessage = function (TcpConnection $connection, $data) { echo "Received from client: $data"; $connection->send("服務器已收到: $data"); }; // 當客戶端斷開連接時 $worker->onClose = function (TcpConnection $connection) { echo "Connection closed: {$connection->getRemoteIp()}:{$connection->getRemotePort()}\n"; }; // 運行 Worker Worker::runAll(); ``` static::init(); static::parseCommand(); static::lock(); static::daemonize(); static::initWorkers(); static::installSignal(); static::saveMasterPid(); static::lock(\LOCK_UN); static::displayUI(); static::forkWorkers(); static::resetStd(); static::monitorWorkers(); ### 2.**客戶端代碼** 創建一個 TCP 客戶端，連接到服務端并發送消息。 ``` use Workerman\Worker; use Workerman\Connection\AsyncTcpConnection; require_once __DIR__ . '/vendor/autoload.php'; // 創建一個 Worker（客戶端不需要監聽端口） $worker = new Worker(); // 當 Worker 啟動時 $worker->onWorkerStart = function () { // 創建一個異步 TCP 連接 $connection = new AsyncTcpConnection('tcp://127.0.0.1:2347'); // 當連接成功時 $connection->onConnect = function (AsyncTcpConnection $connection) { echo "Connected to server\n"; // 發送消息到服務端 $connection->send("Hello from client!"); }; // 當收到服務端消息時 $connection->onMessage = function (AsyncTcpConnection $connection, $data) { echo "Received from server: $data"; }; // 當連接關閉時 $connection->onClose = function (AsyncTcpConnection $connection) { echo "Connection closed\n"; }; // 當連接失敗時 $connection->onError = function (AsyncTcpConnection $connection, $code, $msg) { echo "Connection error: $msg\n"; }; // 發起連接 $connection->connect(); }; // 運行 Worker Worker::runAll(); ```