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秒队列就执行了
本文由:xiasohu168.com 作者:xiaoshu发表,转载请注明来源!