README

基于 reactphp-x/worker 的分布式长连接 GatewayWorker 实现，架构参考 Workerman GatewayWorker，支持 TCP 与 WebSocket（WebSocket 使用 reactphp-x/websocket-middleware）。

架构

Client (TCP/WebSocket)
        ↓
    Gateway  ←→  Register  ←→  BusinessWorker
        ↓                            ↓
   转发连接事件                  Events 业务逻辑

• Register：服务注册中心，协调 Gateway 与 BusinessWorker 地址发现
• Gateway：接受客户端长连接，通过二进制 GatewayProtocol 转发给 BusinessWorker
• BusinessWorker：处理 onConnect / onMessage / onClose 业务逻辑

安装

composer install

运行示例

cd examples
php start.php start

默认端口：

TCP 测试

telnet 127.0.0.1 8282

WebSocket 测试

<script>
  var conn = new WebSocket('ws://127.0.0.1:8283/ws');
  conn.onopen = () => conn.send('Hello!');
  conn.onmessage = (e) => console.log(e.data);
</script>

自定义应用

参考 examples/Applications/YourApp/：

• start_register.php — 注册中心
• start_gateway_tcp.php — TCP Gateway
• start_gateway_websocket.php — WebSocket Gateway
• start_businessworker.php — 业务 Worker
• Events.php — 业务回调

License

MIT