在流明的 AWS SQS 中实施优先级（高、中、低）

Question

如何在 Lumen PHP 中传递 AWS SQS 中的优先级（高、中、低）。

包

"php": "^7.3|^8.0",
"aws/aws-sdk-php": "^3.158",
"laravel/lumen-framework": "^8.0"

queqe.php

<?php

return [
    'default' => env('QUEUE_CONNECTION', 'sqs'),

    'connections' => [
        'sqs' => [
            'driver' => 'sqs',
            'key' => 'key',
            'secret' => 'secret',
            'prefix' => 'https://sqs.us-east-1.amazonaws.com/1234567891452',
            'queue' => '',
            'suffix' => 'dev-test-app',
            'region' => 'us-east-1',
            'after_commit' => false,
        ]
    ],
];

EmailJob.php

<?php

namespace App\Jobs;

use Log;

class EmailJob extends Job
{
    public $queue;

    public function __construct($data)
    {
        $this->queue = $data['queue'];
    }

    public function handle()
    {
        Log::info('Email job '.$this->queue.' is run at start time - '.microtime(true));
    }
}

SmsJob.php

<?php

namespace App\Jobs;

use Log;

class SmsJob extends Job
{
    public $queue;

    public function __construct($data)
    {
        $this->queue = $data['queue'];
    }

    public function handle()
    {
        Log::info('Sms job '.$this->queue.' is run at start time - '.microtime(true));
    }
}

加入队列

Queue::push(new EmailJob(array('queue' => 'email-test')));
Queue::push(new SmsJob(array('queue' => 'sms-test')));

我如何设置电子邮件、短信工作等的优先级（高、中、低）...可能还会添加新工作。

Answer 1

SQS 是 Simple 队列服务 - 不幸的是它没有内置的优先级系统。

您必须创建多个队列。生产者将消息发送到正确的队列（高、中、低），消费者首先轮询高队列中的工作并继续工作。如果高队列为空，则轮询中队列，如果也为空，则轮询低队列。

您也可以使用 Amazon MQ，它是托管的 ActiveMQ 或 RabbitMQ，它们都很可能支持此功能。