laravel 队列之Homestead(ubuntu)下laravel使用RabbitMQ——实战篇

  • 前言

    最之前已经写了RabbitMQ服务端的配置,详情可查看这篇文章——Laravel 队列之Homestead(ubuntu)下laravel使用RabbitMQ——服务器配置篇
    接下来就是如何使用RabbitMQ

  • 参考资料

    感谢所有文章作者!
    laravel-queue-rabbitmq
    laravel + rabbitmq
    世上最全的RabbitMQ-总结
    RabbitMQ中 exchange、route、queue的关系

  • 用法1:单独使用laravel-queue-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代码:

<?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
  • 调用函数后执行结果:

Homestead(ubuntu)下laravel使用RabbitMQ——实战篇

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

  • 用法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代码一样)结果:

Homestead(ubuntu)下laravel使用RabbitMQ——实战篇

Homestead(ubuntu)下laravel使用RabbitMQ——实战篇

注意:

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 队列之Homestead(ubuntu)下laravel使用RabbitMQ——实战篇

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

  • 其他用法

    1、laravel-queue-rabbitmq+Supervisor守护进程。本质上就是换了个队列驱动,用法和redis无任何差别;
    2、可以使用类似这种用法:java操作RabbitMQ,脱离了laravel,使用连接+生产者+消费者的方式;
    3、还可以使用更复杂的用法,例如接入其他通信协议(例如MQTT),订阅主题的方式等等,具体用法可以参考RabbitMQ官网。

  • 总结

    常规使用laravel+redis队列+Supervisor的方式已经能满足我们日常需要。按照钱老的《工程控制论》的说法就是——一个系统,最新或者最先进的技术未必是最优的,适合系统的、确保系统稳定的才是最好的。
    当然反过来我们也不能墨守成规,自己的技能包也要适时的更新和进步,这样才能无愧于自己,无愧于自己热爱的事业。

本作品采用《CC 协议》,转载必须注明作者和本文链接
《L04 微信小程序从零到发布》
从小程序个人账户申请开始,带你一步步进行开发一个微信小程序,直到提交微信控制台上线发布。
《G01 Go 实战入门》
从零开始带你一步步开发一个 Go 博客项目,让你在最短的时间内学会使用 Go 进行编码。项目结构很大程度上参考了 Laravel。
讨论数量: 0
(= ̄ω ̄=)··· 暂无内容!

讨论应以学习和精进为目的。请勿发布不友善或者负能量的内容,与人为善,比聪明更重要!