下面由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. 增加事件監聽
查看源碼得知在事務完成之后，會調用對應的事件，所以只需增加對事件的監聽即可。
-
新增類 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 = []; }} -
創建輔助函數 ?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); }} -
創建監聽 ?AppListenersTransactionListener
namespace AppListeners;use AppHandlersTransactionHandler;class TransactionListener{ public function handle() { app(TransactionHandler::class)->run(); }} -
綁定監聽 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 ] ];} -
更改調用方式 ?AppObserversUserObserver
class UserObserver{ public function created (User $user) { after_transaction(function() use ($user) { dispatch(new SmsQueue($user)); }); }}
OK，一個優雅的解決方式就完成了~~
相關推薦：laravel
