Homestead環(huán)境でLaravelでRabbitMQを使用するにはどうすればよいですか? Homestead (ubuntu) Laravel で RabbitMQ を使用する方法を次の記事で紹介しますので、ご參考になれば幸いです。

RabbitMQ を使用した Homestead(ubuntu) Laravel

使用法 1: laravel-queue-rabbitmq を単獨(dú)で使用する

Laravel のインストール RabbitMQ:
まず、laravel-queue-rabbitmq でサポートされている laravel のバージョン情報に注意してください:

##962021 年 10 月 5 日ドキュメント106、72021 年 10 月 5 日Documentation1182021 年 4 月 6 日Documentation

インストール コマンドを?qū)g行します:

composer require vladimir-yuldashev/laravel-queue-rabbitmq

インストールが完了するまで待ち、<pre class='brush:php;toolbar:false;'>&amp;#39;connections&amp;#39; =&gt; [ // ... &amp;#39;rabbitmq&amp;#39; =&gt; [ &amp;#39;driver&amp;#39; =&gt; &amp;#39;rabbitmq&amp;#39;, &amp;#39;queue&amp;#39; =&gt; env(&amp;#39;RABBITMQ_QUEUE&amp;#39;, &amp;#39;default&amp;#39;), &amp;#39;connection&amp;#39; =&gt; PhpAmqpLib\Connection\AMQPLazyConnection::class, &amp;#39;hosts&amp;#39; =&gt; [ [ &amp;#39;host&amp;#39; =&gt; env(&amp;#39;RABBITMQ_HOST&amp;#39;, &amp;#39;127.0.0.1&amp;#39;), &amp;#39;port&amp;#39; =&gt; env(&amp;#39;RABBITMQ_PORT&amp;#39;, 5672), &amp;#39;user&amp;#39; =&gt; env(&amp;#39;RABBITMQ_USER&amp;#39;, &amp;#39;guest&amp;#39;), &amp;#39;password&amp;#39; =&gt; env(&amp;#39;RABBITMQ_PASSWORD&amp;#39;, &amp;#39;guest&amp;#39;), &amp;#39;vhost&amp;#39; =&gt; env(&amp;#39;RABBITMQ_VHOST&amp;#39;, &amp;#39;/&amp;#39;), ], ], &amp;#39;options&amp;#39; =&gt; [ &amp;#39;ssl_options&amp;#39; =&gt; [ &amp;#39;cafile&amp;#39; =&gt; env(&amp;#39;RABBITMQ_SSL_CAFILE&amp;#39;, null), &amp;#39;local_cert&amp;#39; =&gt; env(&amp;#39;RABBITMQ_SSL_LOCALCERT&amp;#39;, null), &amp;#39;local_key&amp;#39; =&gt; env(&amp;#39;RABBITMQ_SSL_LOCALKEY&amp;#39;, null), &amp;#39;verify_peer&amp;#39; =&gt; env(&amp;#39;RABBITMQ_SSL_VERIFY_PEER&amp;#39;, true), &amp;#39;passphrase&amp;#39; =&gt; env(&amp;#39;RABBITMQ_SSL_PASSPHRASE&amp;#39;, null), ], &amp;#39;queue&amp;#39; =&gt; [ &amp;#39;job&amp;#39; =&gt; VladimirYuldashev\LaravelQueueRabbitMQ\Queue\Jobs\RabbitMQJob::class, ], ], /* * Set to &quot;horizon&quot; if you wish to use Laravel Horizon. */ &amp;#39;worker&amp;#39; =&gt; env(&amp;#39;RABBITMQ_WORKER&amp;#39;, &amp;#39;default&amp;#39;), ], // ... ],</pre> を

config/queue.php

に追加して、 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

コマンドを?qū)g行してタスク クラスを生成します:

php artisan make:job TestQueue

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

呼び出しキュー関數(shù):

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

キューを開く:

php artisan queue:work

関數(shù)呼び出し後の実行結(jié)果:

Queue消費(fèi)が成功した場合、データベースを確認(rèn)すると、データも書き込まれます。正常に入力します。

使い方 2: laravel-queue-rabbitmq を使用する Rabbitmq-server

ここで疑問が生じますが、方法 1 は普通に使えるのですが、なぜそうする必要があるのでしょうか。これを追加しますrabbitmq-server、rabbitmq-server は何をしますか?
公式説明によると—RabbitMQ は機(jī)能が豊富なマルチプロトコル メッセージング ブローカーであり、サポートしています:

• AMQP 0-9-1

• AMQP 1.0

• ##MQTT 3.1.1

• STOMP 1.0 ～ 1.2

十分な翻訳: RabbitMQ は、機(jī)能が豊富なマルチプロトコル メッセージ ブローカーです。以下のプロトコルをサポートしています。

RabbitMQ 公式 Web サイトの説明によると:

RabbitMQ は多くのオペレーティング システムとクラウド環(huán)境で実行され、最も一般的な言語に対応する幅広い開発者ツールを提供します。

翻訳:

RabbitMQ は多くのオペレーティング システムおよびクラウド環(huán)境で実行され、最も一般的な言語に対応する幅広い開発ツールを提供します。

要約すると: 方法 1 は、laravel キューメソッドを使用します。これは比較的単純で、キュー內(nèi)にあまり多くの概念的なもの (プロデューサーやコンシューマーなど) が関與しません。 .)、rabbitmq-server を使用すると、全員にサーバーが提供されます。言語に関係なく、アカウントとパスワードを使用して、対応する host と port# に接続します。 ## は RabbitMQ を使用できます。同様のものにはEMQX(mqttサーバー)などがあります。また、rabbitmq-server は、キューの関連ステータスを表示して管理を容易にする管理バックグラウンドを提供します。 rabbitmq-server を開始します:

sudo service rabbitmq-server start

キューを開きます:

php artisan queue:work

キューをテストします (コードはメソッド 1 のコードと同じです) 結(jié)果:

注: config/queue の

username と #。 php ##password での接続にデフォルトのゲスト アカウントとパスワードを使用しないでください。そうしないと、エラーが報告されます:

The connection timed out after 3 sec while awaiting incoming data

管理者アカウントとパスワードは、前の記事で追加されています。このアカウントとパスワードを使用するには、管理者アカウントに権限を追加する必要もあります:

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

rabbitmq-server

管理バックグラウンドでユーザー権限を確認(rèn)します:

権限は Can access virtual hosts

/ が表示され、権限がない場合は No Access が表示されます。

その他の使用法

1. laravel-queue-rabbitmq スーパーバイザー デーモン。本質(zhì)的には、キュー ドライバーを変更することであり、使用法は redis と変わりません;

2. これと同様の使用法を使用できます: Java は RabbitMQ を操作し、laravel から離脫し、メソッドを使用します。プロデューサーとコンシューマーの接続;

3. 他の通信プロトコル (MQTT など) へのアクセス、トピックのサブスクライブなど、より複雑な使用法も使用できます。具體的な使用法については、RabbitMQ 公式を參照してください。 Webサイト。

概要

laravel redis queue Supervisor を定期的に使用することで、すでに日常のニーズを満たすことができます。 Qian Lao 氏の「エンジニアリング サイバネティクス」によれば、システムにとって、最新または最先端のテクノロジーが最良であるとは限らず、システムに適しており、システムの安定性を保証するものが最良であると考えられています。

もちろん、その一方で、古いルールに固執(zhí)することはできません。私たちが自分自身と愛するキャリアにふさわしい人間になるためには、スキル パッケージをタイムリーに更新し、改善する必要があります。

関連する推奨事項:

最新の 5 つの Laravel ビデオ チュートリアル

パッケージのバージョン	Laravel バージョン	バグ修正まで

以上がlaravelでRabbitMQを使う方法(Homestead環(huán)境)の詳細(xì)內(nèi)容です。詳細(xì)については、PHP 中國語 Web サイトの他の関連記事を參照してください。