hyperf 中事务管理推荐使用 db::transaction() 自动处理提交与回滚,所有操作须在闭包内完成且不可跨协程;手动事务需 try-catch 保障完整性;默认隔离级别为 repeatable read,注意避免耗时操作与跨协程事务。

Hyperf 中事务管理主要通过 Db::transaction() 方法实现,它会自动处理提交和回滚,无需手动调用 commit() 或 rollback() —— 只要闭包内无异常,就自动提交;一旦抛出异常(包括 throw new Exception 或未捕获的错误),框架会自动回滚。
使用 Db::transaction() 包裹业务逻辑
这是最推荐、最安全的方式。所有数据库操作必须在闭包内完成,且不能跨协程或异步任务执行。
- 事务内所有查询、插入、更新、删除都共享同一个 PDO 连接和事务上下文
- 若闭包中调用其他 service 方法,需确保这些方法不主动开启新连接或事务(避免嵌套事务失效)
- 示例:
use Hyperf\DbConnection\Db;
$result = Db::transaction(function () {
$user = User::create(['name' => 'Alice']);
$profile = Profile::create(['user_id' => $user->id, 'bio' => 'Hello']);
// 若此处抛异常,上面两条记录都会回滚
if (empty($user) || empty($profile)) {
throw new \RuntimeException('创建失败');
}
return ['user_id' => $user->id, 'profile_id' => $profile->id];
});
手动控制事务(不推荐,仅特殊场景)
当需要更精细控制(如部分回滚、保存点)时,可手动调用 Db::beginTransaction()、Db::commit()、Db::rollback()。但要注意:必须成对出现,且不能遗漏异常捕获。
- 务必用 try-catch 包裹,确保无论成功失败都能释放连接
- 手动事务不支持超时自动回滚,需自行保障逻辑健壮性
- 示例:
Db::beginTransaction();
try {
User::create(['name' => 'Bob']);
Profile::create(['user_id' => 100, 'bio' => 'Hi']);
Db::commit();
} catch (\Throwable $e) {
Db::rollback();
throw $e;
}
事务中的查询也受隔离级别约束
Hyperf 默认使用 MySQL 的 REPEATABLE READ 隔离级别(取决于数据库配置)。这意味着:
- 事务内多次
SELECT同一数据,结果一致(不会看到其他事务已提交的变更) - 若需读取最新数据,可用
SELECT ... FOR UPDATE或SELECT ... LOCK IN SHARE MODE加锁 - 注意:Eloquent 的
find()、first()等默认不加锁,如需强一致性请显式加锁
常见陷阱与建议
- 不要在事务中调用 HTTP 请求、Redis 操作或耗时任务——会延长事务持有时间,增加死锁风险
- 避免在事务内做条件判断后决定是否继续(如先查再删),应尽量用原子 SQL(如
DELETE WHERE EXISTS)代替 - 协程环境下,每个协程有独立的数据库连接,事务不会跨协程传播,勿在
go()内开启事务后等待其他协程结果 - 单元测试中启用事务时,记得在
tearDown()中清理或使用@beforeTransaction注解重置状态










