rx/websocket

使用 Rx 的 PHP Websocket 库

维护者

详情

github.com/RxPHP/RxWebsocket

源代码

问题

安装次数: 177,259

依赖者: 5

建议者: 0

安全性: 0

星标: 34

关注者: 5

分支: 9

公开问题: 6

2.2.0 2023-12-12 13:25 UTC

Requires

Requires (Dev)

MIT 6461c4f4296497cf595e9a38bfa9990ecd381665

  • Matt Bonneau <matt.woop@bonneau.net>
  • David Dan <davidwdan.woop@gmail.com>

websocketWebSocketsreactreactiverxrfc6455rx.phprxphp

This package is not auto-updated.

Last update: 2024-09-15 01:55:57 UTC

README

CI status

Rx\Websocket 是一个 PHP Websocket 库。

使用方法

客户端

$client = new \Rx\Websocket\Client('ws://127.0.0.1:9191/');

$client->subscribe(
    function (\Rx\Websocket\MessageSubject $ms) {
        $ms->subscribe(
            function ($message) {
                echo $message . "\n";
            }
        );

        $sayHello = function () use ($ms) {
            $ms->onNext('Hello');
        };

        $sayHello();
        \EventLoop\addPeriodicTimer(5, $sayHello);
    },
    function ($error) {
        // connection errors here
    },
    function () {
        // stopped trying to connect here
    }
);

一个Echo服务器

$server = new \Rx\Websocket\Server('127.0.0.1:9191');

$server->subscribe(function (\Rx\Websocket\MessageSubject $cs) {
    $cs->subscribe($cs);
});

将所有内容输出到控制台的服务器

$server = new \Rx\Websocket\Server('127.0.0.1:9191');

$server->subscribe(function (\Rx\Websocket\MessageSubject $cs) {
    $cs->subscribe(function ($message) {
        echo $message;
    });
});

安装

使用 Composer

composer require rx/websocket