# rsocket-php

**Repository Path**: mirrors_rsocket/rsocket-php

## Basic Information

- **Project Name**: rsocket-php
- **Description**: RSocket PHP implementation using ReactPHP
- **Primary Language**: Unknown
- **License**: Apache-2.0
- **Default Branch**: master
- **Homepage**: None
- **GVP Project**: No

## Statistics

- **Stars**: 0
- **Forks**: 0
- **Created**: 2020-09-25
- **Last Updated**: 2026-05-17

## Categories & Tags

**Categories**: Uncategorized

**Tags**: None

## README

RSocket PHP
================
[![Composer](https://img.shields.io/packagist/v/rsocket/rsocket-php)](https://packagist.org/packages/rsocket/rsocket-php)

RSocket PHP SDK based on ReactPHP and RxPHP.

# Requirements

* PHP 7.4+

# Examples

### RSocket Client

```php
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 Server

```php
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 Service stub and routing

Please check https://github.com/rsocket/rsocket-php/tree/master/tests/route

# RSocket

- Operations
    - [x] REQUEST_FNF
    - [x] REQUEST_RESPONSE
    - [x] REQUEST_STREAM
    - [ ] REQUEST_CHANNEL
    - [x] METADATA_PUSH
- More Operations
    - [x] Error
    - [ ] Cancel
    - [x] Keepalive
- QoS
    - [ ] RequestN
    - [ ] Lease
- Transport
    - [x] TCP
    - [x] Websocket
- High Level APIs
    - [x] Client
    - [x] Server
- Misc
    - [x] RxPHP

# References

* RSocket: https://rsocket.io
* ReactPHP: https://github.com/reactphp/reactphp
* ReactPHP Projects: https://github.com/reactphp/reactphp/wiki/Users
* RxPHP: https://github.com/ReactiveX/RxPHP
* New .phpstorm.meta.php features: https://blog.jetbrains.com/phpstorm/2019/02/new-phpstorm-meta-php-features/
* PHP Reactive Programming: https://www.packtpub.com/web-development/php-reactive-programming
* Ratchet: Asynchronous WebSocket server https://github.com/ratchetphp/Ratchet
* Pawl: asynchronous WebSocket client https://github.com/ratchetphp/Pawl
* PHP 8: Attributes: https://stitcher.io/blog/attributes-in-php-8