php网络编程指南：WebSocket编程详解

中国大学网 2024-10-17

websocket 是一种允许客户端和服务器通过单个 tcp 连接进行全双工通信的协议。使用 php 开发 websocket 应用程序的步骤如下：安装 ratchet pawl 库。创建 websocket 服务器，使用 ratchet pawl 库并实现 websocket 应用程序类。实现 onopen、onmessage、onclose 和 onerror 方法来处理连接和消息。使用 send() 方法向客户端发送消息。创建一个简单的聊天室演示 websocket 应用程序的实战案例。

PHP 网络编程指南：WebSocket 编程详解

WebSocket 是一种全双工通信协议，允许客户端和服务器在单个 TCP 连接上进行实时通信。下面是使用 PHP 编写 WebSocket 应用程序的分步指南。

1. 安装依赖

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

composer require ratchet/pawl

2. 创建 WebSocket 服务器

使用 Ratchet Pawl 库创建 WebSocket 服务器：

use Ratchet\Server\IoServer;
use Ratchet\Http\HttpServer;
use Ratchet\WebSocket\WsServer;
use Example\WebsocketApplication;

$transport = new HttpServer(new WsServer(new WebsocketApplication()));
$server = IoServer::factory($transport, 8080);
$server->run();

3. 实现 WebSocket 应用程序

创建一个实现 \Ratchet\WebSocket\MessageComponentInterface 接口的 WebSocket 应用程序类：

namespace Example;

class WebsocketApplication implements \Ratchet\WebSocket\MessageComponentInterface
{
    // ...
}

4. 处理连接和消息

在应用程序类中，实现以下方法：

onOpen: 在客户端连接时调用。
onMessage: 在客户端发送消息时调用。
onClose: 在客户端断开连接时调用。
onError: 在出现错误时调用。

5. 发送消息

使用 $this->send() 方法向客户端发送消息。

实战案例

为了展示一个简单的 WebSocket 应用程序，我们创建一个简单的聊天室：

前端（HTML）：

JavaScript：

const socket = new WebSocket('ws://localhost:8080');

socket.onmessage = (event) => {
  const message = JSON.parse(event.data);
  $('#messages').append(`${message.username}: ${message.body}`);
};

$('#send-button').click(() => {
  const message = {
    username: 'user',
    body: $('#message').val()
  };

  socket.send(JSON.stringify(message));
  $('#message').val('');
});

WebSocket 应用程序（PHP）：

use Ratchet\MessageComponentInterface;
use Ratchet\ConnectionInterface;

class ChatApplication implements MessageComponentInterface
{
    protected $clients;

    public function __construct()
    {
        $this->clients = new \SplObjectStorage;
    }

    public function onOpen(ConnectionInterface $conn)
    {
        // Add the new connection to the list of clients
        $this->clients->attach($conn);
    }

    public function onMessage(ConnectionInterface $from, $msg)
    {
        $message = json_decode($msg);

        // Broadcast the message to all other clients
        foreach ($this->clients as $client) {
            if ($client !== $from) {
                $client->send(json_encode($message));
            }
        }
    }

    public function onClose(ConnectionInterface $conn)
    {
        // Remove the connection from the list of clients
        $this->clients->detach($conn);
    }

    public function onError(ConnectionInterface $conn, \Exception $e)
    {
        // Log the error and close the connection
        echo $e->getMessage() . PHP_EOL;
        $conn->close();
    }
}

运行 Websocket 服务器

执行以下命令运行 WebSocket 服务器：