PHP 怎么用RSocket

本文目录导读：

1. 使用第三方 PHP 库（推荐）
2. 使用 WebSocket 桥接（跨语言方案）
3. 通过 HTTP/2 桥接（针对 Spring Boot RSocket）
4. 高级配置
5. 注意事项

在 PHP 中使用 RSocket 需要特别注意，因为 PHP 官方并没有 RSocket 的标准扩展，主要的实现都是第三方库，以下我会介绍当前可用的几种方案及其使用方法：

使用第三方 PHP 库（推荐）

目前最成熟的 PHP RSocket 库是 rsocket/rsocket（由 ReactPHP 生态提供）。

安装

composer require rsocket/rsocket

基本使用示例

<?php
require 'vendor/autoload.php';
use RSocket\RSocket;
use RSocket\RSocketConnector;
use React\EventLoop\Factory;
// 创建事件循环
$loop = Factory::create();
// 配置连接（默认端口 42252）
$connector = new RSocketConnector();
$connector->connect('tcp://localhost:42252')->then(function(RSocket $rsocket) use ($loop) {
    echo "Connected!\n";
    // 1. 请求-响应模式（类似 HTTP）
    $rsocket->requestResponse('request', '你好，服务器！')->then(function($response) {
        echo "收到响应: " . $response . "\n";
    });
    // 2. 请求-流模式
    $rsocket->requestStream('stream', '获取数据流')->then(function($stream) {
        $stream->on('data', function($data) {
            echo "流数据: " . $data . "\n";
        });
    });
    // 3. 即发即忘模式
    $rsocket->fireAndForget('fire', '不需要响应');
}, function($error) {
    echo "连接失败: " . $error->getMessage() . "\n";
});
$loop->run();

服务器端示例

use RSocket\RSocketServer;
use RSocket\Responder\AbstractRSocketResponder;
class MyResponder extends AbstractRSocketResponder
{
    // 处理请求-响应
    public function requestResponse($data): string
    {
        return "服务器收到: " . $data;
    }
    // 处理请求-流
    public function requestStream($data): Generator
    {
        for ($i = 0; $i < 5; $i++) {
            yield "数据 $i 来自流";
        }
    }
    // 处理即发即忘
    public function fireAndForget($data): void
    {
        echo "收到即时消息: " . $data . "\n";
    }
}
$loop = Factory::create();
$server = new RSocketServer($loop, new MyResponder());
$server->listen(42252);
echo "K4启动服务器在端口 42252...\n";
$loop->run();

使用 WebSocket 桥接（跨语言方案）

如果必须与其他语言（如 Java/Spring 或 Node.js）的 RSocket 服务通信，可以通过 WebSocket 进行桥接：

<?php
// 使用 WebSocket + JSON 传输
use Ratchet\Client\WebSocket;
$connector = new WebSocket('wss://java-service/rsocket');
$connector->send(json_encode([
    'type' => 'request-response',
    'route' => 'user.info',
    'data' => ['userId' => 123]
]));
$connector->on('message', function($msg) {
    $response = json_decode($msg, true);
    echo "服务端响应: " . json_encode($response) . "\n";
});

通过 HTTP/2 桥接（针对 Spring Boot RSocket）

如果目标是 Spring Boot 的 RSocket（使用 @MessageMapping），可以将 PHP 作为 HTTP 客户端发送：

<?php
$client = new \GuzzleHttp\Client();
// 模拟 RSocket 请求（通常需要配合网关）
$response = $client->post('http://spring-boot-service/rsocket', [
    'json' => [
        'route' => 'hello',
        'payload' => ['name' => 'PHP 客户端']
    ]
]);
echo $response->getBody();

推荐的生产方案

由于 PHP 生态的限制，在生产环境中通常采用以下组合：

高级配置

// 配置 TLS 连接
$connector = new RSocketConnector();
$connector->setTlsCertificate(__DIR__ . '/cert.pem');
$connector->setTlsKey(__DIR__ . '/key.pem');
$connector->setTlsCertificateVerifyPeer(true);
// 添加拦截器
$connector->addInterceptor(function($payload) {
    // 记录日志或添加鉴权信息
    $payload['token'] = 'jwt-token';
    return $payload;
});

注意事项

1. 性能限制：ReactPHP 是单线程异步模型，不适合 CPU 密集型应用
2. 协议支持：目前库对 RSocket v1.0 的支持还不完整（缺少通道模式）
3. 错误处理：需要仔细处理断线重连逻辑
4. 测试：可以使用 Java/Node.js 的 RSocket 客户端做集成测试

如果项目对性能要求极高,建议将 RSocket 服务用 Java/Go 实现，PHP 通过消息队列或 HTTP 协议与其交互，这样可以利用 RSocket 的优势，同时避免 PHP 实现的性能瓶颈。