(要求Workerman版本>=3.3.0)

void \Channel\Client::on(string $event_name, callback $callback_function)

$event_nameイベントを購読し、イベント発生時の$callback_functionコールバックを登録します。

コールバック関数のパラメータ

$event_name

購読されているイベントの名称。任意の文字列を使用できます。

$callback_function

イベント発生時にトリガーされるコールバック関数。関数プロトタイプはcallback_function(mixed $event_data)です。$event_dataはイベントの発行時に渡されるイベントデータです。

注意:同じイベントに2つのコールバック関数が登録されている場合、後続のコールバック関数が最初のコールバック関数を上書きします。

マルチプロセスワーカー(複数のサーバー)で、クライアントがメッセージを送信すると、すべてのクライアントにブロードキャストする。

start.php

<?php
use Workerman\Worker;
use Workerman\Connection\TcpConnection;
require_once __DIR__ . '/vendor/autoload.php';

// Channelサーバーを初期化
$channel_server = new Channel\Server('0.0.0.0', 2206);

// websocketサーバー
$worker = new Worker('websocket://0.0.0.0:4236');
$worker->name = 'websocket';
$worker->count = 6;
// 各workerプロセスが起動するとき
$worker->onWorkerStart = function($worker)
{
    // ChannelクライアントがChannelサーバーに接続する
    Channel\Client::connect('127.0.0.1', 2206);
    // broadcastイベントを購読し、イベントコールバックを登録
    Channel\Client::on('broadcast', function($event_data)use($worker){
        // 現在のworkerプロセスのすべてのクライアントにメッセージをブロードキャストする
        foreach($worker->connections as $connection)
        {
            $connection->send($event_data);
        }
    });
};

$worker->onMessage = function(TcpConnection $connection, $data)
{
   // クライアントが送信したデータをイベントデータとして扱う
   $event_data = $data;
   // すべてのworkerプロセスにbroadcastイベントを発行する
   \Channel\Client::publish('broadcast', $event_data);
};

Worker::runAll();

テスト

Chromeブラウザを開き、F12キーを押してデバッグコンソールを開き、Consoleタブで以下のコードを入力します(または以下のコードをHTMLページに配置してJavaScriptで実行します)

メッセージを受信する接続

// 127.0.0.1を実際のworkermanのIPに置き換える
ws = new WebSocket("ws://127.0.0.1:4236");
ws.onmessage = function(e) {
    alert("サーバーからのメッセージを受信:" + e.data);
};

メッセージをブロードキャスト

ws.send('hello world');