如何使用 PHP 建立 WebSocket 服务器？

2024-03-24 18:59:20

用 PHP 建立 WebSocket 服务器的完整指南

引言

WebSocket 是一种协议，可实现客户端和服务器之间持续不断的双向通信。与 HTTP 等传统协议不同，WebSocket 允许服务器主动向客户端发送消息，从而实现实时通信。本文将引导你使用 PHP 创建一个简单的 WebSocket 服务器。

先决条件

安装 PHP
具备基本的 PHP 知识

服务器端代码

以下是创建 WebSocket 服务器的 PHP 代码：

php代码

<?php
// WebSocket 服务器端口
$port = 12345;

// 创建 WebSocket 服务器
$server = stream_socket_server("tcp://0.0.0.0:$port");

// 检测客户端连接
while (true) {
    $client = stream_socket_accept($server);
    
    // 处理客户端消息
    while ($data = fread($client, 65535)) {
        // 解码 WebSocket 帧数据
        $decodedData = json_decode($data);

        // 根据收到的消息类型采取相应操作
        switch ($decodedData->type) {
            case 'message':
                // 向客户端发送消息
                fwrite($client, json_encode(['type' => 'message', 'data' => 'Hello from server']));
                break;
            case 'close':
                // 关闭客户端连接
                fclose($client);
                break;
            default:
                // 忽略未知消息类型
                break;
        }
    }

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

// 关闭 WebSocket 服务器
fclose($server);

客户端端代码

以下是使用 JavaScript 创建 WebSocket 客户端的代码：

JavaScript代码

// 创建 WebSocket 客户端
const ws = new WebSocket('ws://localhost:12345');

// WebSocket 客户端连接成功事件
ws.onopen = function() {
    console.log('WebSocket connected!');
};

// WebSocket 客户端收到消息事件
ws.onmessage = function(event) {
    // 解析收到的 JSON 数据
    const data = JSON.parse(event.data);

    // 根据消息类型采取相应操作
    switch (data.type) {
        case 'message':
            // 显示服务器发送的消息
            console.log(`Server: ${data.data}`);
            break;
        default:
            // 忽略未知消息类型
            break;
    }
};

// WebSocket 客户端连接关闭事件
ws.onclose = function() {
    console.log('WebSocket closed!');
};

// WebSocket 客户端连接错误事件
ws.onerror = function(error) {
    console.log(`WebSocket error: ${error}`);
};

// 发送消息到服务器
ws.send(JSON.stringify({type: 'message', data: 'Hello from client'}));