laravel6安装rabbitmq扩展

1.执行composer安装

composer require vladimir-yuldashev/laravel-queue-rabbitmq "10.X" --ignore-platform-reqs

2.配置文件 queue配置文件种加入

'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),
            ],
        ],

        /*
         * Set to "horizon" if you wish to use Laravel Horizon.
         */
        'worker' => env('RABBITMQ_WORKER', 'default'),

    ]
]

3.env配置

QUEUE_DRIVER=rabbitmq
RABBITMQ_HOST=容器ip地址
RABBITMQ_PORT=5672
RABBITMQ_USER=admin
RABBITMQ_PASSWORD=admin
RABBITMQ_VHOST=my_vhost
RABBITMQ_QUEUE=队列名称

修改QUEUE_CONNECTION=rabbitmq

4.生成测试队列任务

php artisan make:job DlTest

...以上代码简略
public function __construct($time)
{
    //echo $time;
    //延迟时间
    $this->delay = $time;
}

/**
 * Execute the job.
 *
 * @return void
 */
public function handle()
{
    echo "执行队列";
}

5.测试加入队列在控制器里执行这个方法

$this->dispatch(new DlTest(10));

6.监听队列执行

php artisan queue:work

7.等待10秒队列就执行了