本篇內(nèi)容主要講解“Laravel中用Observer事件致redis隊(duì)列異常問題怎么解決”，感興趣的朋友不妨來看看。本文介紹的方法操作簡(jiǎn)單快捷，實(shí)用性強(qiáng)。下面就讓小編來帶大家學(xué)習(xí)“Laravel中用Observer事件致Redis隊(duì)列異常問題怎么解決”吧!
創(chuàng)新互聯(lián)公司是一家專注于成都網(wǎng)站設(shè)計(jì)、成都網(wǎng)站建設(shè)與策劃設(shè)計(jì),蒼溪網(wǎng)站建設(shè)哪家好?創(chuàng)新互聯(lián)公司做網(wǎng)站,專注于網(wǎng)站建設(shè)10余年,網(wǎng)設(shè)計(jì)領(lǐng)域的專業(yè)建站公司;建站業(yè)務(wù)涵蓋:蒼溪等地區(qū)。蒼溪做網(wǎng)站價(jià)格咨詢:028-86922220
新建某個(gè)模型之后，利用 Observer 模型事件 Created 推入異步短信發(fā)送隊(duì)列
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));
}}業(yè)務(wù)部門反饋偶爾有用戶收取不到短信通知，我便查看日志發(fā)現(xiàn)偶爾有錯(cuò)誤異常：No query results for model [App\Models\User]. 表示找不到對(duì)應(yīng)的模型
我敲不應(yīng)該啊，我是在創(chuàng)建模型之后再進(jìn)行隊(duì)列調(diào)用……，遂對(duì)業(yè)務(wù)代碼再進(jìn)行仔細(xì)核查猜測(cè)應(yīng)該是受事務(wù)影響。
驗(yàn)證猜想：
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();
}
}果然在等待三秒之后提交隊(duì)列異常已是 100% 觸發(fā)。
$user->save() 這個(gè)方法創(chuàng)建數(shù)據(jù)成功，便會(huì)一并觸發(fā)調(diào)度器，將模型事件一一執(zhí)行。
在事件中推送模型至隊(duì)列中，而隊(duì)列進(jìn)程在不間斷消費(fèi)隊(duì)列中數(shù)據(jù)。
在大部分情況下 do something 處理速度正常的話，隊(duì)列進(jìn)程將會(huì)照常運(yùn)行。
如果在 do something 階段偶爾出現(xiàn)延遲，造成事務(wù)還未 commit 而隊(duì)列已經(jīng)開始消費(fèi)新模型；故引發(fā)上述錯(cuò)誤。
然后我在搜索 Github Issues 記錄時(shí)，發(fā)現(xiàn)此問題在 2015 年的一個(gè) Issue 已經(jīng)有人提出，而在 Laravel 8.X 中終于新增了對(duì)事務(wù)模型事件的支持；learnku.com/docs/laravel/8.x/eloqu... ，在社區(qū)文檔似乎并沒有找到相關(guān)說明~
由于我的版本是 6.x 所以用不了這個(gè)新特性[哭唧唧]~~
這里涉及到 MySQL 的事務(wù)隔離級(jí)別，InnoDB 引擎的默認(rèn)隔離級(jí)別是 REPEATABLE READ，關(guān)于各個(gè)級(jí)別的區(qū)別可以在 官方文檔 找到。
將隔離級(jí)別切換到 READ UNCOMMITTED 即可解決此問題，但是為了防止出現(xiàn)更大的問題我勸你別用這種方式~
查看源碼得知在事務(wù)完成之后，會(huì)調(diào)用對(duì)應(yīng)的事件，所以只需增加對(duì)事件的監(jiān)聽即可。
新增類 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 = [];
}}創(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);
}}創(chuàng)建監(jiān)聽 App\Listeners\TransactionListener
namespace App\Listeners;use App\Handlers\TransactionHandler;class TransactionListener{
public function handle()
{
app(TransactionHandler::class)->run();
}}綁定監(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
]
];}更改調(diào)用方式 App\Observers\UserObserver
class UserObserver{
public function created (User $user)
{
after_transaction(function() use ($user) {
dispatch(new SmsQueue($user));
});
}}到此，相信大家對(duì)“Laravel中用Observer事件致Redis隊(duì)列異常問題怎么解決”有了更深的了解，不妨來實(shí)際操作一番吧！這里是創(chuàng)新互聯(lián)網(wǎng)站，更多相關(guān)內(nèi)容可以進(jìn)入相關(guān)頻道進(jìn)行查詢，關(guān)注我們，繼續(xù)學(xué)習(xí)！
