laravel怎么使用RabbitMQ(Homestead环境)

2022-05-15 0 441

Homestead环境下Laravel怎么使用RabbitMQ?下面本篇文章就来给大家介绍一下Homestead(ubuntu) + Laravel 使用RabbitMQ的方法,希望对大家有所帮助!

laravel怎么使用RabbitMQ(Homestead环境)

Homestead(ubuntu) + Laravel 使用RabbitMQ

用法1:单独使用laravel-queue-rabbitmq

laravel安装RabbitMQ:
首先注意自己laravel-queue-rabbitmq支持的laravel版本信息:

Package Version Laravel Version Bug Fixes Until

96October 5th, 2021Documentation106, 7October 5th, 2021Documentation118April 6th, 2021Documentation

执行安装命令:

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=rabbitmqQUEUE_CONNECTION=rabbitmq

执行命令生成任务类:

php artisan make:job TestQueue

修改TestQueue.php代码:

<?phpnamespace 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

调用函数后执行结果:

laravel怎么使用RabbitMQ(Homestead环境)

队列消费成功,查看数据库,数据也写入正常。

用法2:使用laravel-queue-rabbitmq+rabbitmq-server

到这里,会有一个问题,既然方法1能够正常使用,为什么还要加入rabbitmq-serverrabbitmq-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 运行在许多操作系统和云环境中,并为大多数流行语言提供了广泛的开发工具。

总结起来就是:方法1使用的是laravel队列的使用方法,比较简单,并没有涉及到太多队列当中概念性的东西(例如生产者和消费者等等),而使用rabbitmq-server,为大家提供了一个服务端,不管是什么语言,使用账号、密码连接到相应的hostport就能使用RabbitMQ。类似的还有EMQX(mqtt服务端)等等。并且rabbitmq-server提供了一个管理后台,可以查看队列的相关情况,便于管理。

启动rabbitmq-server:

sudo service rabbitmq-server start

开启队列:

php artisan queue:work

测试队列(代码和方法1代码一样)结果:

laravel怎么使用RabbitMQ(Homestead环境)

laravel怎么使用RabbitMQ(Homestead环境)

注意:

config/queue.phpusernamepassword里不要使用默认的guest账号密码来连接,否则会报错:

The connection timed out after 3 sec while awaiting incoming data

前文已经添加过admin的账号密码,使用这个账号密码还需要给admin账号添加权限:

sudo rabbitmqctl set_permissions -p / admin ".*" ".*" ".*"

rabbitmq-server管理后台查看用户权限:

laravel怎么使用RabbitMQ(Homestead环境)

有权限是Can access virtual hosts显示/,无权限就是显示No Access

其他用法

1、laravel-queue-rabbitmq+Supervisor守护进程。本质上就是换了个队列驱动,用法和redis无任何差别;

2、可以使用类似这种用法:java操作RabbitMQ,脱离了laravel,使用连接+生产者+消费者的方式;

3、还可以使用更复杂的用法,例如接入其他通信协议(例如MQTT),订阅主题的方式等等,具体用法可以参考RabbitMQ官网。

总结

常规使用laravel+redis队列+Supervisor的方式已经能满足我们日常需要。按照钱老的《工程控制论》的说法就是——一个系统,最新或者最先进的技术未必是最优的,适合系统的、确保系统稳定的才是最好的。

当然反过来我们也不能墨守成规,自己的技能包也要适时的更新和进步,这样才能无愧于自己,无愧于自己热爱的事业。

相关推荐:最新的五个Laravel视频教程

收藏 (0) 打赏

感谢您的支持,我会继续努力的!

打开微信/支付宝扫一扫,即可进行扫码打赏哦,分享从这里开始,精彩与您同在
点赞 (0)

【声明:根据2013年1月30日《计算机软件保护条例》2次修订第17条规定: 为了学习和研究软件内含的设计思想和原理,通过安装、显示、传输或者存 储软件等方式使用软件的,可以不经软件著作权人许可,不向其支付报酬! 鉴于此,也希望大家按此说明研究软件!】
本站所有源码尽量保证原汁原味,如有特殊情况会作出声明及标注,网站资源不做任何二次加密(原版加密除外,不影响程序使用的不会做解密处理),方便您更好的学习参考。 在您的能力范围内,为了大环境的良性发展,请尽可能的选择正版资源。如若本站内容侵犯了原著者的合法权益,可联系我们进行处理。

即刻码站__国内靠谱的站长资源下载平台 php教程 laravel怎么使用RabbitMQ(Homestead环境) https://www.jike1995.com/36023.html

常见问题
  • 本站所有资源版权均属于原作者所有,这里所提供资源均只能用于参考学习用,请勿直接商用。若由于商用引起版权纠纷,一切责任均由使用
查看详情
  • 最常见的情况是下载不完整: 可对比下载完压缩包的与网盘上的容量,若小于网盘提示的容量则是这个原因。这是浏览器下载的bug,建议用百度
查看详情

相关文章

发表评论
暂无评论
官方客服团队

为您解决烦忧 - 24小时在线 专业服务