Laravel 不同的队列驱动程序使用不同的连接答案

【问题标题】：Laravel different queue driver usage with different connectionsLaravel 不同的队列驱动程序使用不同的连接
【发布时间】：2020-08-26 14:28:21
【问题描述】：

我想问一下 laravel 5.8 不同的队列驱动使用不同的队列连接。这可能吗？如果您认为是，请检查以下内容。

我正在测试使用 Amazon SQS，同时我还想通过 shiftonelabs/laravel-sqs-fifo-queue 使用 Amazon SQS FIFO。

我的队列配置如下。

'连接'=> [

    'sqs' => [
        'driver' => 'sqs',
        'key' => 'xxxxx',
        'secret' => 'xxxxx',
        'prefix' => 'https://sqs.ap-southeast-1.amazonaws.com/xxxxx/',
        'queue' => 'queue_name_1',
        'region' => 'xxxxx',
    ],

    'sqs-fifo' => [
        'driver' => 'sqs-fifo',
        'key'    => 'xxxxx',
        'secret' => 'xxxxx',
        'prefix' => 'https://sqs.ap-southeast-1.amazonaws.com/xxxxx/',
        'queue'  => 'queue_name_2',
        'region' => 'xxxxx',
        'group' => 'default',
        'deduplicator' => 'unique',
    ],



],

主管配置如下。

[program:laravel-worker-ii]
process_name=%(program_name)s_%(process_num)02d
command=php /var/www/html/test_env/scheduler_test/artisan queue:work sqs sqs-fifo --timeout=30 --tries=3 --sleep=3
autostart=true
autorestart=true
user=root
numprocs=50
redirect_stderr=true
stdout_logfile=/tmp/worker-ii.log

工作控制器
第一份工作

$goodJob = (new DoSomethingGoodJob($data))->onQueue('queue_name_1');
$this->dispatch($goodJob);

第二份工作

$betterJob = (new DoSomethingBetterJob($data))->onQueue('queue_name_2');
$this->dispatch($betterJob);

【问题讨论】：

您是否尝试将相同的作业发送到 2 个不同的队列？预期的结果是什么？
@ChristopheHubert 我想用不同的队列驱动程序使用不同的作业。我更新了配置并从控制器添加了作业调度代码。

标签： laravel message-queue amazon-sqs supervisord

【解决方案1】：

我不确定您要做什么，但主管中提到的连接取决于您分派工作的连接。您发送作业的连接应该是主管配置中提到的连接。

【讨论】：

我已经编辑了如何使用具有不同队列驱动程序的不同队列名称来调度作业。编辑后的版本能解释我想要什么吗？
您提到的配置文件是不同连接的列表，而不是队列。如果你想分派到特定的连接这样做： $goodJob = (new DoSomethingGoodJob($data))->onConnection('sqs-fifo'); $this->dispatch($goodJob);