Laravel中用Observer事件致Redis隊列異常問題

下面由laravel教程欄目帶大家分享記錄關于laravel observer 導致 redis 隊列異常問題,希望對大家有所幫助!

? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ?

1、業務邏輯

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

ApphttpControllersUsersController

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

AppObserversUserObserver

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

2、發現異常

業務部門反饋偶爾有用戶收取不到短信通知,我便查看日志發現偶爾有錯誤異常:No query results for model [AppModelsUser]. 表示找不到對應的模型

我敲不應該啊,我是在創建模型之后再進行隊列調用……,遂對業務代碼再進行仔細核查猜測應該是受事務影響。

驗證猜想:

    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隊列異常問題

  1. 新增類 AppHandlersTransactionHandler

    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(AppHandlersTransactionHandler::class, function (){             return new AppHandlersTransactionHandler();         });         app(AppHandlersTransactionHandler::class)->add($job);     }}
  3. 創建監聽 ?AppListenersTransactionListener

    namespace AppListeners;use AppHandlersTransactionHandler;class TransactionListener{     public function handle()     {         app(TransactionHandler::class)->run();     }}
  4. 綁定監聽 AppProvidersEventServiceProvider

    namespace AppProviders;use AppListenersTransactionListener;use IlluminateDatabaseEventsTransactionCommitted;use IlluminateDatabaseEventsTransactionRolledBack;use IlluminateFoundationSupportProvidersEventServiceProvider 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. 更改調用方式 ?AppObserversUserObserver

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

OK,一個優雅的解決方式就完成了~~

相關推薦:laravel

? 版權聲明
THE END
喜歡就支持一下吧
點贊15 分享