Laravel异步队列中能用到MySQL事务回滚吗？

问答 / 326 / 5 / 创建于 2年前

假设在EventServiceProvider中有一个事件，和一组异步监听器

        'App\Events\Game\CreateEvent' => [
            'App\Listeners\Game\CreateEventListener1',
            'App\Listeners\Game\CreateEventListener2',
            'App\Listeners\Game\CreateEventListener3',
        ],

每个侦听器都会操作DB，我希望其中有一个抛出异常的时候，对整个队列的事务进行回滚，请问这样如何实现呢？

65 声望

暂无个人描述~

《L04 微信小程序从零到发布》

从小程序个人账户申请开始，带你一步步进行开发一个微信小程序，直到提交微信控制台上线发布。

《G01 Go 实战入门》

从零开始带你一步步开发一个 Go 博客项目，让你在最短的时间内学会使用 Go 进行编码。项目结构很大程度上参考了 Laravel。

推荐文章：

更多推荐...

Laravel 11 中文文档仓库，已翻译完成！！！ 16 / 28 |

Mysql 的 varchar 字段最大长度真的是 65535 吗？ 34 / 10 |

失业两个月找存在感系列——几行代码轻松实现laravel链式追踪，一分钟快速排查系统问题 23 / 19 |

MySQL 实用小技巧——谁动了我的 MySQL ？ 63 / 18 |

经过代理如何获取真实IP 及 laravel 中配置可信代理的原理 16 / 1 |

如何在 Laravel 中创建一个简单的事件流？ 28 / 18 |

通尼和它的朋友

32 声望

最佳答案

如果是同步（没接队列），可以试试将发送事件时的操作放进事务里面，例如下面代码：

<?php
DB::transaction(function () {
  OrderShipped::dispatch($order);
});

如果是异步的话就要自己实现了，有一个概念叫saga，就是来保持异步的数据一致性的，可以看看有没有相关的包

2年前评论

levi （楼主）

我搜一下看看

讨论数量: 5

通尼和它的朋友

32 声望

如果是同步（没接队列），可以试试将发送事件时的操作放进事务里面，例如下面代码：

<?php
DB::transaction(function () {
  OrderShipped::dispatch($order);
});

如果是异步的话就要自己实现了，有一个概念叫saga，就是来保持异步的数据一致性的，可以看看有没有相关的包

2年前评论

levi （楼主）

我搜一下看看

laravel_peng

版主 899 声望 / 技术员 @ 修炼的漱石

其实事件和监听者，使用的是观察着模式，是一种代码解耦的方式。
使用队列通知或者延迟队列通知观察者，那么代码的连续性被隔断，队列相当于消息中间件，此时监听者是互相隔离的，没办法回滚。
不使用队列的话，就要看Laravel底层是怎么执行事件通知的，以及怎么调用观察者，此时的代码是连续的，不过要修改底层代码，加上事务回滚。

2年前评论

levi （楼主）

感谢

Smilephp

课程读者 109 声望

这得自己做业务代码回滚吧

2年前评论

讨论应以学习和精进为目的。请勿发布不友善或者负能量的内容，与人为善，比聪明更重要！

帮助