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', 'vhost' => env('RABBITMQ_VHOST', '/'), ], ], 'options' => [
'ssl_options' => [
'cafile' => env('RABBITMQ_SSL_CAFILE', null), 'local_cert' => env('RABBITMQ_SSL_LOCALCERT', 'local_key' => env('RABBITMQ_SSL_LOCALKEY', 'verify_peer' => env('RABBITMQ_SSL_VERIFY_PEER', true), 'passphrase' => env('RABBITMQ_SSL_PASSPHRASE', /*
* Set to "horizon" if you wish to use Laravel Horizon.
*/
'worker' => env('RABBITMQ_WORKER', ]
]
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秒队列就执行了