Laravel中用Observer事件致Redis队列异常问题

2022-05-15 0 155

下面由Laravel教程栏目带大家分享记录关于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、原因分析

$user->save() 这个方法创建数据成功,便会一并触发调度器,将模型事件一一执行。

在事件中推送模型至队列中,而队列进程在不间断消费队列中数据。

在大部分情况下 do something 处理速度正常的话,队列进程将会照常运行。

如果在 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. 增加事件监听

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

Laravel中用Observer事件致Redis队列异常问题

新增类 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 = [];    }}

创建辅助函数 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);    }}

创建监听 App\\Listeners\\TransactionListener

namespace App\\Listeners;use App\\Handlers\\TransactionHandler;class TransactionListener{    public function handle()    {        app(TransactionHandler::class)->run();    }}

绑定监听 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        ]    ];}

更改调用方式 App\\Observers\\UserObserver

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

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

相关推荐:最新的五个Laravel视频教程

收藏 (0) 打赏

感谢您的支持,我会继续努力的!

打开微信/支付宝扫一扫,即可进行扫码打赏哦,分享从这里开始,精彩与您同在
点赞 (0)

【声明:根据2013年1月30日《计算机软件保护条例》2次修订第17条规定: 为了学习和研究软件内含的设计思想和原理,通过安装、显示、传输或者存 储软件等方式使用软件的,可以不经软件著作权人许可,不向其支付报酬! 鉴于此,也希望大家按此说明研究软件!】
本站所有源码尽量保证原汁原味,如有特殊情况会作出声明及标注,网站资源不做任何二次加密(原版加密除外,不影响程序使用的不会做解密处理),方便您更好的学习参考。 在您的能力范围内,为了大环境的良性发展,请尽可能的选择正版资源。如若本站内容侵犯了原著者的合法权益,可联系我们进行处理。

即刻码站__国内靠谱的站长资源下载平台 php教程 Laravel中用Observer事件致Redis队列异常问题 https://www.jike1995.com/36272.html

常见问题
  • 本站所有资源版权均属于原作者所有,这里所提供资源均只能用于参考学习用,请勿直接商用。若由于商用引起版权纠纷,一切责任均由使用
查看详情
  • 最常见的情况是下载不完整: 可对比下载完压缩包的与网盘上的容量,若小于网盘提示的容量则是这个原因。这是浏览器下载的bug,建议用百度
查看详情

相关文章

发表评论
暂无评论
官方客服团队

为您解决烦忧 - 24小时在线 专业服务