在 Workerman 中使用 WebSocket 实现实时监控，该如何操作？

<?php
use Workerman\Worker;
use Workerman\Connection\TcpConnection;

require_once __DIR__ . '/vendor/autoload.php';

// 创建WebSocket服务器，监听2346端口
$ws_worker = new Worker('websocket://0.0.0.0:2346');

// 当客户端连接时触发
$ws_worker->onConnect = function($connection) {
    echo "New connection\n";
};

// 当客户端发送消息时触发
$ws_worker->onMessage = function($connection, $data) {
    $connection->send("Hello, you sent: $data");
};

// 当客户端断开连接时触发
$ws_worker->onClose = function($connection) {
    echo "Connection closed\n";
};

// 运行所有Worker
Worker::runAll();

<?php
use Workerman\Worker;
use Workerman\Connection\TcpConnection;

require_once __DIR__ . '/vendor/autoload.php';

$ws_worker = new Worker('websocket://0.0.0.0:2346');

$ws_worker->onConnect = function($connection) {
    echo "New connection\n";
};

$ws_worker->onMessage = function($connection, $data) {
    // 假设$data是客户端请求的监控数据
    $monitor_data = getMonitorData(); // 这里假设有一个函数来获取监控数据
    $connection->send(json_encode($monitor_data));
};

$ws_worker->onClose = function($connection) {
    echo "Connection closed\n";
};

Worker::runAll();

function getMonitorData() {
    // 这里模拟获取监控数据
    return [
        'cpu_usage' => rand(10, 90),
        'memory_usage' => rand(10, 90),
        'disk_usage' => rand(10, 90)
    ];
}

<?php
use Workerman\Worker;
use Workerman\Connection\TcpConnection;

require_once __DIR__ . '/vendor/autoload.php';

$ws_worker = new Worker('websocket://0.0.0.0:2346');

// 存储所有连接的客户端
$connections = [];

$ws_worker->onConnect = function($connection) use (&$connections) {
    $connections[$connection->id] = $connection;
    echo "New connection\n";
};

$ws_worker->onMessage = function($connection, $data) use (&$connections) {
    $data = json_decode($data, true);
    if ($data['type'] === 'subscribe') {
        // 订阅特定类型的监控数据
        $connection->subscribe = $data['subscribe'];
    } elseif ($data['type'] === 'broadcast') {
        // 广播消息给所有客户端
        $message = $data['message'];
        foreach ($connections as $conn) {
            $conn->send(json_encode(['type' => 'broadcast', 'message' => $message]));
        }
    }

    // 推送监控数据
    $monitor_data = getMonitorData($connection->subscribe);
    $connection->send(json_encode(['type' => 'monitor', 'data' => $monitor_data]));
};

$ws_worker->onClose = function($connection) use (&$connections) {
    unset($connections[$connection->id]);
    echo "Connection closed\n";
};

Worker::runAll();

function getMonitorData($subscribe = null) {
    $data = [
        'cpu_usage' => rand(10, 90),
        'memory_usage' => rand(10, 90),
        'disk_usage' => rand(10, 90)
    ];

    if ($subscribe) {
        // 根据订阅类型返回特定数据
        return array_intersect_key($data, array_flip($subscribe));
    }

    return $data;
}