Laravel如何停止异步事件队列

先写个简单的例子

在EventServiceProvider中添加一个事件和两个异步侦听器（再次说明一下，是异步队列ShouldQueue，不是同步的）

        'App\Events\Test\RollEvent' => [
            'App\Listeners\Test\CapterAEventListener',
            'App\Listeners\Test\CapterBEventListener',
        ],

CapterAEventListener输出一行命令，并抛出错误

    public function handle(RollEvent $event)
    {
        echo 'RoolEventA'.PHP_EOL;
        throw new TaskException('testA');
    }

    public  function  failed(RollEvent  $event, $exception) 
    {
        dump($exception);
    }

CapterBEventListener输出一行命令

    public function handle(RollEvent $event)
    {
        echo 'RoolEventB'.PHP_EOL;
    }

在tinker中执行事件

event(new App\Events\Test\RollEvent)

在pm2中监控结果如下：

> [2022-03-24 15:30:40][yMICB1wuiz1vGVPOTExspfTJnegZIcNt] Processing: App\Listeners\Test\CapterAEventListener
> RoolEventA
> [2022-03-24 15:30:40][htYbO4KZjRTucow0sWVHSGebjbHOCOfP] Processing: App\Listeners\Test\CapterBEventListener
> RoolEventB
> [2022-03-24 15:30:40][htYbO4KZjRTucow0sWVHSGebjbHOCOfP] Processed: App\Listeners\Test\CapterBEventListener
> [2022-03-24 15:30:43][yMICB1wuiz1vGVPOTExspfTJnegZIcNt] Processing: App\Listeners\Test\CapterAEventListener
> RoolEventA
> [2022-03-24 15:30:46][yMICB1wuiz1vGVPOTExspfTJnegZIcNt] Processing: App\Listeners\Test\CapterAEventListener
> RoolEventA
> App\Exceptions\TaskException {#2116
> }
> [2022-03-24 15:30:46][yMICB1wuiz1vGVPOTExspfTJnegZIcNt] Failed:  App\Listeners\Test\CapterAEventListener

事件执行过程如下：

先执行CapterAEventListener，输出，抛出错误中断当前队列
继续执行CapterBEventListener，输出
重新执行CapterAEventListener，输出，抛出错误中断当前队列
再次执行CapterAEventListener，输出，抛出错误，达到重试最大次数，停止执行

问题：

我如何在CapterAEventListener的handle第一次抛出错误后，停止整个队列继续执行？如果是在同步的事件中，返回false就不会继续执行了，但是异步队列事件，抛出错误仍旧会继续执行。而我希望的是在一开始抛出错误就停止RollEvent所有异步事件侦听器继续执行

levi

65 声望

暂无个人描述~

0 人点赞

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

我们将带你从零开发一个项目并部署到线上，本课程教授 Web 开发中专业、实用的技能，如 Git 工作流、Laravel Mix 前端工作流等。

推荐文章：

更多推荐...

如何打造令后端面试官印象深刻的简历？ 14 / 10 |

分享创造

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

博客

如何让DcatAdmin再放光芒,惠及百万PHPer 18 / 39 |

博客

Clarity——微软开源并完全免费使用的新一代网站体验分析利器 12 / 1 |

博客

工作小锦囊系列——如何实现一个车辆预定功能（下） 13 / 15 |

博客

工作小锦囊系列——如何实现一个车辆预定功能（上） 23 / 13 |

bigdaxin

见习助教 121 声望

最佳答案

    public function handle(RollEvent $event)
    {
        echo 'RoolEventB'.PHP_EOL;
    }
    public function fail($exception = null)
    {

        //错误后操作
        //$this->delete();


    }

3年前评论

bigdaxin （作者）

@levi 或者异常后你存个队列状态，后面的队列查询这个状态做对应操作。。队列一般是要执行完的。

levi （楼主）

我试过$this->delete()一点效果没有，执行过程和上面一样

levi （楼主）

我之前少加了use InteractsWithQueue;，加上这条trait之后，执行过程如下：①先执行CapterAEventListener，抛出错误，执行$this->delete()，CapterAEventListener不再执行；②开始执行CapterBEventListener；请问能不能在CapterAEventListener中将当前事件所有队列都停止呢？

bigdaxin （作者）

@levi 杀掉队列进程，框架好像没有自带。

levi （楼主）

@bigdaxin 好的

讨论数量: 8

bigdaxin

见习助教 121 声望

    public function handle(RollEvent $event)
    {
        echo 'RoolEventB'.PHP_EOL;
    }
    public function fail($exception = null)
    {

        //错误后操作
        //$this->delete();


    }

3年前评论

bigdaxin （作者）

@levi 或者异常后你存个队列状态，后面的队列查询这个状态做对应操作。。队列一般是要执行完的。

levi （楼主）

我试过$this->delete()一点效果没有，执行过程和上面一样

levi （楼主）

我之前少加了use InteractsWithQueue;，加上这条trait之后，执行过程如下：①先执行CapterAEventListener，抛出错误，执行$this->delete()，CapterAEventListener不再执行；②开始执行CapterBEventListener；请问能不能在CapterAEventListener中将当前事件所有队列都停止呢？

bigdaxin （作者）

@levi 杀掉队列进程，框架好像没有自带。

levi （楼主）

@bigdaxin 好的

xiaopi

课程读者 60 声望 / 程序员 @ 个人

可以换一种思路，使用链式Job。一条链上的，第一个执行失败了，就不会执行后面的了。

3年前评论

levi （楼主）

好的，谢谢，明白了

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

帮助

Laravel如何停止异步事件队列

先写个简单的例子

在pm2中监控结果如下：

事件执行过程如下：

问题：

推荐文章：

社区赞助商

关于 LearnKu

资源推荐

服务提供商

其他信息

Laravel如何停止异步事件队列

先写个简单的例子

在pm2中监控结果如下：

事件执行过程如下：

问题：

推荐文章：

社区赞助商

关于 LearnKu

资源推荐

服务提供商

其他信息

请登录