php数据如何制作简单的聊天室_php数据WebSocket实时通信开发-php教程-PHP中文网

php数据如何制作简单的聊天室_php数据WebSocket实时通信开发

爱谁谁

发布： 2025-10-25 09:42:02

原创

774人浏览过

答案：使用PHP结合WebSocket实现聊天室需通过原生socket或第三方库建立全双工通信，替代低效的AJAX轮询。示例代码展示了基于PHP原生socket创建WebSocket服务器的过程，包括监听连接、握手协议、消息广播等核心逻辑，实现客户端间实时消息传递。

php数据如何制作简单的聊天室_php数据websocket实时通信开发

实现一个简单的聊天室，核心在于实时通信。PHP本身是请求-响应模式的后端语言，无法单独完成实时推送，但结合 WebSocket 技术可以解决这个问题。下面介绍如何使用 PHP 和 WebSocket 实现一个基础的聊天室功能。

1. 为什么需要 WebSocket？

传统 PHP 配合 AJAX 轮询的方式虽然能模拟实时聊天，但效率低、延迟高。而 WebSocket 提供了全双工通信通道，服务器可以在有新消息时主动推送给客户端，真正实现“实时”。

PHP 可以通过内置的 socket 扩展或借助第三方库来搭建 WebSocket 服务。

2. 使用 PHP 原生 Socket 搭建 WebSocket 服务

无需额外依赖，可以用 PHP 写一个简易的 WebSocket 服务器。以下是一个基本结构示例：

立即学习“PHP免费学习笔记（深入）”；

怪兽AI数字人

数字人短视频创作，数字人直播，实时驱动数字人

查看详情

// server.php
$host = '127.0.0.1';
$port = 8080;

$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);

$clients = [];

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

    socket_select($read, $write, $except, null);

    if (in_array($socket, $read)) {
        $client = socket_accept($socket);
        $key = uniqid();
        $clients[$key] = $client;

        $header = socket_read($client, 1024);
        performHandshake($client, $header);

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

    foreach ($read as $client) {
        $data = @socket_recv($client, $buf, 1024, 0);
        if ($data === false) {
            continue;
        }
        if ($data == 0) {
            // 客户端断开
            foreach ($clients as $k => $c) {
                if ($c === $client) {
                    unset($clients[$k]);
                    break;
                }
            }
            socket_close($client);
        } else {
            $message = unmask($buf);
            $response = mask("用户 " . rand(1000, 9999) . "：" . $message);

            foreach ($clients as $c) {
                socket_write($c, $response, strlen($response));
            }
        }
    }
}

function performHandshake($client, $headers) {
    $headers = explode("\r\n", $headers);
    $secKey = '';
    foreach ($headers as $h) {
        if (preg_match('/Sec-WebSocket-Key: (.+)/', $h, $matches)) {
            $secKey = $matches[1];
        }
    }
    $acceptKey = base64_encode(sha1($secKey . '258EAFA5-E914-47DA-95CA-C5AB0DC85B11', true));
    $upgradeHeaders = "HTTP/1.1 101 Switching Protocols\r\n";
    $upgradeHeaders .= "Upgrade: websocket\r\n";
    $upgradeHeaders .= "Connection: Upgrade\r\n";
    $upgradeHeaders .= "Sec-WebSocket-Accept: $acceptKey\r\n\r\n";
    socket_write($client, $upgradeHeaders, strlen($upgradeHeaders));
}

function mask($payload) {
    $frame = [];
    $frame[0] = '81';
    $len = strlen($payload);
    if ($len <= 125) {
        $frame[1] = dechex($len);
    } elseif ($len < 65536) {
        $frame[1] = '7e' . str_pad(dechex($len), 4, '0', STR_PAD_LEFT);
    } else {
        $frame[1] = '7f' . str_pad(dechex($len), 16, '0', STR_PAD_LEFT);
    }
    $frame[2] = bin2hex($payload);
    return hex2bin(implode('', $frame));
}

function unmask($payload) {
    $length = ord($payload[1]) & 127;
    if ($length == 126) {
        $masks = substr($payload, 4, 4);
        $data = substr($payload, 8);
    } elseif ($length == 127) {
        $masks = substr($payload, 10, 4);
        $data = substr($payload, 14);
    } else {
        $masks = substr($payload, 2, 4);
        $data = substr($payload, 6);
    }
    $text = '';
    for ($i = 0; $i < strlen($data); ++$i) {
        $text .= $data[$i] ^ $masks[$i % 4];
    }
    return $text;
}

登录后复制

启动方式：在命令行运行 php server.php，即可开启 WebSocket 服务（监听 8080 端口）。

3. 前端页面连接 WebSocket

使用 JavaScript 创建 WebSocket 连接，发送和接收消息：

<!DOCTYPE html>
<html>
<head>
    <title>简易聊天室</title>
</head>
<body>
    <div id="chat"></div>
    <input type="text" id="msg" placeholder="输入消息" />
    <button onclick="send()">发送</button>

    <script>
        const ws = new WebSocket('ws://127.0.0.1:8080');

        ws.onopen = function() {
            console.log('已连接到聊天室');
        };

        ws.onmessage = function(e) {
            const div = document.createElement('div');
            div.innerHTML = e.data;
            document.getElementById('chat').appendChild(div);
        };

        function send() {
            const input = document.getElementById('msg');
            ws.send(input.value);
            input.value = '';
        }
    </script>
</body>
</html>

登录后复制

注意：浏览器中的 WebSocket 地址必须与 PHP 启动的服务地址一致（协议为 ws://，端口匹配）。