基于 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