React Socket Client中定时任务无法正常运行的问题求助

问题分析 #

第一种代码的问题 #

ConnectionInterface 对象代表已建立的Socket连接，它并不存在 connection 事件（该事件属于Socket Server）。因此你绑定的connection回调永远不会触发，导致定时任务从未被添加到事件循环中。

第二种代码的问题 #

代码逻辑本身无错误，但可能因未捕获连接失败异常、服务器未返回数据，或未显式启动事件循环（若代码中遗漏$loop->run()），导致无法触发data事件。

正确实现代码 #

$loop = \React\EventLoop\Loop::get();

// 添加定时任务（用于数据库行检查）
$loop->addPeriodicTimer(2, function () {
    var_dump('执行定时任务：检查数据库行');
    // 在此处编写你的数据库检查逻辑
});

// 创建Socket连接器并传入事件循环
$connector = new \React\Socket\Connector([], $loop);
$connector->connect($host)->then(
    // 连接成功回调
    function (\React\Socket\ConnectionInterface $connection) {
        $connection->write('test write');

        // 监听服务器返回的数据
        $connection->on('data', function ($data) {
            var_dump('收到服务器数据:', $data);
        });

        // 监听连接关闭事件（可选）
        $connection->on('close', function () {
            var_dump('Socket连接已关闭');
        });
    },
    // 连接失败回调（捕获异常）
    function (\Exception $e) {
        var_dump('Socket连接失败:', $e->getMessage());
    }
);

// 启动事件循环（必须调用，否则所有事件都不会执行）
$loop->run();

关键说明 #

1. 定时任务直接添加到全局事件循环中，无需依赖Socket连接的特定事件。
2. 连接成功后直接绑定data事件处理服务器返回数据，无需额外监听connection事件。
3. 必须调用$loop->run()启动事件循环，否则所有定时任务和Socket事件都不会触发。
4. 添加连接失败回调，便于排查连接问题。

内容的提问来源于stack exchange，提问作者Alma Z