Swoole怎么捕获协程中的异常

在Swoole协程中，父协程无法直接捕获子协程异常，必须在子协程内使用try-catch处理，或通过Channel传递异常信息回父协程，同时可配合全局异常处理器和日志记录保障程序稳定性。

在 Swoole 中使用协程时，异常捕获需要特别注意协程的运行机制。由于协程是异步执行的，直接在父协程中 try-catch 是无法捕获子协程中抛出的异常的。必须在协程内部自行处理异常，或通过其他方式传递错误信息。

1. 在协程内部使用 try-catch

例如：

use Swoole\Coroutine;

Coroutine\run(function () {
    go(function () {
        try {
            throw new RuntimeException("协程内发生错误");
        } catch (Throwable $exception) {
            echo "捕获到异常: " . $exception->getMessage() . "\n";
        }
    });
});

这样可以确保协程内的异常被及时处理，不会影响其他协程或主流程。

2. 使用 defer 或 defer 函数模拟 finally 行为

Swoole 协程中虽然不支持 defer 关键字，但你可以通过闭包或回调模拟资源清理和异常兜底逻辑。

实际开发中建议配合日志记录，确保异常可追踪：

go(function () {
    try {
        // 模拟网络请求或数据库操作
        $client = new Swoole\Coroutine\Http\Client('httpbin.org', 80);
        if (!$client->get('/status/500')) {
            throw new RuntimeException("HTTP 请求失败");
        }
    } catch (Throwable $throwable) {
        error_log("协程异常: " . $throwable->getMessage());
    } finally {
        $client?->close();
    }
});

3. 通过 channel 传递异常信息

如果需要在父协程中感知子协程的异常，可以通过 Swoole\Coroutine\Channel 将异常对象或错误信息传递回来。

谱乐AI

谱乐AI，集成 Suno、Udio 等顶尖AI音乐模型的一站式AI音乐生成平台。

下载

示例：

use Swoole\Coroutine\Channel;

Coroutine\run(function () {
    $chan = new Channel(1);

    go(function () use ($chan) {
        try {
            throw new Exception("子协程出错");
        } catch (Throwable $e) {
            $chan->push(['error' => $e]);
        }
    });

    $result = $chan->pop();
    if (isset($result['error'])) {
        echo "收到异常: " . $result['error']->getMessage() . "\n";
    }
});

4. 全局异常处理器（慎用）

Swoole 提供了 Swoole\Runtime::enableCoroutine() 和错误监听机制，但协程中的致命错误（Fatal Error）仍可能导致进程退出。

可以注册 set_exception_handler 处理未被捕获的异常，但这不能替代协程内的主动捕获。

set_exception_handler(function ($exception) {
    echo "全局捕获异常: " . $exception->getMessage() . "\n";
});

go(function () {
    throw new Exception("未在协程内捕获");
});

注意：某些版本的 Swoole 中，协程内未捕获的异常可能不会触发全局处理器，依赖版本行为，不推荐完全依赖此方式。