本篇內(nèi)容主要講解“Laravel中用Observer事件致redis隊列異常問題怎么解決”，感興趣的朋友不妨來看看。本文介紹的方法操作簡單快捷，實用性強(qiáng)。下面就讓小編來帶大家學(xué)習(xí)“Laravel中用Observer事件致Redis隊列異常問題怎么解決”吧!                      

創(chuàng)新互聯(lián)公司是一家專注于成都網(wǎng)站設(shè)計、成都網(wǎng)站建設(shè)與策劃設(shè)計,蒼溪網(wǎng)站建設(shè)哪家好?創(chuàng)新互聯(lián)公司做網(wǎng)站,專注于網(wǎng)站建設(shè)10余年,網(wǎng)設(shè)計領(lǐng)域的專業(yè)建站公司;建站業(yè)務(wù)涵蓋:蒼溪等地區(qū)。蒼溪做網(wǎng)站價格咨詢:028-86922220

1、業(yè)務(wù)邏輯

新建某個模型之后，利用 Observer 模型事件 Created 推入異步短信發(fā)送隊列

App\Http\Controllers\UsersController

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

        try{
            $input = request()->validated();
            $user->fill($input);
            $user->save();
            //do something......
            //其他數(shù)據(jù)表操作

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

    }

App\Observers\UserObserver

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

2、發(fā)現(xiàn)異常

業(yè)務(wù)部門反饋偶爾有用戶收取不到短信通知，我便查看日志發(fā)現(xiàn)偶爾有錯誤異常：No query results for model [App\Models\User]. 表示找不到對應(yīng)的模型

我敲不應(yīng)該啊，我是在創(chuàng)建模型之后再進(jìn)行隊列調(diào)用……，遂對業(yè)務(wù)代碼再進(jìn)行仔細(xì)核查猜測應(yīng)該是受事務(wù)影響。

驗證猜想：

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

        try{
            $input = request()->validated();
            $user->fill($input);
            $user->save();
            //do something......
            //其他數(shù)據(jù)表操作

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

    }

果然在等待三秒之后提交隊列異常已是 100%  觸發(fā)。

3、原因分析

• $user->save() 這個方法創(chuàng)建數(shù)據(jù)成功，便會一并觸發(fā)調(diào)度器，將模型事件一一執(zhí)行。

• 在事件中推送模型至隊列中，而隊列進(jìn)程在不間斷消費(fèi)隊列中數(shù)據(jù)。

• 在大部分情況下 do something 處理速度正常的話，隊列進(jìn)程將會照常運(yùn)行。

• 如果在 do something 階段偶爾出現(xiàn)延遲，造成事務(wù)還未 commit 而隊列已經(jīng)開始消費(fèi)新模型；故引發(fā)上述錯誤。

然后我在搜索 Github Issues 記錄時，發(fā)現(xiàn)此問題在 2015 年的一個 Issue 已經(jīng)有人提出，而在 Laravel 8.X 中終于新增了對事務(wù)模型事件的支持；learnku.com/docs/laravel/8.x/eloqu... ，在社區(qū)文檔似乎并沒有找到相關(guān)說明~

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

4、解決異常

1. 修改 MySQL 事務(wù)隔離級別（不推薦）

這里涉及到 MySQL 的事務(wù)隔離級別，InnoDB 引擎的默認(rèn)隔離級別是 REPEATABLE READ，關(guān)于各個級別的區(qū)別可以在 官方文檔 找到。

將隔離級別切換到 READ UNCOMMITTED 即可解決此問題，但是為了防止出現(xiàn)更大的問題我勸你別用這種方式~

2. 增加事件監(jiān)聽

查看源碼得知在事務(wù)完成之后，會調(diào)用對應(yīng)的事件，所以只需增加對事件的監(jiān)聽即可。

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. 創(chuàng)建輔助函數(shù)  app/helpers.php

   if (! function_exists('after_transaction')) {
       /*
        * 事務(wù)結(jié)束之后再進(jìn)行操作
        * */
       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. 創(chuàng)建監(jiān)聽  App\Listeners\TransactionListener

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

4. 綁定監(jiān)聽 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. 更改調(diào)用方式  App\Observers\UserObserver

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

到此，相信大家對“Laravel中用Observer事件致Redis隊列異常問題怎么解決”有了更深的了解，不妨來實際操作一番吧！這里是創(chuàng)新互聯(lián)網(wǎng)站，更多相關(guān)內(nèi)容可以進(jìn)入相關(guān)頻道進(jìn)行查詢，關(guān)注我們，繼續(xù)學(xué)習(xí)！

本文題目：Laravel中用Observer事件致Redis隊列異常問題怎么解決
文章起源：http://jinyejixie.com/article14/jjpjde.html

成都網(wǎng)站建設(shè)公司_創(chuàng)新互聯(lián)，為您提供網(wǎng)站改版、自適應(yīng)網(wǎng)站、做網(wǎng)站、網(wǎng)站營銷、網(wǎng)站導(dǎo)航、標(biāo)簽優(yōu)化

廣告

聲明：本網(wǎng)站發(fā)布的內(nèi)容（圖片、視頻和文字）以用戶投稿、用戶轉(zhuǎn)載內(nèi)容為主，如果涉及侵權(quán)請盡快告知，我們將會在第一時間刪除。文章觀點不代表本網(wǎng)站立場，如需處理請聯(lián)系客服。電話：028-86922220；郵箱：631063699@qq.com。內(nèi)容未經(jīng)允許不得轉(zhuǎn)載，或轉(zhuǎn)載時需注明來源： 創(chuàng)新互聯(lián)