在swoole协程中,父协程无法直接捕获子协程异常,必须在子协程内使用try-catch处理,或通过channel传递异常信息回父协程,同时可配合全局异常处理器和日志记录保障程序稳定性。
在 Swoole 中使用协程时,异常捕获需要特别注意协程的运行机制。由于协程是异步执行的,直接在父协程中 try-catch 是无法捕获子协程中抛出的异常的。必须在协程内部自行处理异常,或通过其他方式传递错误信息。
1. 在协程内部使用 try-catch
最直接有效的方式是在每个协程函数内部使用 try-catch 捕获异常,避免异常未被捕获导致程序崩溃。
例如:
use SwooleCoroutine; Coroutinerun(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 SwooleCoroutineHttpClient('httpbin.org', 80); if (!$client->get('/status/500')) { throw new RuntimeException("HTTP 请求失败"); } } catch (Throwable $throwable) { Error_log("协程异常: " . $throwable->getMessage()); } finally { $client?->close(); } });
3. 通过 channel 传递异常信息
如果需要在父协程中感知子协程的异常,可以通过 SwooleCoroutineChannel 将异常对象或错误信息传递回来。
示例:
use SwooleCoroutineChannel; Coroutinerun(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 提供了 SwooleRuntime::enableCoroutine() 和错误监听机制,但协程中的致命错误(Fatal Error)仍可能导致进程退出。
可以注册 set_exception_handler 处理未被捕获的异常,但这不能替代协程内的主动捕获。
set_exception_handler(function ($exception) { echo "全局捕获异常: " . $exception->getMessage() . "n"; }); go(function () { throw new Exception("未在协程内捕获"); });
注意:某些版本的 Swoole 中,协程内未捕获的异常可能不会触发全局处理器,依赖版本行为,不推荐完全依赖此方式。
基本上就这些。关键是要在每个 go 协程里自己做 try-catch,别指望外面能抓到里面的异常。用 channel 可以实现结果回传,适合任务调度场景。