ワーカーマンを使用してリアルタイムでメッセージをプッシュおよび受信する方法

composer require workerman/workerman

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

use WorkermanWorker;

$pusher = new Worker();
$pusher->count = 4;

$pusher->onWorkerStart = function ($pusher) {
    $inner_ws = new Worker('websocket://127.0.0.1:8000');
    
    $inner_ws->onConnect = function ($connection) {
        echo "New client connected
";
    };
    
    $inner_ws->onMessage = function ($connection, $data) use ($pusher) {
        echo "Received message: $data
";
        
        // 接收到消息后，将消息推送给所有在线客户端
        foreach ($pusher->connections as $client) {
            $client->send($data);
        }
    };
    
    $inner_ws->onClose = function ($connection) {
        echo "Client closed
";
    };
    
    Worker::runAll();
};

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

use WorkermanWorker;

$receiver = new Worker();
$receiver->count = 4;

$receiver->onWorkerStart = function ($receiver) {
    $ws = new Worker('websocket://127.0.0.1:8001');
    
    $ws->onConnect = function ($connection) {
        echo "New client connected
";
    };
    
    $ws->onMessage = function ($connection, $data) {
        echo "Received message: $data
";
        
        // 处理接收到的消息
        // ...
    };
    
    $ws->onClose = function ($connection) {
        echo "Client closed
";
    };
    
    Worker::runAll();
};

php push_server.php start

php receive_server.php start