Laravel 8 任務(wù)事件

2021-07-15 16:28 更新

使用 Queue facade 上的 before 和 after 方法，可以指定在處理排隊任務(wù)之前或之后執(zhí)行的回調(diào)。如果要為控制面板執(zhí)行附加日志記錄或增量統(tǒng)計，這些回調(diào)會是絕佳時機。通常，你應(yīng)該從 服務(wù)提供者 調(diào)用這些方法。例如，我們可以使用 Laravel 的 AppServiceProvider：

<?php

namespace App\Providers;

use Illuminate\Support\Facades\Queue;
use Illuminate\Support\ServiceProvider;
use Illuminate\Queue\Events\JobProcessed;
use Illuminate\Queue\Events\JobProcessing;

class AppServiceProvider extends ServiceProvider
{
    /**
     * 注冊任何應(yīng)用程序服務(wù)
     *
     * @return void
     */
    public function register()
    {
        //
    }

    /**
     * 啟動任何應(yīng)用程序服務(wù).
     *
     * @return void
     */
    public function boot()
    {
        Queue::before(function (JobProcessing $event) {
            // $event->connectionName
            // $event->job
            // $event->job->payload()
        });

        Queue::after(function (JobProcessed $event) {
            // $event->connectionName
            // $event->job
            // $event->job->payload()
        });
    }
}

使用 Queue facade 上的 looping 方法，你可以指定在 worker 嘗試從隊列獲取任務(wù)之前執(zhí)行的回調(diào)。例如，你可以注冊一個閉包來回滾以前失敗的任務(wù)留下的任何事務(wù)：

Queue::looping(function () {
    while (DB::transactionLevel() > 0) {
        DB::rollBack();
    }
});


以上內(nèi)容是否對您有幫助：
在線筆記
App下載
App下載

掃描二維碼

下載編程獅App

公眾號
微信公眾號

編程獅公眾號