php socket聊天室

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

// 创建 Socket
$socket = socket_create(AF_INET, SOCK_STREAM, SOL_TCP);
if (!$socket) {
    echo "socket_create() failed: reason: " . socket_strerror(socket_last_error()) . "\n";
    exit();
}

// 绑定 Socket 到地址和端口
$result = socket_bind($socket, $host, $port);
if (!$result) {
    echo "socket_bind() failed: reason: " . socket_strerror(socket_last_error($socket)) . "\n";
    exit();
}

// 监听连接
$result = socket_listen($socket, 3);
if (!$result) {
    echo "socket_listen() failed: reason: " . socket_strerror(socket_last_error($socket)) . "\n";
    exit();
}

echo "Server listening on $host:$port...\n";

while (true) {
    // 接受客户端连接
    $client = socket_accept($socket);
    if (!$client) {
        echo "socket_accept() failed: reason: " . socket_strerror(socket_last_error($socket)) . "\n";
        continue;
    }

    // 读取客户端消息
    $input = socket_read($client, 1024);
    if (!$input) {
        echo "socket_read() failed: reason: " . socket_strerror(socket_last_error($client)) . "\n";
        socket_close($client);
        continue;
    }

    echo "Received message: $input\n";

    // 广播消息给所有客户端
    foreach ($clients as $client) {
        if ($client != $client) {
            socket_write($client, $input, strlen($input));
        }
    }

    // 关闭客户端连接
    socket_close($client);
}

socket_close($socket);
?>