rsocket/rsocket-php

基于 ReactPHP 和 RxPHP 的 RSocket PHP SDK

维护者

详细信息

github.com/rsocket/rsocket-php

主页

源代码

问题

维基

文档

安装: 184

依赖项: 0

建议者: 0

安全性: 0

星标: 10

关注者: 4

分支: 3

公开问题: 3

0.2.0 2022-01-28 00:00 UTC

Requires

Requires (Dev)

Apache License 2.0 4e1b16259a6beb1afc2e7a3c9979c025670a6e1a

rpcreactiversocket

This package is not auto-updated.

Last update: 2024-09-22 14:14:49 UTC

README

Composer

基于 ReactPHP 和 RxPHP 的 RSocket PHP SDK。

要求

  • PHP 7.4+

示例

RSocket 客户端

Scheduler::setDefaultFactory(function () {
    return new Scheduler\EventLoopScheduler(Loop::get());
});

$rsocketPromise = RSocketConnector::create()->connect("tcp://127.0.0.1:42252");

$rsocketPromise->then(function (RSocket $rsocket) {
    $observablePayload = $rsocket->requestResponse(Payload::fromText("text/plain", "Ping"));
    $observablePayload->subscribe(
        function (Payload $x) {
            echo 'Result: ' . $x->getDataUtf8();
        }
    );
});

RSocket 服务器

Scheduler::setDefaultFactory(function () {
    return new Scheduler\EventLoopScheduler(Loop::get());
});

$listenUri = "tcp://127.0.0.1:42252";
$socketAcceptor = CallableSocketAcceptor::handle(function ($setupPayload, $sendingRSocket) {
    return AbstractRSocket::requestResponseHandler(function ($payload) {
        return Observable::of(Payload::fromText("metadata", "PONG"));
    });
});
$server = RSocketServer::create($socketAcceptor)->bind($listenUri);
print("RSocket Server started on ${listenUri}");

RSocket 服务存根和路由

请检查 https://github.com/rsocket/rsocket-php/tree/master/tests/route

RSocket

  • 操作
    • REQUEST_FNF
    • REQUEST_RESPONSE
    • REQUEST_STREAM
    • REQUEST_CHANNEL
    • METADATA_PUSH
  • 更多操作
    • 错误
    • 取消
    • 保活
  • 服务质量
    • RequestN
    • 租约
  • 传输
    • TCP
    • WebSocket
  • 高级 API
    • 客户端
    • 服务器
  • 其他
    • RxPHP

参考