wsプロトコル

現在、Workermanのwsプロトコルバージョンは13です。

Workermanはクライアントとして、wsプロトコルを使用してWebSocket接続を開始し、リモートWebSocketサーバーに接続して双方向通信を実現できます。

注意
wsプロトコルはAsyncTcpConnectionをクライアントとして使用する場合のみ使用可能で、WebSocketサーバーとしてリッスンすることはできません。つまり、以下の書き方は誤りです。

$worker = new Worker('ws://0.0.0.0:8080');

WorkermanをWebSocketサーバーとして使用したい場合は、WebSocketプロトコルを使用してください。

wsをWebSocketクライアントプロトコルの例：

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

use Workerman\Protocols\Ws;
use Workerman\Worker;
use Workerman\Connection\AsyncTcpConnection;

$worker = new Worker();
// プロセス起動時
$worker->onWorkerStart = function()
{
    // WebSocketプロトコルでリモートWebSocketサーバーに接続
    $ws_connection = new AsyncTcpConnection("ws://127.0.0.1:1234");
    // 55秒ごとにサーバーにopcodeが0x9のWebSocket心拍を送信(オプション)
    $ws_connection->websocketPingInterval = 55;
    // HTTPヘッダーを設定(オプション)
    $ws_connection->headers = [
        'Cookie' => 'PHPSID=82u98fjhakfusuanfnahfi; token=2hf9a929jhfihaf9i',
        'OtherKey' => 'values'
    ];
    // データタイプを設定(オプション)
    $ws_connection->websocketType = Ws::BINARY_TYPE_BLOB; // BINARY_TYPE_BLOBはテキスト、BINARY_TYPE_ARRAYBUFFERはバイナリ
    // TCPが三回のハンドシェイクを完了したとき(オプション)
    $ws_connection->onConnect = function($connection){
        echo "tcp connected\n";
    };
    // WebSocketがハンドシェイクを完了したとき(オプション)
    $ws_connection->onWebSocketConnect = function(AsyncTcpConnection $con, $response) {
        echo $response;
        $con->send('hello');
    };
    // リモートWebSocketサーバーからメッセージが届いたとき
    $ws_connection->onMessage = function($connection, $data){
        echo "recv: $data\n";
    };
    // 接続時にエラーが発生した場合、一般的にはリモートWebSocketサーバーへの接続失敗エラー(オプション)
    $ws_connection->onError = function($connection, $code, $msg){
        echo "error: $msg\n";
    };
    // リモートWebSocketサーバーへの接続が切断されたとき(オプション、再接続を推奨)
    $ws_connection->onClose = function($connection){
        echo "connection closed and try to reconnect\n";
        // 接続が切れた場合、1秒後に再接続
        $connection->reConnect(1);
    };
    // 上記の様々なコールバックを設定した後、接続操作を実行
    $ws_connection->connect();
};
Worker::runAll();

さらに、ws/wssクライアントとしての参考をご参照ください。