README

支持策略

只有最新版本将获得新功能。将通过以下方案提供错误修复

安装

您可以通过使用以下命令通过composer安装此包

composer require vladimir-yuldashev/laravel-queue-rabbitmq

此包将自动注册自己。

将连接添加到config/queue.php

'connections' => [
    // ...

    'rabbitmq' => [
    
       '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,
           ],
       ],
   
       /*
        * Set to "horizon" if you wish to use Laravel Horizon.
        */
       'worker' => env('RABBITMQ_WORKER', 'default'),
        
    ],

    // ...    
],

可选配置

可选地将队列选项添加到连接的配置中。为该连接创建的每个队列都将获得这些属性。

当您想优先处理延迟的消息时，可以通过添加额外选项来实现。

• 当省略max-priority时，使用时最大优先级设置为2。

'connections' => [
    // ...

    'rabbitmq' => [
        // ...

        'options' => [
            'queue' => [
                // ...

                'prioritize_delayed' =>  false,
                'queue_max_priority' => 10,
            ],
        ],
    ],

    // ...    
],

当您想通过路由键发布交换的消息时，可以通过添加额外选项来实现。

• 当省略交换时，RabbitMQ将使用amq.direct交换进行路由键。
• 当省略路由键时，默认路由键是队列名称。
• 当在路由键中使用%s时，队列名称将被替换。

注意：当使用带有路由键的交换时，您可能需要自己创建队列的绑定。

'connections' => [
    // ...

    'rabbitmq' => [
        // ...

        'options' => [
            'queue' => [
                // ...

                'exchange' => 'application-x',
                'exchange_type' => 'topic',
                'exchange_routing_key' => '',
            ],
        ],
    ],

    // ...    
],

当您想指示其他进程也处理消息时，Laravel将失败作业存储到数据库中。但是，也许您想指示其他进程也处理消息。当您想指示RabbitMQ将失败消息重新路由到交换或特定队列时，可以通过添加额外选项来实现。

• 当省略交换时，RabbitMQ将使用amq.direct交换进行路由键。
• 当省略路由键时，默认路由键队列名称将被替换为'.failed'。
• 当在路由键中使用%s时，队列名称将被替换。

注意：当使用带有路由键的failed_job交换时，您可能需要自己创建交换/队列的绑定。

'connections' => [
    // ...

    'rabbitmq' => [
        // ...

        'options' => [
            'queue' => [
                // ...

                'reroute_failed' => true,
                'failed_exchange' => 'failed-exchange',
                'failed_routing_key' => 'application-x.%s',
            ],
        ],
    ],

    // ...    
],

使用您自己的RabbitMQJob类

有时您必须处理由另一个应用程序发布的消息。
这些消息可能不会遵循Laravel作业负载模式。这些消息的问题在于，Laravel工作进程无法确定实际作业或类来执行。

您可以通过扩展内置的RabbitMQJob::class并在队列连接配置中定义自己的类来做到这一点。当您在配置中指定job键并使用自己的类名时，从代理检索的每个消息都将由您的类包装。

配置示例

'connections' => [
    // ...

    'rabbitmq' => [
        // ...

        'options' => [
            'queue' => [
                // ...

                'job' => \App\Queue\Jobs\RabbitMQJob::class,
            ],
        ],
    ],

    // ...    
],

您的作业类示例

<?php

namespace App\Queue\Jobs;

use VladimirYuldashev\LaravelQueueRabbitMQ\Queue\Jobs\RabbitMQJob as BaseJob;

class RabbitMQJob extends BaseJob
{

    /**
     * Fire the job.
     *
     * @return void
     */
    public function fire()
    {
        $payload = $this->payload();

        $class = WhatheverClassNameToExecute::class;
        $method = 'handle';

        ($this->instance = $this->resolve($class))->{$method}($this, $payload);

        $this->delete();
    }
}

或者您可能想向负载添加额外属性

<?php

namespace App\Queue\Jobs;

use VladimirYuldashev\LaravelQueueRabbitMQ\Queue\Jobs\RabbitMQJob as BaseJob;

class RabbitMQJob extends BaseJob
{
   /**
     * Get the decoded body of the job.
     *
     * @return array
     */
    public function payload()
    {
        return [
            'job'  => 'WhatheverFullyQualifiedClassNameToExecute@handle',
            'data' => json_decode($this->getRawBody(), true)
        ];
    }
}

Laravel用法

完成配置后，您可以使用Laravel Queue API。如果您已使用其他队列驱动程序，则无需更改其他任何内容。如果您不知道如何使用队列API，请参阅官方Laravel文档：https://laravel.net.cn/docs/queues

Laravel Horizon用法

从8.0版开始，此包默认支持Laravel Horizon。首先安装Horizon，然后将RABBITMQ_WORKER设置为horizon。

Lumen用法

对于Lumen的使用，应在bootstrap/app.php中手动注册服务提供者，如下所示

$app->register(VladimirYuldashev\LaravelQueueRabbitMQ\LaravelQueueRabbitMQServiceProvider::class);

消费消息

有两种方式可以消费消息。

1. queue:work命令，这是Laravel内置的命令。此命令使用basic_get。

2. rabbitmq:consume命令，这是由本包提供的。此命令使用basic_consume，比basic_get性能高约2倍。

测试

使用docker-compose设置RabbitMQ

docker-compose up -d rabbitmq

要运行测试套件，可以使用以下命令

# To run both style and unit tests.
composer test

# To run only style tests.
composer test:style

# To run only unit tests.
composer test:unit

如果您在样式测试中收到任何错误，可以使用以下命令自动修复大部分，如果不是全部问题

composer fix:style

贡献

您可以通过发现错误和开启问题来为此包做出贡献。请添加您创建的拉取请求或问题的包版本。（例如：[5.2] 延迟作业上的致命错误）