Как настроить несколько обменов в laravel-queue-rabbitmq?

Question

Как настроить несколько обменов в laravel-queue-rabbitmq?

Я нашел знаменитую библиотеку для использования RabbitMQ в Laravel.

В конфигурации config/queue.php Я могу указать только один обмен и имя очереди. Поддерживает ли он несколько обменов?

4

laravel laravel-5 rabbitmq laravel-queue laravel-queue-rabbitmq

Источник

user8291684 19 дек '18 в 21:23

2 ответа

Другие вопросы по тегам laravel laravel-5 rabbitmq laravel-queue laravel-queue-rabbitmq

user3914603 13 авг '21 в 14:15 2021-08-13 14:15 · Answer 1 · 2021-08-13 14:15

Для будущих людей, которые будут искать ответ на этот вопрос. Есть один (плохой) способ добавить несколько бирж. Вы должны дублировать соединение rabbitmq с новым обменом, и когда вы захотите опубликовать сообщение на новом обмене, вы просто измените соединение. Это очень уродливый способ, но я не сделал другого. Очередь Laravel не предоставляет метода для изменения обмена, но есть метод onConnectionчем вы помогаете. Вот простой пример

              'conn_one' => [

        'driver' => 'rabbitmq',
        'queue' => env('RABBITMQ_QUEUE', 'default'),
        'connection' => PhpAmqpLib\Connection\AMQPLazyConnection::class,

        'hosts' => [
            [
                'host' => env('RABBITMQ_HOST', '127.0.0.1'),
                'port' => env('RABBITMQ_PORT', 5672),
                'user' => env('RABBITMQ_USER', 'guest'),
                'password' => env('RABBITMQ_PASSWORD', 'guest'),
                'vhost' => env('RABBITMQ_VHOST', '/'),
            ],
        ],

        'options' => [
            'ssl_options' => [
                'cafile' => env('RABBITMQ_SSL_CAFILE', null),
                'local_cert' => env('RABBITMQ_SSL_LOCALCERT', null),
                'local_key' => env('RABBITMQ_SSL_LOCALKEY', null),
                'verify_peer' => env('RABBITMQ_SSL_VERIFY_PEER', true),
                'passphrase' => env('RABBITMQ_SSL_PASSPHRASE', null),
            ],
            'queue' => [
                'job' => VladimirYuldashev\LaravelQueueRabbitMQ\Queue\Jobs\RabbitMQJob::class,
                'exchange' => 'exchange_two',
                'exchange_type' => 'fanout',
            ],
        ],

     ],

    'conn_two' => [
        'driver' => 'rabbitmq',
        'queue' => env('RABBITMQ_QUEUE', 'default'),
        'connection' => PhpAmqpLib\Connection\AMQPLazyConnection::class,

        'hosts' => [
            [
                'host' => env('RABBITMQ_HOST', '127.0.0.1'),
                'port' => env('RABBITMQ_PORT', 5672),
                'user' => env('RABBITMQ_USER', 'guest'),
                'password' => env('RABBITMQ_PASSWORD', 'guest'),
                'vhost' => env('RABBITMQ_VHOST', '/'),
            ],
        ],

        'options' => [
            'ssl_options' => [
                'cafile' => env('RABBITMQ_SSL_CAFILE', null),
                'local_cert' => env('RABBITMQ_SSL_LOCALCERT', null),
                'local_key' => env('RABBITMQ_SSL_LOCALKEY', null),
                'verify_peer' => env('RABBITMQ_SSL_VERIFY_PEER', true),
                'passphrase' => env('RABBITMQ_SSL_PASSPHRASE', null),
            ],
            'queue' => [
                'job' => VladimirYuldashev\LaravelQueueRabbitMQ\Queue\Jobs\RabbitMQJob::class,
                'exchange' => 'exchange_two',
                'exchange_type' => 'fanout',
            ],
        ],
    ],

Использовать

      ExampleJob::dispach($data)->onConnection('conn_one');
ExampleJob::dispach($data)->onConnection('conn_two');

user836895 02 авг '22 в 05:27 2022-08-02 05:27 · Answer 2 · 2022-08-02 05:27

Или другим уродливым способом может быть установка такой конфигурации

      Config::set('queue.connections.rabbitmq.options.queue.exchange', 'exchange_two');

перед отправкой задания на новую биржу. Таким образом, вам не нужно создавать дублирующее соединение, просто задавая новое имя обмена перед отправкой задания на новый обмен.