websocket-client

概述

ripple提供了一个易用的WebSocketClient组件,可以用于创建WebSocket客户端连接。

use Co\Net;
use Ripple\Library\Net\WebSocket\Client\Connection;
use function Co\run;

$connection            = Net::WebSocket()->connect('wss://echo.websocket.org');
$connection->onOpen(function (Connection $connection) {
    $connection->send('{"action":"ping","data":[]}');
});

$connection->onMessage(function (string $data, Connection $connection) {
    echo 'Received: ' . $data . \PHP_EOL;
});

$connection->onClose(function (Connection $connection) {
    echo 'Connection closed' . \PHP_EOL;
});

run();