记 Laravel Observer 导致 Redis 队列异常

1、业务逻辑

新建某个模型之后,利用 Observer 模型事件 Created 推入异步短信发送队列

App\Http\Controllers\UsersController

    public function store(User $user)
    {
        \DB::beginTransaction();

        try{
            $input = request()->validated();
            $user->fill($input);
            $user->save();
            //do something......
            //其他数据表操作

            \DB::commit();
        } catch ($e \Exception) {
            \DB::rollBack();
        }

    }

App\Observers\UserObserver

class UserObserver
{
    public function created (User $user)
    {
        dispatch(new SmsQueue($user));
    }
}

2、发现异常

业务部门反馈偶尔有用户收取不到短信通知,我便查看日志发现偶尔有错误异常:No query results for model [App\Models\User]. 表示找不到对应的模型

我敲不应该啊,我是在创建模型之后再进行队列调用……,遂对业务代码再进行仔细核查猜测应该是受事务影响。

验证猜想:

    public function store(User $user)
    {
        \DB::beginTransaction();

        try{
            $input = request()->validated();
            $user->fill($input);
            $user->save();
            //do something......
            //其他数据表操作

            sleep(3); //三秒之后再提交事务            
            \DB::commit();
        } catch ($e \Exception) {
            \DB::rollBack();
        }

    }

果然在等待三秒之后提交队列异常已是 100% 触发。

3、原因分析

  1. $user->save() 这个方法创建数据成功,便会一并触发调度器,将模型事件一一执行。
  2. 在事件中推送模型至队列中,而队列进程在不间断消费队列中数据。
  3. 在大部分情况下 do something 处理速度正常的话,队列进程将会照常运行。
  4. 如果在 do something 阶段偶尔出现延迟,造成事务还未 commit 而队列已经开始消费新模型;故引发上述错误。

然后我在搜索 Github Issues 记录时,发现此问题在 2015 年的一个 Issue 已经有人提出,而在 Laravel 8.X 中终于新增了对事务模型事件的支持;learnku.com/docs/laravel/8.x/eloqu... ,在社区文档似乎并没有找到相关说明~

由于我的版本是 6.x 所以用不了这个新特性[哭唧唧]~~

4、解决异常

1. 修改 MySQL 事务隔离级别(不推荐)

这里涉及到 MySQL 的事务隔离级别,InnoDB 引擎的默认隔离级别是 REPEATABLE READ,关于各个级别的区别可以在 官方文档 找到。

将隔离级别切换到 READ UNCOMMITTED 即可解决此问题,但是为了防止出现更大的问题我劝你别用这种方式~

2. 增加事件监听

查看源码得知在事务完成之后,会调用对应的事件,所以只需增加对事件的监听即可。

image-20211029160303394

  1. 新增类 App\Handlers\TransactionHandler

    class TransactionHandler
    {
        public array $handlers;
    
        public function __construct()
        {
            $this->handlers = [];
        }
    
        public function add(\Closure $handler)
        {
            $this->handlers[] = $handler;
        }
    
        public function run()
        {
            foreach ($this->handlers as $handler) {
                $handler();
            }
            $this->handlers = [];
        }
    }
  2. 创建辅助函数 app/helpers.php

    
    if (! function_exists('after_transaction')) {
        /*
         * 事务结束之后再进行操作
         * */
        function after_transaction(Closure $job)
        {
            app()->singletonIf(\App\Handlers\TransactionHandler::class, function (){
                return new \App\Handlers\TransactionHandler();
            });
            app(\App\Handlers\TransactionHandler::class)->add($job);
        }
    }
    
  3. 创建监听 App\Listeners\TransactionListener

    
    namespace App\Listeners;
    
    use App\Handlers\TransactionHandler;
    
    class TransactionListener
    {
        public function handle()
        {
            app(TransactionHandler::class)->run();
        }
    }
  4. 绑定监听 App\Providers\EventServiceProvider

    
    namespace App\Providers;
    
    use App\Listeners\TransactionListener;
    use Illuminate\Database\Events\TransactionCommitted;
    use Illuminate\Database\Events\TransactionRolledBack;
    use Illuminate\Foundation\Support\Providers\EventServiceProvider as ServiceProvider;;
    
    class EventServiceProvider extends ServiceProvider
    {
        /**
         * The event listener mappings for the application.
         *
         * @var array
         */
        protected $listen = [
            TransactionCommitted::class => [
                TransactionListener::class
            ],
            TransactionRolledBack::class => [
                TransactionListener::class
            ]
        ];
    }
    
  5. 更改调用方式 App\Observers\UserObserver

class UserObserver
{
    public function created (User $user)
    {
        after_transaction(function() use ($user) {
            dispatch(new SmsQueue($user));
        });
    }
}

OK,一个优雅的解决方式就完成了~~

本作品采用《CC 协议》,转载必须注明作者和本文链接
本帖由系统于 1年前 自动加精
《L04 微信小程序从零到发布》
从小程序个人账户申请开始,带你一步步进行开发一个微信小程序,直到提交微信控制台上线发布。
《G01 Go 实战入门》
从零开始带你一步步开发一个 Go 博客项目,让你在最短的时间内学会使用 Go 进行编码。项目结构很大程度上参考了 Laravel。
讨论数量: 24

handlers 应该需要每次清空下。不然2次after_transaction会重复派发job。

1年前 评论
lidongyoo (楼主) 1年前
勇敢的心 1年前
di-gua (作者) 1年前
Summer

优雅

1年前 评论
lidongyoo (楼主) 1年前

file

我怀疑有这个问题

1年前 评论
lidongyoo (楼主) 1年前

laravel8.x里面是不是设置afterCommit就可以了

1年前 评论
lidongyoo (楼主) 1年前
happyqian_ah 9个月前

我也想发文章跟你一样优雅,无奈唯有卧槽卧槽 :sweat_smile:

1年前 评论
lidongyoo (楼主) 1年前
bigdaxin (作者) 1年前

之前遇到过,我没想过去监听事物,我直接让模型不触发模型事件的方式保存,然后自己在整一个事件来手动触发队列 :joy:,我现在更喜欢你的解决方式

1年前 评论

优雅 :cow:啤

1年前 评论
翟宇鑫

牛的牛的,最近刚好碰到异步事件出现 No query results for model [App\Models\User] 这个错误
头疼不已,能力有限,又不能精准确定是哪里的问题
去试试楼主的方案

1年前 评论

給queue 使用aftercommit

Laravel
但是 在 octane下 使用 aftercommit 不生效 不知道是什麼原因造成的

1年前 评论
lidongyoo (楼主) 1年前

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