如何基於PHP 的socket_accept() 函數實現一個簡單的聊天室應用原型？

M66 2025-06-05

在Web 編程中，PHP 通常被用於處理HTTP 請求，但其實PHP 也提供了豐富的底層網絡操作函數，包括socket_*系列函數，可以用來實現TCP 通訊功能。本文將演示如何基於PHP 的socket_accept()函數，構建一個簡易的聊天室應用原型，以幫助你理解PHP 的socket 編程機制。

一、基本原理

聊天室的基本機制是：服務器監聽一個端口，多個客戶端通過socket 連接到服務器，服務器接受客戶端的連接（通過socket_accept() ），並將接收到的消息廣播給所有其他客戶端。

二、服務端代碼

服務端負責創建socket、綁定端口、監聽連接，並循環接受客戶端連接，然後處理和轉發消息。

 <?php
$host = '0.0.0.0';
$port = 12345;
$clients = [];

$server = socket_create(AF_INET, SOCK_STREAM, SOL_TCP);
socket_set_option($server, SOL_SOCKET, SO_REUSEADDR, 1);
socket_bind($server, $host, $port);
socket_listen($server);

echo "Server started on $host:$port\n";

while (true) {
    $read = $clients;
    $read[] = $server;

    $write = $except = null;

    if (socket_select($read, $write, $except, null) < 1) {
        continue;
    }

    if (in_array($server, $read)) {
        $client = socket_accept($server);
        if ($client) {
            socket_getpeername($client, $addr, $port);
            echo "Client connected: {$addr}:{$port}\n";
            $clients[] = $client;
            socket_write($client, "歡迎來到聊天室！\n");
        }
        unset($read[array_search($server, $read)]);
    }

    foreach ($read as $sock) {
        $data = @socket_read($sock, 2048, PHP_NORMAL_READ);
        if ($data === false) {
            $index = array_search($sock, $clients);
            socket_getpeername($sock, $addr, $port);
            echo "Client disconnected: {$addr}:{$port}\n";
            unset($clients[$index]);
            socket_close($sock);
            continue;
        }

        $data = trim($data);
        if (!empty($data)) {
            socket_getpeername($sock, $addr, $port);
            $message = "[{$addr}:{$port}] 說: {$data}\n";

            foreach ($clients as $client) {
                if ($client !== $sock) {
                    socket_write($client, $message);
                }
            }

            echo $message;
        }
    }
}

三、客戶端實現方式

客戶端可以使用telnet 或者使用瀏覽器配合WebSocket 代理進行連接。不過，如果你希望用PHP 模擬客戶端發送消息，也可以用如下代碼：

 <?php
$host = '127.0.0.1';
$port = 12345;

$socket = socket_create(AF_INET, SOCK_STREAM, SOL_TCP);
socket_connect($socket, $host, $port);

echo socket_read($socket, 2048);

while (true) {
    echo "請輸入消息: ";
    $msg = trim(fgets(STDIN));

    if ($msg === 'exit') {
        break;
    }

    socket_write($socket, $msg . "\n");

    $response = socket_read($socket, 2048);
    echo "收到消息: " . $response;
}

socket_close($socket);

四、實用建議與擴展思路

多進程支持：你可以利用pcntl_fork()實現多進程支持，避免主進程阻塞。
日誌管理：為每條消息添加時間戳，方便後期排查問題。
身份識別：為每個客戶端設置暱稱或ID，可以增強用戶體驗。
前端連接：可以通過WebSocket 轉發，將PHP 聊天室與網頁前端集成，使用http://m66.net/socket-proxy類似的中間件進行通信橋接。

五、總結

通過socket_accept()等PHP Socket 函數，我們可以在命令行環境中實現一個基礎的聊天服務。儘管PHP 並非實時通訊的主流語言，但藉助其底層函數，仍可完成TCP 通訊功能，適合作為學習網絡編程機制的入門範例。如果要將其部署到生產環境，建議結合更專業的消息隊列和異步服務器框架來提升性能與穩定性。

socket_accept