laravel怎么使用RabbitMQ(Homestead环境)
时间:2022-02-14 14:04
Homestead环境下Laravel怎么使用RabbitMQ?下面本篇文章就来给大家介绍一下Homestead(ubuntu) + Laravel 使用RabbitMQ的方法,希望对大家有所帮助! laravel安装RabbitMQ: 执行安装命令: 等待安装完成后在 并且在 执行命令生成任务类: 修改 调用队列函数: 开启队列: 调用函数后执行结果: 队列消费成功,查看数据库,数据也写入正常。 到这里,会有一个问题,既然方法1能够正常使用,为什么还要加入 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: 开启队列: 测试队列(代码和方法1代码一样)结果: 在 前文已经添加过admin的账号密码,使用这个账号密码还需要给admin账号添加权限: 在 有权限是 1、laravel-queue-rabbitmq+Supervisor守护进程。本质上就是换了个队列驱动,用法和redis无任何差别; 2、可以使用类似这种用法:java操作RabbitMQ,脱离了laravel,使用连接+生产者+消费者的方式; 3、还可以使用更复杂的用法,例如接入其他通信协议(例如MQTT),订阅主题的方式等等,具体用法可以参考RabbitMQ官网。 常规使用laravel+redis队列+Supervisor的方式已经能满足我们日常需要。按照钱老的《工程控制论》的说法就是——一个系统,最新或者最先进的技术未必是最优的,适合系统的、确保系统稳定的才是最好的。 当然反过来我们也不能墨守成规,自己的技能包也要适时的更新和进步,这样才能无愧于自己,无愧于自己热爱的事业。 相关推荐:最新的五个Laravel视频教程 以上就是laravel怎么使用RabbitMQ(Homestead环境)的详细内容,更多请关注gxlsystem.com其它相关文章!Homestead(ubuntu) + Laravel 使用RabbitMQ
用法1:单独使用laravel-queue-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
代码:<?php
namespace App\Jobs;
use App\Models\UserInfo;
use Illuminate\Bus\Queueable;
use Illuminate\Contracts\Queue\ShouldBeUnique;
use Illuminate\Contracts\Queue\ShouldQueue;
use Illuminate\Foundation\Bus\Dispatchable;
use Illuminate\Queue\InteractsWithQueue;
use Illuminate\Queue\SerializesModels;
class TestQueue implements ShouldQueue
{
use Dispatchable, InteractsWithQueue, Queueable, SerializesModels;
private $data;
/**
* Create a new job instance.
*
* @return void
*/
public function __construct($data)
{
//
$this->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
用法2:使用laravel-queue-rabbitmq+rabbitmq-server
rabbitmq-server
,rabbitmq-server
又是干啥的?
根据官方描述——RabbitMQ is a feature rich, multi-protocol messaging broker. It supports:总结起来就是:方法1使用的是laravel队列的使用方法,比较简单,并没有涉及到太多队列当中概念性的东西(例如生产者和消费者等等),而使用
rabbitmq-server
,为大家提供了一个服务端,不管是什么语言,使用账号、密码连接到相应的host
和port
就能使用RabbitMQ。类似的还有EMQX(mqtt服务端)等等。并且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
sudo rabbitmqctl set_permissions -p / admin ".*" ".*" ".*"
rabbitmq-server
管理后台查看用户权限:Can access virtual hosts
显示/
,无权限就是显示No Access
。其他用法
总结