在使用 ReactPHP 的 Ratchet 客户端建立 WebSocket 连接时，事件循环默认异步执行，导致后续代码（如 echo $reason）立即执行而非等待连接结束；通过显式调用 $loop->run() 可阻塞主线程直至事件循环终止，从而实现同步等待。
在使用 reactphp 的 ratchet 客户端建立 websocket 连接时，事件循环默认异步执行，导致后续代码（如 `echo $reason`）立即执行而非等待连接结束；通过显式调用 `$loop->run()` 可阻塞主线程直至事件循环终止，从而实现同步等待。
ReactPHP 的事件循环（React\EventLoop\Loop）本质上是非阻塞的——它注册回调、监听 I/O 事件，并在后台持续调度任务，但不会自动阻塞主流程。因此，即使你已通过 Ratchet\Client\connect() 设置了连接成功、消息接收和关闭逻辑，若未显式启动并等待循环结束，PHP 脚本会直接执行后续语句（例如 echo "the echo $reason\n";），此时 $reason 仍为初始值 "unknown"。
✅ 正确做法是：在所有异步逻辑注册完成后，手动调用 $loop->run() ——该方法会阻塞当前线程，直到循环被 stop() 显式终止（如收到 "quit" 消息后），此时所有异步操作已完成，变量状态已更新。
以下是修正后的完整示例：
WebSocket 8.18.2 是该协议规范的一个重要迭代版本，主要优化了连接稳定性与数据传输效率。它通过全双工通信机制，允许客户端与服务器在单一长连接上实时交换数据，大幅降低传统 HTTP 轮询的开销。该版本增强了心跳保活、自动重连及二进制帧传输能力，适用于即时通讯、在线游戏及金融行情推送等低延迟场景，为开发者提供更可靠的实时网络交互基础。
use React\EventLoop\Loop;
$loop = Loop::get();
$reason = "unknown";
\Ratchet\Client\connect(
'wss://demo.piesocket.com/v3/channel_1?api_key=VCXCEuvhGcBDP7XhiJJUDvR1e1D3eiVjgZ9VRiaV¬ify_self',
[],
[],
$loop
)->then(
function ($conn) use ($loop, &$reason) {
$conn->on('message', function ($msg) use ($loop, $conn, &$reason) {
echo $msg . "\n";
if ((string)$msg === "quit") {
$conn->close();
$loop->stop(); // 终止事件循环
$reason = "quit";
}
});
},
function ($e) {
echo "Could not connect: {$e->getMessage()}\n";
}
);
// ✅ 关键：显式运行并等待事件循环结束
$loop->run();
// 此时 $reason 已被正确赋值（"quit" 或保持 "unknown"）
echo "the echo $reason\n";
⚠️ 注意事项：
- Loop::get() 内部有“自动运行”机制：若脚本结束前循环既未启动也未停止，ReactPHP 会尝试在 exit 前自动调用 run()。但该行为不可靠（尤其在 CLI 长生命周期脚本或子程序中），且无法保证你的 echo 一定在其后执行。显式调用 run() 是唯一可控、可预测的方式。
- 若将 WebSocket 逻辑封装为函数（如 function waitForWebSocket(): string { ... }），务必在函数末尾调用 $loop->run() 并返回 $reason，才能满足“大脚本等待子程序完成”的需求。
- 切勿在已运行的循环中重复调用 run()（会抛出异常），可通过 $loop->isRunning() 判断；在子程序场景中，建议每次新建独立 Loop 实例（或确保复用时状态干净）。
总结：异步 ≠ 不可控。ReactPHP 的设计哲学是“显式优于隐式”，$loop->run() 就是同步协调异步任务的权威入口——掌握它，才能让事件驱动逻辑真正服务于你的业务流程。
