laravel怎么为队列任务创建和使用中间件_laravel队列任务中间件创建与使用方法

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

class AppServiceProvider extends ServiceProvider
{
    public function boot()
    {
        Queue::before(function (JobProcessing $event) {
            // 类似中间件的 before 处理
            \Log::info('任务即将执行: ' . $event->job->getName());
        });

        Queue::after(function (JobProcessed $event) {
            // 类似中间件的 after 处理
            \Log::info('任务执行完成: ' . $event->job->getName());
        });
    }
}

trait InteractsWithMiddleware
{
    protected function middleware($job, $next)
    {
        $this->beforeHandle($job);
        $result = $next($job);
        $this->afterHandle($job);
        return $result;
    }

    protected function beforeHandle($job)
    {
        // 子类可重写
    }

    protected function afterHandle($job)
    {
        // 子类可重写
    }
}

class SendWelcomeEmail implements ShouldQueue
{
    use InteractsWithMiddleware;

    public function handle()
    {
        return $this->middleware(null, function () {
            // 实际业务逻辑
            \Log::info('发送欢迎邮件...');
        });
    }

    protected function beforeHandle($job)
    {
        \Log::info('准备发送邮件...');
    }

    protected function afterHandle($job)
    {
        \Log::info('邮件发送完毕');
    }
}

class LoggingJobDecorator implements ShouldQueue
{
    protected $job;

    public function __construct($job)
    {
        $this->job = $job;
    }

    public function handle()
    {
        \Log::info('任务开始: ' . get_class($this->job));
        $this->job->handle();
        \Log::info('任务结束: ' . get_class($this->job));
    }
}

dispatch(new LoggingJobDecorator(new SendWelcomeEmail()));