在AWS SQS中实现优先级（高、中、低）（以流明为单位

Question

如何在流明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是一种简单的队列服务--不幸的是，它没有内置的优先级系统。

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

另外，您也可以使用Amazon MQ，它是托管的ActiveMQ或RabbitMQ，这两种MQ很可能都支持这个特性。