首页 > 解决方案 > Laravel 不同的队列驱动程序使用不同的连接

问题描述

我想问一下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);

标签: laravelmessage-queueamazon-sqssupervisord

解决方案


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


推荐阅读