Laravel对接AWS SQS时如何读取已入队任务的payload等队列消息内容

1. 核心错误点说明 #

• 你在handle()方法中调用Queue::pop()->payload()的逻辑错误：Queue::pop()会主动从SQS队列中拉取下一条待处理的新任务，并非当前正在执行的任务实例，还会直接将该新任务从SQS待处理队列移除，极端情况会导致任务丢失。
• 你自定义了protected $job属性存储业务数据，覆盖了InteractsWithQueue trait内置的同名系统属性，这是你无法读取任务原生payload的核心原因。
• json_encode失败是因为Laravel原生任务payload包含对象、资源类结构，存在循环引用或者无法序列化的字段，强制序列化会报错。

2. 正确实现代码 #

<?php

namespace App\Jobs;
use App\CookieXrayConsentLog;
use App\CookieXrayScript;
use Carbon\Carbon;
use Illuminate\Bus\Queueable;
use Illuminate\Queue\SerializesModels;
use Illuminate\Queue\InteractsWithQueue;
use Illuminate\Contracts\Queue\ShouldQueue;
use Illuminate\Foundation\Bus\Dispatchable;
use Illuminate\Support\Facades\DB;
use Illuminate\Support\Facades\Log;
use Illuminate\Support\Facades\Storage;

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

    // 重命名自定义属性，避免覆盖系统内置的$job属性
    protected $custom_data;

    // 任务最大重试次数
    public $tries = 5;

    /**
     * 创建新任务实例
     *
     * @return void
     */
    public function __construct(array $data)
    {
        $this->custom_data = $data;
        $this->onConnection('sqs');
        $this->onQueue('dev_consent');
    }

    /**
     * 执行任务
     *
     * @return void
     */
    public function handle()
    {
        // 1. 获取Laravel格式化后的当前任务完整Payload（数组格式）
        $payload = $this->job->payload();
        Log::info('当前任务完整Payload：', $payload);

        // 2. 获取SQS原生MessageBody
        $sqsMessage = $this->job->getSqsMessage();
        Log::info('SQS原生MessageBody：', [$sqsMessage['Body']]);

        // 3. 获取SQS原生消息属性
        Log::info('SQS消息属性：', [$sqsMessage['Attributes'] ?? []]);

        // 4. 打印你自定义传入的业务数据
        Log::info('自定义业务数据：', $this->custom_data);
    }
}

3. 使用说明 #

日志打印不要将数组拼接到字符串后，直接传入Log类的第二个参数，Laravel会自动格式化输出内容，不会出现序列化报错问题。

内容的提问来源于stack exchange，提问作者Usman Ali