如何在Laravel中获取AWS SQS队列消息及queue:listen报错处理

问题定位步骤 #

• 首先开启详细错误输出：执行队列命令时加-vvv参数，即运行php artisan queue:listen -vvv，同时查看storage/logs/laravel.log日志文件，获取具体的失败报错信息，避免无错误提示无法定位。
• 核对SQS基础配置：首先确认FIFO队列名称必须以.fifo为后缀，你的当前配置SQS_QUEUE=NewTestNotificationQueue无此后缀，属于FIFO队列的强制规则问题；其次核对AWS密钥权限、区域、队列前缀的账号ID是否和AWS控制台一致。
• 确认消息来源：如果SQS中的消息是外部系统推送，而非Laravel自身分发的任务，Laravel默认的队列处理器无法解析非Laravel序列化格式的消息，会直接标记为失败。

解决方法 #

1. 修正FIFO队列配置
   将.env文件中的SQS_QUEUE值修改为AWS控制台对应的FIFO队列完整名称（必须带.fifo后缀），修改后执行php artisan config:clear清空配置缓存生效。

2. 适配外部SQS消息处理逻辑
   如果消息为外部系统推送，无需走Laravel默认的任务序列化解析，直接在任务类中获取原始消息内容处理即可，同时新增失败回调方法记录错误：

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;

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

    /**
     * Create a new job instance.
     *
     * @return void
     */
    public function __construct()
    {
        //
    }

    /**
     * Execute the job.
     *
     * @return void
     */
    public function handle()
    {  
        // 获取SQS原始消息内容
        $rawMessage = $this->job->getRawBody();
        $messageData = json_decode($rawMessage, true);
        // 你的业务处理逻辑写在这里
        \Log::info('获取到SQS消息', ['data' => $messageData]);
    }

    /**
     * 任务失败回调
     */
    public function failed(\Throwable $e)
    {
        \Log::error('SQS任务处理失败', [
            'error_msg' => $e->getMessage(),
            'error_trace' => $e->getTraceAsString()
        ]);
    }
}

3. 校验AWS IAM权限
   确认你使用的AWS密钥对应的IAM用户，拥有目标SQS队列的以下最小权限：

{
    "Version": "2012-10-17",
    "Statement": [
        {
            "Effect": "Allow",
            "Action": [
                "sqs:ReceiveMessage",
                "sqs:DeleteMessage",
                "sqs:GetQueueAttributes"
            ],
            "Resource": "arn:aws:sqs:eu-west-1:465941881099:NewTestNotificationQueue.fifo"
        }
    ]
}

4. 手动验证队列连通性
   可以直接调用AWS SDK拉取消息，确认队列本身可正常访问：

$sqsClient = new \Aws\Sqs\SqsClient([
    'region' => env('AWS_DEFAULT_REGION'),
    'version' => 'latest',
    'credentials' => [
        'key' => env('AWS_ACCESS_KEY_ID'),
        'secret' => env('AWS_SECRET_ACCESS_KEY'),
    ]
]);
$response = $sqsClient->receiveMessage([
    'QueueUrl' => env('SQS_PREFIX') . '/' . env('SQS_QUEUE'),
    'MaxNumberOfMessages' => 1
]);
dd($response->get('Messages'));

内容的提问来源于stack exchange，提问作者Amit Sudhans