下面由Laravel教學欄位帶大家分享記錄關於Laravel Observer 導致 Redis 佇列異常問題，希望對大家有幫助！
新建某個模型之後，利用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));
}}業務部門回饋偶爾有使用者收取不到簡訊通知，我便查看日誌發現偶爾有錯誤異常：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% 觸發。
$user->save() 這個方法建立資料成功，就會一併觸發調度器，將模型事件一一執行。
在事件中推送模型至佇列中，而佇列程序在不間斷消費佇列中資料。
在大部分情況下 do something 處理速度正常的話，佇列進程將會照常運作。
如果在 do something 階段偶爾出現延遲，造成事務還未 commit 而隊列已經開始消費新模型；故引發上述錯誤。
然後我在搜尋Github Issues 記錄時，發現此問題在2015 年的一個Issue 已經有人提出，而在Laravel 8.X 中終於新增了對事務模型事件的支援；learnku.com/docs/laravel/8.x/eloqu... ，在社區文檔似乎沒有找到相關說明~
#由於我的版本是6.x 所以用不了這個新特性[哭唧唧]~~
這裡涉及到MySQL 的事務隔離級別，InnoDB 引擎的預設隔離級別是REPEATABLE READ，關於各個級別的區別可以在官方文件中找到。
將隔離等級切換到READ UNCOMMITTED 即可解決此問題，但是為了防止出現更大的問題我勸你別用這種方式~
查看原始碼得知在交易完成之後，會呼叫對應的事件，所以只要增加對事件的監聽即可。
新增類別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影片教學
以上是Laravel中用Observer事件致Redis佇列異常問題的詳細內容。更多資訊請關注PHP中文網其他相關文章！
