onMessage

説明:

callback Worker::$onMessage

クライアントが接続を通じてデータを送信した時（Workermanがデータを受信した時）にトリガーされるコールバック関数。

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

$connection

接続オブジェクト、すなわちTcpConnectionインスタンスであり、クライアント接続の操作に使用されます。例えば、データ送信、接続の閉鎖など。

$data

クライアント接続から送られてきたデータ。もしWorkerがプロトコルを指定している場合、$dataは対応するプロトコルでデコードされたデータです。データタイプはプロトコルのdecode()実装に依存します。websocketのtextのframeは文字列であり、HTTPプロトコルはWorkerman\Protocols\Http\Requestオブジェクトです。

サンプル

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

$worker = new Worker('websocket://0.0.0.0:8484');
$worker->onMessage = function(TcpConnection $connection, $data)
{
    var_dump($data);
    $connection->send('receive success');
};
// workerの実行
Worker::runAll();

ヒント：匿名関数をコールバックとして使用することに加えて、こちらを参考にすることで他のコールバックの書き方も使用できます。