Protocolo ws

Actualmente, la versión del protocolo ws de Workerman es 13.

Workerman puede actuar como cliente, iniciando una conexión websocket a través del protocolo ws para comunicarse en ambas direcciones con un servidor websocket remoto.

Nota
El protocolo ws solo puede ser utilizado como cliente con AsyncTcpConnection y no puede ser utilizado para escuchar como servidor websocket. Es decir, la siguiente escritura es incorrecta.

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

Si deseas usar Workerman como servidor websocket, por favor utiliza el protocolo websocket.

Ejemplo de ws como protocolo de cliente websocket:

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

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

$worker = new Worker();
// Al iniciar el proceso
$worker->onWorkerStart = function()
{
    // Conectar al servidor websocket remoto usando el protocolo websocket
    $ws_connection = new AsyncTcpConnection("ws://127.0.0.1:1234");
    // Enviar un ping websocket con opcode 0x9 al servidor cada 55 segundos (opcional)
    $ws_connection->websocketPingInterval = 55;
    // Configurar encabezados http (opcional)
    $ws_connection->headers = [
        'Cookie' => 'PHPSID=82u98fjhakfusuanfnahfi; token=2hf9a929jhfihaf9i',
        'OtherKey' => 'values'
    ];
    // Configurar tipo de datos (opcional)
    $ws_connection->websocketType = Ws::BINARY_TYPE_BLOB; // BINARY_TYPE_BLOB para texto, BINARY_TYPE_ARRAYBUFFER para binario
    // Cuando el TCP complete el handshaking de tres vías (opcional)
    $ws_connection->onConnect = function($connection){
        echo "tcp connected\n";
    };
    // Cuando el websocket complete el handshaking (opcional)
    $ws_connection->onWebSocketConnect = function(AsyncTcpConnection $con, $response) {
        echo $response;
        $con->send('hello');
    };
    // Cuando el servidor websocket remoto envía un mensaje
    $ws_connection->onMessage = function($connection, $data){
        echo "recv: $data\n";
    };
    // Cuando ocurre un error en la conexión, generalmente es un error de falla al conectar al servidor websocket remoto (opcional)
    $ws_connection->onError = function($connection, $code, $msg){
        echo "error: $msg\n";
    };
    // Cuando se cierra la conexión con el servidor websocket remoto (opcional, se recomienda agregar reconexión)
    $ws_connection->onClose = function($connection){
        echo "connection closed and try to reconnect\n";
        // Si la conexión se cierra, reconectar después de 1 segundo
        $connection->reConnect(1);
    };
    // Después de configurar todas estas devoluciones de llamada, realizar la operación de conexión
    $ws_connection->connect();
};
Worker::runAll();

Más referencia como cliente ws/wss