扫二维码与项目经理沟通
我们在微信上24小时期待你的声音
解答本文疑问/技术咨询/运营咨询/技术建议/互联网交流
这篇文章主要介绍“laravel如何使用RabbitMQ”,在日常操作中,相信很多人在laravel如何使用RabbitMQ问题上存在疑惑,小编查阅了各式资料,整理出简单好用的操作方法,希望对大家解答”laravel如何使用RabbitMQ”的疑惑有所帮助!接下来,请跟着小编一起来学习吧!
创新互联建站坚持“要么做到,要么别承诺”的工作理念,服务领域包括:做网站、成都网站制作、企业官网、英文网站、手机端网站、网站推广等服务,满足客户于互联网时代的钢城网站设计、移动媒体设计的需求,帮助企业找到有效的互联网解决方案。努力成为您成熟可靠的网络建设合作伙伴!
laravel安装RabbitMQ:
首先注意自己laravel-queue-rabbitmq支持的laravel版本信息:
Package Version | Laravel Version | Bug Fixes Until | |
---|---|---|---|
9 | 6 | October 5th, 2021 | Documentation |
10 | 6, 7 | October 5th, 2021 | Documentation |
11 | 8 | April 6th, 2021 | Documentation |
执行安装命令:
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'), ], // ... ],
并且在config/queue.php
中修改:
//把sync修改为rabbitmq,同理使用redis驱动则修改为redis 'default' => env('QUEUE_CONNECTION', 'sync'), 'default' => env('QUEUE_CONNECTION', 'rabbitmq'), //或者修改.env下QUEUE_CONNECTION=rabbitmq QUEUE_CONNECTION=rabbitmq
执行命令生成任务类:
php artisan make:job TestQueue
修改TestQueue.php
代码:
data = $data; } /** * Execute the job. * * @return void */ public function handle() { // $data = $this->data; UserInfo::query()->firstOrCreate( ["phone" => $data["phone"]], ["name" => $data["name"]] ); } }
调用队列函数:
public function test(Request $request){ $data = ["name" => "李大", "phone" => "12345678901"]; $this->dispatch(new TestQueue($data)); }
开启队列:
php artisan queue:work
队列消费成功,查看数据库,数据也写入正常。
到这里,会有一个问题,既然方法1能够正常使用,为什么还要加入rabbitmq-server
,rabbitmq-server
又是干啥的?
根据官方描述——RabbitMQ is a feature rich, multi-protocol messaging broker. It supports:
AMQP 0-9-1
AMQP 1.0
MQTT 3.1.1
STOMP 1.0 through 1.2
翻译过来就是:RabbitMQ 是一个功能丰富的多协议消息代理。 它支持以下几种协议。
根据RabbitMQ官网的描述:
RabbitMQ runs on many operating systems and cloud environments, and provides a wide range of developer tools for most popular languages.
翻译过来就是:
RabbitMQ 运行在许多操作系统和云环境中,并为大多数流行语言提供了广泛的开发工具。
rabbitmq-server
,为大家提供了一个服务端,不管是什么语言,使用账号、密码连接到相应的host
和port
就能使用RabbitMQ。类似的还有EMQX(mqtt服务端)等等。并且rabbitmq-server
提供了一个管理后台,可以查看队列的相关情况,便于管理。启动rabbitmq-server:
sudo service rabbitmq-server start
开启队列:
php artisan queue:work
在config/queue.php
的username
和password
里不要使用默认的guest账号密码来连接,否则会报错:
The connection timed out after 3 sec while awaiting incoming data
前文已经添加过admin的账号密码,使用这个账号密码还需要给admin账号添加权限:
sudo rabbitmqctl set_permissions -p / admin ".*" ".*" ".*"
在rabbitmq-server
管理后台查看用户权限:
有权限是Can access virtual hosts
显示/
,无权限就是显示No Access
。
1、laravel-queue-rabbitmq+Supervisor守护进程。本质上就是换了个队列驱动,用法和redis无任何差别;
2、可以使用类似这种用法:java操作RabbitMQ,脱离了laravel,使用连接+生产者+消费者的方式;
3、还可以使用更复杂的用法,例如接入其他通信协议(例如MQTT),订阅主题的方式等等。
到此,关于“laravel如何使用RabbitMQ”的学习就结束了,希望能够解决大家的疑惑。理论与实践的搭配能更好的帮助大家学习,快去试试吧!若想继续学习更多相关知识,请继续关注创新互联网站,小编会继续努力为大家带来更多实用的文章!
我们在微信上24小时期待你的声音
解答本文疑问/技术咨询/运营咨询/技术建议/互联网交流