Homestead ???? Laravel? ?? RabbitMQ? ??? ?????? ?? ???? Homestead(ubuntu) + Laravel? ?? RabbitMQ? ???? ??? ???????. ??? ???? ?????!

Homestead(ubuntu) + RabbitMQ? ???? Laravel

??? 1: laravel-queue-rabbitmq? ??

laravel ?? RabbitMQ:
?? laravel-queue-?? ???? laravel ?? ??? ?????. Rabbitmq:

??? ??	Laravel ??	?? ?? ???
9	6	2021? 10? 5?	??
10	6, 7	2021? 10? 5?	??
11	8	2021? 4? 6?	??

?? ?? ??:

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驅(qū)動則修改為redis
'default' => env('QUEUE_CONNECTION', 'sync'),
'default' => env('QUEUE_CONNECTION', 'rabbitmq'),
//或者修改.env下QUEUE_CONNECTION=rabbitmq
QUEUE_CONNECTION=rabbitmq

執(zhí)行命令生成任務類：

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"]]
        );
    }
}

調(diào)用隊列函數(shù)：

public function test(Request $request){
    $data = ["name" => "李大", "phone" => "12345678901"];
    $this->dispatch(new TestQueue($data));
}

開啟隊列：

php artisan queue:work

調(diào)用函數(shù)后執(zhí)行結(jié)果：

隊列消費成功，查看數(shù)據(jù)庫，數(shù)據(jù)也寫入正常。

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

到這里，會有一個問題，既然方法1能夠正常使用，為什么還要加入rabbitmq-server，rabbitmq-server又是干啥的？
根據(jù)官方描述——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 是一個功能豐富的多協(xié)議消息代理。 它支持以下幾種協(xié)議。

根據(jù)RabbitMQ官網(wǎng)的描述:

RabbitMQ runs on many operating systems and cloud environments, and provides a wide range of developer tools for most popular languages.

翻譯過來就是：

RabbitMQ 運行在許多操作系統(tǒng)和云環(huán)境中，并為大多數(shù)流行語言提供了廣泛的開發(fā)工具。

總結(jié)起來就是：方法1使用的是laravel隊列的使用方法，比較簡單，并沒有涉及到太多隊列當中概念性的東西（例如生產(chǎn)者和消費者等等），而使用rabbitmq-server，為大家提供了一個服務端，不管是什么語言，使用賬號、密碼連接到相應的host和port就能使用RabbitMQ。類似的還有EMQX（mqtt服務端）等等。并且rabbitmq-server提供了一個管理后臺，可以查看隊列的相關情況，便于管理。

啟動rabbitmq-server：

sudo service rabbitmq-server start

開啟隊列：

php artisan queue:work

測試隊列（代碼和方法1代碼一樣）結(jié)果：

注意：

在config/queue.php的username和password里不要使用默認的guest賬號密碼來連接，否則會報錯：

The connection timed out after 3 sec while awaiting incoming data

前文已經(jīng)添加過admin的賬號密碼，使用這個賬號密碼還需要給admin賬號添加權限：

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

在rabbitmq-server管理后臺查看用戶權限：

有權限是Can access virtual hosts顯示/，無權限就是顯示No Accessrrreee

? config/queue.php? ???? config/queue.php?? ?????. >:

rrreee ??? ???? ?? ??? ??: rrreee

TestQueue.php ?? ??:

rrreee

??? ?? ??:

rrreee

??? ??:

rrreee

?? ?? ?? ?? ?:

Queue ?? ??, ?????? ?? ? ????? ???? ?????.

??? 2: laravel-queue-rabbitmq+rabbitmq-server ????

?? ?? 1? ????? ??? ? ??? ? rabbitmq-server? ???? ???? >, rabbitmq-server? ?? ?? ???? ?? ??? ??? RabbitMQ? ??? ??? ?? ???? ??? ??????.

• AMQP 0-9-1

??AMQP 1.0??

??MQTT 3.1.1??

??STOMP 1.0 ~ 1.2??

????? ??? ????: RabbitMQ ??? ??? ?? ???? ??? ??????. ?? ????? ?????. ??????RabbitMQ ?? ????? ??? ???:????RabbitMQ? ??? ?? ??? ???? ???? ???? ?? ?? ???? ??? ?? ???? ??? ??? ?????.??????:????RabbitMQ? ??? ?? ???? ?????. ??? ? ???? ?? ??? ???? ?? ?? ???? ??? ?? ???? ?? ??? ?????. ???????????????, ?? 1? ??? ? ?? ??? ?????, ?? ????? ???? ?(???, ??? ?)? ?? ?? ??? ??? ???? ??? rabbitmq? ?????. -server? ??? ???? ?? ??? ?? ??? ?????. ??? ????? ???? ?? ???? ??? ???? ???. .RabbitMQ. ??? ???? EMQX(mqtt ??) ?? ????. ??? rabbitmq-server? ?? ??? ?? ???? ?? ??? ? ? ?? ?? ??? ?????. ????rabbitmq-server ??: ??rrreee??? ??: ??rrreee??? ???(??? ?? 1? ??) ??: ??????????????????: ???? in config/queue. php ??? ?? ? ????? ?? ??? ??? ????? ???? ???? ???. ??? ??? ??? ?????: ??rrreee????? ?? ? ???? ??? ??????? ? ??? ????? ??????. ?? ??? ??? ??? ???? ???: ??rrreee?? rabbitmq-server ?? ??????? ??? ??? ??????: ??????????? ?? ???? ??? ? ???? ??/, ??? ??? No Access? ?????. ?????????? ???????1.laravel-queue-rabbitmq+Supervisor ??. ????? ? ????? ???? ??? ???? redis? ??? ????. ????2 ??? ??? ???? ??? ? ????. java? laravel ?? ?? + ??? + ??? ??? ???? RabbitMQ? ?????. 3. ?? ?? ????(?: MQTT) ???, ?? ?? ? ?? ??? ???? ??? ?? ????. ???? ???? RabbitMQ ?? ????? ?????. ??????????????laravel+redis queue+Supervisor? ????? ???? ???? ?? ??? ??? ? ????. Qian Lao? "????? ??????"? ??? ???? ??? ?? ?? ?? ??? ??? ???? ???? ???? ???? ???? ?? ??? ?? ? ????. ??????, ??? ??? ??? ? ???, ??? ???? ??? ?? ???? ??? ? ??? ?? ???? ??? ?????? ???? ???. ???????? ??: ???? 5?? Laravel ??? ??????????

? ??? Laravel(Homestead ??)?? RabbitMQ? ???? ??? ?? ?????. ??? ??? PHP ??? ????? ?? ?? ??? ?????!