Swoole和Workerman的消息推送在PHP与MySQL中的实时性和可靠性

<?php
// 创建WebSocket服务器
$server = new SwooleWebSocketServer('0.0.0.0', 9501);

// 监听WebSocket连接打开事件
$server->on('open', function (SwooleWebSocketServer $server, $request) {
    echo "connection open: {$request->fd}
";
});

// 监听WebSocket消息事件
$server->on('message', function (SwooleWebSocketServer $server, $frame) {
    echo "received message: {$frame->data}
";

    // 在此处处理消息推送逻辑，比如将消息写入MySQL数据库

    // 广播消息给所有连接的客户端
    foreach ($server->connections as $fd) {
        $server->push($fd, $frame->data);
    }
});

// 监听WebSocket连接关闭事件
$server->on('close', function ($ser, $fd) {
    echo "connection close: {$fd}
";
});

// 启动服务器
$server->start();
?>

<?php
// 引入Workerman的自动加载文件
require_once __DIR__ . '/vendor/autoload.php';

use WorkermanWorker;

// 创建一个Worker监听9501端口，使用WebSocket协议通信
$ws_worker = new Worker("websocket://0.0.0.0:9501");

// 启动4个进程对外提供服务
$ws_worker->count = 4;

// 监听WebSocket连接打开事件
$ws_worker->onConnect = function ($connection) {
    echo "new connection
";
};

// 监听WebSocket消息事件
$ws_worker->onMessage = function ($connection, $data) {
    echo "received message: {$data}
";

    // 在此处处理消息推送逻辑，比如将消息写入MySQL数据库

    // 广播消息给所有连接的客户端
    foreach ($connection->worker->connections as $client_connection) {
        $client_connection->send($data);
    }
};

// 启动Worker
Worker::runAll();
?>