首先,我们用composer 下载安装amqp的包
composer require bschmitt/laravel-amqp
下载完毕后
vendor/bschmitt/laravel-amqp/config/amqp.php copy to comfig/amqp.php
修改bootstrap/app.php文件
$app->configure('amqp');
$app->register(Bschmitt\Amqp\LumenServiceProvider::class);
取消$app->withFacades();的注释
在Controller现在可以测试发布消息
Amqp::publish('routing-key','message', ['queue'=>'queue-name']);
测试如下:
image在RabbitMQ的后台中我们已经可以看到数据正在进入队列:
image
网友评论