Laravel与AWS SQS集成：深入理解队列作业负载与数据访问

// 原始代码片段 (存在问题)
class QueueCookieConsent implements ShouldQueue
{
    protected $job; // 属性名可能引起混淆

    public function __construct(array $data)
    {
        $this->job = $data; // 将自定义数据赋值给 $this->job
        $this->onConnection('sqs');
        $this->onQueue('dev_consent');
    }

    public function handle()
    {
        // 尝试访问自定义数据
        Log::info('job => ' .' This --- '. json_encode($this->job));
        // ...
    }
}

<?php

namespace App\Jobs;

use Illuminate\Bus\Queueable;
use Illuminate\Contracts\Queue\ShouldQueue;
use Illuminate\Foundation\Bus\Dispatchable;
use Illuminate\Queue\InteractsWithQueue;
use Illuminate\Queue\SerializesModels;
use Illuminate\Support\Facades\Log;

class QueueCookieConsent implements ShouldQueue
{
    use Dispatchable, InteractsWithQueue, Queueable, SerializesModels;

    /**
     * 存储通过构造函数传入的自定义数据。
     *
     * @var array
     */
    protected $consentData; // 更清晰的属性名

    /**
     * 最大重试次数。
     *
     * @var int
     */
    public $tries = 5;

    /**
     * 创建一个新的作业实例。
     *
     * @param array $data 传入作业的自定义数据。
     * @return void
     */
    public function __construct(array $data)
    {
        $this->consentData = $data; // 将自定义数据存储在 $this->consentData
        $this->onConnection('sqs');
        $this->onQueue('dev_consent');
    }

    /**
     * 执行作业。
     *
     * @return void
     */
    public function handle()
    {
        // 访问自定义数据
        Log::info('Custom Job Data: ' . json_encode($this->consentData));

        // ... 使用 $this->consentData 进行业务逻辑处理 ...
    }
}

<?php

namespace App\Jobs;

use Illuminate\Bus\Queueable;
use Illuminate\Contracts\Queue\ShouldQueue;
use Illuminate\Foundation\Bus\Dispatchable;
use Illuminate\Queue\InteractsWithQueue;
use Illuminate\Queue\SerializesModels;
use Illuminate\Support\Facades\Log;
use Illuminate\Queue\Jobs\Job as BaseJob; // 引入并别名，避免与潜在的自定义Job类名冲突

class QueueCookieConsent implements ShouldQueue
{
    use Dispatchable, InteractsWithQueue, Queueable, SerializesModels;

    protected $consentData;
    public $tries = 5;

    public function __construct(array $data)
    {
        $this->consentData = $data;
        $this->onConnection('sqs');
        $this->onQueue('dev_consent');
    }

    /**
     * 执行作业。
     *
     * @param BaseJob $job 当前正在执行的队列作业实例。
     * @return void
     */
    public function handle(BaseJob $job) // 通过类型提示获取底层Job实例
    {
        // 1. 访问自定义数据
        Log::info('Custom Job Data: ' . json_encode($this->consentData));

        // 2. 访问原始队列负载 (Raw Queue Payload)
        // $job->payload() 返回一个数组，其中包含序列化的作业类、UUID、displayName、data等
        $rawPayload = $job->payload();
        Log::info('Raw Queue Payload: ' . json_encode($rawPayload));

        // 您可以从原始负载中提取特定信息
        Log::info('Job UUID from Payload: ' . ($rawPayload['uuid'] ?? 'N/A'));
        Log::info('Job Name from Payload: ' . ($rawPayload['displayName'] ?? 'N/A'));
        Log::info('Job Data from Raw Payload (serialized properties): ' . json_encode($rawPayload['data'] ?? 'N/A'));

        // 3. 访问其他作业元数据
        Log::info('Job Attempts: ' . $job->attempts()); // 获取当前重试次数

        // ... 您的业务逻辑 ...
    }
}