当前位置：首页 > PHP

php socket实现聊天室

2026-04-03 05:36:03PHP

实现基础Socket服务器

在PHP中创建一个Socket服务器需要使用socket_create、socket_bind和socket_listen函数。以下代码展示如何初始化一个基本的Socket服务器：

$host = '127.0.0.1';
$port = 1234;

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

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

处理客户端连接

使用socket_accept接收客户端连接，并为每个连接创建一个新的Socket资源。建议将客户端Socket存储在数组中以便管理：

$clients = [];

while (true) {
    $newClient = socket_accept($socket);
    $clients[] = $newClient;

    $clientIp = '';
    socket_getpeername($newClient, $clientIp);
    echo "New client connected: $clientIp\n";
}

实现消息广播

当客户端发送消息时，服务器需要将消息广播给所有连接的客户端。使用socket_read接收消息，socket_write发送消息：

while (true) {
    $readSockets = $clients;
    $readSockets[] = $socket;

    if (socket_select($readSockets, $write, $except, 0) > 0) {
        foreach ($readSockets as $readSocket) {
            if ($readSocket === $socket) {
                // 处理新连接
            } else {
                $message = socket_read($readSocket, 1024);
                if ($message === false || $message === '') {
                    // 客户端断开连接
                } else {
                    foreach ($clients as $client) {
                        if ($client !== $readSocket) {
                            socket_write($client, $message, strlen($message));
                        }
                    }
                }
            }
        }
    }
}

处理客户端断开

当客户端断开连接时，需要从客户端数组中移除对应的Socket并关闭连接：

$index = array_search($readSocket, $clients);
if ($index !== false) {
    socket_close($readSocket);
    unset($clients[$index]);
    echo "Client disconnected\n";
}

完整示例代码

以下是一个简单的PHP Socket聊天室服务器实现：

$host = '127.0.0.1';
$port = 1234;
$clients = [];

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

echo "Chat server started on $host:$port\n";

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

    if (socket_select($read, $write, $except, 0) < 1)
        continue;

    if (in_array($socket, $read)) {
        $newClient = socket_accept($socket);
        $clients[] = $newClient;

        $clientIp = '';
        socket_getpeername($newClient, $clientIp);
        echo "New client connected: $clientIp\n";

        $key = array_search($socket, $read);
        unset($read[$key]);
    }

    foreach ($read as $client) {
        $message = socket_read($client, 1024);

        if ($message === false || trim($message) === '') {
            $index = array_search($client, $clients);
            socket_close($client);
            unset($clients[$index]);
            echo "Client disconnected\n";
            continue;
        }

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

socket_close($socket);

客户端连接测试

可以使用Telnet或编写PHP客户端来测试这个聊天室：

$socket = socket_create(AF_INET, SOCK_STREAM, SOL_TCP);
socket_connect($socket, '127.0.0.1', 1234);

while (true) {
    $message = fgets(STDIN);
    socket_write($socket, $message, strlen($message));

    $response = socket_read($socket, 1024);
    echo $response;
}