這篇文章主要介紹“l(fā)aravel如何使用RabbitMQ”，在日常操作中，相信很多人在laravel如何使用RabbitMQ問題上存在疑惑，小編查閱了各式資料，整理出簡(jiǎn)單好用的操作方法，希望對(duì)大家解答”laravel如何使用RabbitMQ”的疑惑有所幫助！接下來(lái)，請(qǐng)跟著小編一起來(lái)學(xué)習(xí)吧！

創(chuàng)新互聯(lián)建站堅(jiān)持“要么做到，要么別承諾”的工作理念，服務(wù)領(lǐng)域包括：做網(wǎng)站、成都網(wǎng)站制作、企業(yè)官網(wǎng)、英文網(wǎng)站、手機(jī)端網(wǎng)站、網(wǎng)站推廣等服務(wù)，滿足客戶于互聯(lián)網(wǎng)時(shí)代的鋼城網(wǎng)站設(shè)計(jì)、移動(dòng)媒體設(shè)計(jì)的需求，幫助企業(yè)找到有效的互聯(lián)網(wǎng)解決方案。努力成為您成熟可靠的網(wǎng)絡(luò)建設(shè)合作伙伴！

Homestead(ubuntu) + Laravel 使用RabbitMQ

用法1：?jiǎn)为?dú)使用laravel-queue-rabbitmq

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

執(zhí)行安裝命令：

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

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

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

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

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

開啟隊(duì)列：

php artisan queue:work

隊(duì)列消費(fèi)成功，查看數(shù)據(jù)庫(kù)，數(shù)據(jù)也寫入正常。

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

到這里，會(huì)有一個(gè)問題，既然方法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

翻譯過來(lái)就是：RabbitMQ 是一個(gè)功能豐富的多協(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.

翻譯過來(lái)就是：

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

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

啟動(dòng)rabbitmq-server：

sudo service rabbitmq-server start

開啟隊(duì)列：

php artisan queue:work

注意：

在config/queue.php的username和password里不要使用默認(rèn)的guest賬號(hào)密碼來(lái)連接，否則會(huì)報(bào)錯(cuò)：

The connection timed out after 3 sec while awaiting incoming data

前文已經(jīng)添加過admin的賬號(hào)密碼，使用這個(gè)賬號(hào)密碼還需要給admin賬號(hào)添加權(quán)限：

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

在rabbitmq-server管理后臺(tái)查看用戶權(quán)限：

有權(quán)限是Can access virtual hosts顯示/，無(wú)權(quán)限就是顯示No Access。

其他用法

1、laravel-queue-rabbitmq+Supervisor守護(hù)進(jìn)程。本質(zhì)上就是換了個(gè)隊(duì)列驅(qū)動(dòng)，用法和redis無(wú)任何差別；

2、可以使用類似這種用法：java操作RabbitMQ，脫離了laravel，使用連接+生產(chǎn)者+消費(fèi)者的方式；

3、還可以使用更復(fù)雜的用法，例如接入其他通信協(xié)議（例如MQTT），訂閱主題的方式等等。

到此，關(guān)于“l(fā)aravel如何使用RabbitMQ”的學(xué)習(xí)就結(jié)束了，希望能夠解決大家的疑惑。理論與實(shí)踐的搭配能更好的幫助大家學(xué)習(xí)，快去試試吧！若想繼續(xù)學(xué)習(xí)更多相關(guān)知識(shí)，請(qǐng)繼續(xù)關(guān)注創(chuàng)新互聯(lián)網(wǎng)站，小編會(huì)繼續(xù)努力為大家?guī)?lái)更多實(shí)用的文章！