当前位置：首页 > 文章列表 > 文章 > php教程 > PHP实现简单聊天室，WebSocket实时通信教程

PHP实现简单聊天室，WebSocket实时通信教程

2026-01-18 08:54:45 0浏览收藏

今天golang学习网给大家带来了《PHP数据实现简单聊天室，WebSocket实时通信教程》，其中涉及到的知识点包括等等，无论你是小白还是老手，都适合看一看哦~有好的建议也欢迎大家在评论留言，若是看完有所收获，也希望大家能多多点赞支持呀！一起加油学习~

答案：使用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 服务器。以下是一个基本结构示例：

// 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

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