Protocolo ws

Atualmente, a versão do protocolo ws do Workerman é 13.

Workerman pode atuar como cliente, iniciando uma conexão websocket através do protocolo ws, conectando-se a um servidor websocket remoto, permitindo comunicação bidirecional.

Atenção
O protocolo ws só pode ser usado como cliente através de AsyncTcpConnection, não pode atuar como servidor websocket para escutar o protocolo. Isso significa que a seguinte escrita é errada.

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

Se você deseja usar o Workerman como servidor websocket, utilize o protocolo websocket.

Exemplo de ws como protocolo cliente websocket:

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

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

$worker = new Worker();
// Quando o processo inicia
$worker->onWorkerStart = function()
{
    // Conectar ao servidor websocket remoto usando o protocolo websocket
    $ws_connection = new AsyncTcpConnection("ws://127.0.0.1:1234");
    // Enviar um opcode 0x9 de ping websocket para o servidor a cada 55 segundos (opcional)
    $ws_connection->websocketPingInterval = 55;
    // Configurar cabeçalho http (opcional)
    $ws_connection->headers = [
        'Cookie' => 'PHPSID=82u98fjhakfusuanfnahfi; token=2hf9a929jhfihaf9i',
        'OtherKey' => 'values'
    ];
    // Definir tipo de dados (opcional)
    $ws_connection->websocketType = Ws::BINARY_TYPE_BLOB; // BINARY_TYPE_BLOB para texto, BINARY_TYPE_ARRAYBUFFER para binário
    // Quando o TCP completar o handshake de três vias (opcional)
    $ws_connection->onConnect = function($connection){
        echo "tcp conectado\n";
    };
    // Quando o websocket completar o handshake (opcional)
    $ws_connection->onWebSocketConnect = function(AsyncTcpConnection $con, $response) {
        echo $response;
        $con->send('hello');
    };
    // Quando o servidor websocket remoto envia uma mensagem
    $ws_connection->onMessage = function($connection, $data){
        echo "recv: $data\n";
    };
    // Quando ocorre um erro na conexão, geralmente um erro ao conectar ao servidor websocket remoto (opcional)
    $ws_connection->onError = function($connection, $code, $msg){
        echo "erro: $msg\n";
    };
    // Quando a conexão com o servidor websocket remoto é fechada (opcional, recomenda-se adicionar reconexão)
    $ws_connection->onClose = function($connection){
        echo "conexão fechada e tentando reconectar\n";
        // Se a conexão for fechada, reconectar após 1 segundo
        $connection->reConnect(1);
    };
    // Após definir todos os callbacks acima, executar a operação de conexão
    $ws_connection->connect();
};
Worker::runAll();

Mais referências como cliente ws/wss