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

问答 / 1 / 5 / 创建于 3年前

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

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

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

65 声望

暂无个人描述~

《L03 构架 API 服务器》

你将学到如 RESTFul 设计风格、PostMan 的使用、OAuth 流程，JWT 概念及使用和 API 开发相关的进阶知识。

《L02 从零构建论坛系统》

以构建论坛项目 LaraBBS 为线索，展开对 Laravel 框架的全面学习。应用程序架构思路贴近 Laravel 框架的设计哲学。

推荐文章：

更多推荐...

10年了，兜兜转转，我还是回去了 25 / 41 |

冯老师的困惑 —— 一个跑了两年的 BUG 19 / 16 |

无需修改任何代码和扩展将你的Laravel项目性能提高20倍 101 / 98 |

手摸手带你使用 docker-compose 编排一个开发环境 19 / 15 |

生产环境致命错误你还在等客户反馈吗？分享一下致命错误的自动告警方案 13 / 7 |

PHP 中一次反射需要多长时间 28 / 9 |

通尼和它的朋友

32 声望

最佳答案

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

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

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

3年前评论

levi （楼主）

我搜一下看看

讨论数量: 5

通尼和它的朋友

32 声望

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

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

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

3年前评论

levi （楼主）

我搜一下看看

laravel_peng

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

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

3年前评论

levi （楼主）

感谢

Smilephp

课程读者 142 声望

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

3年前评论

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

帮助