Laravel中用Observer事件致Redis队列异常问题怎么解决

本篇内容主要讲解“Laravel中用Observer事件致redis队列异常问题怎么解决”，感兴趣的朋友不妨来看看。本文介绍的方法操作简单快捷，实用性强。下面就让小编来带大家学习“Laravel中用Observer事件致Redis队列异常问题怎么解决”吧!

创新互联公司是一家专注于成都网站设计、成都网站建设与策划设计,苍溪网站建设哪家好?创新互联公司做网站,专注于网站建设10余年,网设计领域的专业建站公司;建站业务涵盖:苍溪等地区。苍溪做网站价格咨询:028-86922220

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));
        });
    }}

到此，相信大家对“Laravel中用Observer事件致Redis队列异常问题怎么解决”有了更深的了解，不妨来实际操作一番吧！这里是创新互联网站，更多相关内容可以进入相关频道进行查询，关注我们，继续学习！

文章题目：Laravel中用Observer事件致Redis队列异常问题怎么解决
标题链接：http://scyanting.com/article/jjpjde.html

Laravel中用Observer事件致Redis队列异常问题怎么解决

1、业务逻辑

2、发现异常

3、原因分析

4、解决异常

1. 修改 MySQL 事务隔离级别（不推荐）

2. 增加事件监听

其他资讯