当前位置：首页 > PHP

php socket实现聊天室

2026-01-28 23:51:08PHP

实现 PHP Socket 聊天室

PHP 的 Socket 扩展可以用于创建实时聊天应用。以下是一个基础的实现方法：

创建服务器端

服务器端需要监听端口并处理客户端连接：

<?php
set_time_limit(0);
$host = "127.0.0.1";
$port = 25003;

$socket = socket_create(AF_INET, SOCK_STREAM, SOL_TCP) or die("Could not create socket\n");
socket_bind($socket, $host, $port) or die("Could not bind to socket\n");
socket_listen($socket) or die("Could not set up socket listener\n");

$clients = array($socket);

while (true) {
    $read = $clients;
    $write = $except = null;

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

    if (in_array($socket, $read)) {
        $new_client = socket_accept($socket);
        $clients[] = $new_client;
        socket_write($new_client, "Connected to chat server\n");
        $key = array_search($socket, $read);
        unset($read[$key]);
    }

    foreach ($read as $read_socket) {
        $data = @socket_read($read_socket, 1024);
        if ($data === false) {
            $key = array_search($read_socket, $clients);
            socket_close($read_socket);
            unset($clients[$key]);
            continue;
        }

        $data = trim($data);
        if (!empty($data)) {
            foreach ($clients as $client_socket) {
                if ($client_socket != $socket && $client_socket != $read_socket) {
                    socket_write($client_socket, $data . "\n");
                }
            }
        }
    }
}

socket_close($socket);
?>

创建客户端

客户端可以使用命令行或网页界面：

<?php
$host = "127.0.0.1";
$port = 25003;

$socket = socket_create(AF_INET, SOCK_STREAM, SOL_TCP) or die("Could not create socket\n");
socket_connect($socket, $host, $port) or die("Could not connect to server\n");

while (true) {
    $message = readline("Enter message: ");
    socket_write($socket, $message);

    $response = socket_read($socket, 1024);
    echo "Server says: " . $response;
}

socket_close($socket);
?>

网页客户端实现

对于浏览器客户端，可以使用WebSocket或AJAX轮询：

// websocket.html
<!DOCTYPE html>
<html>
<head>
    <title>WebSocket Chat</title>
</head>
<body>
    <div id="messages"></div>
    <input type="text" id="message" />
    <button onclick="sendMessage()">Send</button>

    <script>
        const ws = new WebSocket("ws://localhost:25003");

        ws.onmessage = function(event) {
            document.getElementById("messages").innerHTML += event.data + "<br>";
        };

        function sendMessage() {
            const message = document.getElementById("message").value;
            ws.send(message);
            document.getElementById("message").value = "";
        }
    </script>
</body>
</html>