Comment utiliser RabbitMQ dans Laravel (environnement Homestead)

Comment utiliser RabbitMQ avec Laravel dans l'environnement Homestead ? L'article suivant vous présentera comment utiliser RabbitMQ avec Homestead (ubuntu) + Laravel. J'espère qu'il vous sera utile !

Homestead (ubuntu) + Laravel utilisant RabbitMQ

Utilisation 1 : utilisez laravel-queue-rabbitmq seul

installation de laravel RabbitMQ :
Faites d'abord attention aux informations sur la version de laravel prises en charge par laravel-queue- Rabbitmq :

Version du package	Version Laravel	Corrections de bugs jusqu'au
9	6	5 octobre 2021	Documentation
10	6, 7	5 octobre 2021	Documentation
11	8	6 avril 2021	Documentation

Exécutez la commande d'installation :

composer require vladimir-yuldashev/laravel-queue-rabbitmq

Attendez la fin de l'installation et ajoutez : 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

调用函数后执行结果：

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

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

到这里，会有一个问题，既然方法1能够正常使用，为什么还要加入rabbitmq-server，rabbitmq-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，为大家提供了一个服务端，不管是什么语言，使用账号、密码连接到相应的host和port就能使用RabbitMQ。类似的还有EMQX（mqtt服务端）等等。并且rabbitmq-server提供了一个管理后台，可以查看队列的相关情况，便于管理。

启动rabbitmq-server：

sudo service rabbitmq-server start

开启队列：

php artisan queue:work

测试队列（代码和方法1代码一样）结果：

注意：

在config/queue.php的username和password里不要使用默认的guest账号密码来连接，否则会报错：

The connection timed out after 3 sec while awaiting incoming data

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

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

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

有权限是Can access virtual hosts显示/，无权限就是显示No Accessrrreee

à config/queue.php et modifiez-le dans config/queue.php :

rrreeeExécuter la commande pour générer la classe de tâches : rrreee

Modifier le code TestQueue.php :

rrreee

Appeler la fonction file d'attente :

rrreee

Ouvrir la file d'attente :

rrreee

Résultat de l'exécution après avoir appelé la fonction :

File d'attente La consommation est réussie, vérifiez la base de données et les données sont écrites normalement.

Utilisation 2 : Utilisation de laravel-queue-rabbitmq+rabbitmq-server

À ce stade, il y aura une question puisque la méthode 1 peut être utilisée normalement, pourquoi devrions-nous ajouter rabbitmq-server, rabbitmq-server ? Selon la description officielle - RabbitMQ est un courtier de messagerie multiprotocole riche en fonctionnalités. Il prend en charge :

• AMQP 0-9-1

<. li>

🎜AMQP 1.0🎜

🎜MQTT 3.1.1🎜

🎜STOMP 1.0 à 1.2🎜

🎜La traduction est : RabbitMQ est un courtier de messages multiprotocole riche en fonctionnalités. Il prend en charge les protocoles suivants. 🎜🎜🎜Selon la description sur le site officiel de RabbitMQ :🎜🎜RabbitMQ fonctionne sur de nombreux systèmes d'exploitation et environnements cloud, et fournit une large gamme d'outils de développement pour les langages les plus populaires.🎜🎜La traduction est :🎜🎜RabbitMQ fonctionne sur de nombreux systèmes d'exploitation environnement de systèmes et d'environnements cloud et fournit une large gamme d'outils de développement pour les langages les plus populaires. 🎜🎜🎜🎜🎜Pour résumer : la méthode 1 utilise la méthode d'utilisation de la file d'attente laravel, qui est relativement simple et n'implique pas trop d'éléments conceptuels dans la file d'attente (comme les producteurs et les consommateurs, etc.), et utilise rabbitmq -server fournit un serveur pour tout le monde. Quelle que soit la langue, vous pouvez l'utiliser en vous connectant à l'hôte et au port correspondants à l'aide de votre compte et de votre mot de passe. .LapinMQ. Les fichiers similaires incluent EMQX (serveur mqtt), etc. Et rabbitmq-server fournit un arrière-plan de gestion où vous pouvez afficher l'état pertinent de la file d'attente pour une gestion facile. 🎜🎜Démarrez Rabbitmq-server : 🎜rrreee🎜Ouvrez la file d'attente : 🎜rrreee🎜Testez la file d'attente (le code est le même que la méthode 1) Résultat : 🎜🎜🎜🎜🎜🎜🎜🎜Remarque : 🎜🎜Dans config/queue. phpN'utilisez pas le compte invité et le mot de passe par défaut dans nom d'utilisateur et mot de passe pour vous connecter, sinon une erreur sera signalée : 🎜rrreee🎜Le compte administrateur et le mot de passe ont été ajoutés précédemment, utilisez ce compte et ce mot de passe. Vous devez également ajouter des autorisations au compte administrateur : 🎜rrreee🎜 Vérifiez les autorisations de l'utilisateur dans l'arrière-plan de gestion du rabbitmq-server : 🎜🎜🎜🎜Si vous avez l'autorisation , Peut accéder aux hôtes virtuelsafficher/, s'il n'y a aucune autorisation, Aucun accès sera affiché. 🎜🎜🎜🎜Autres utilisations🎜🎜1. laravel-queue-rabbitmq+Démon Superviseur. Essentiellement, il s'agit de changer le pilote de file d'attente, et l'utilisation n'est pas différente de redis ; 🎜🎜2 Vous pouvez utiliser une utilisation similaire à celle-ci : java exploite RabbitMQ, sans laravel, en utilisant la méthode connexion + producteur + consommateur ; 3. Vous pouvez également utiliser une utilisation plus complexe, comme accéder à d'autres protocoles de communication (tels que MQTT), vous abonner à des sujets, etc. Pour une utilisation spécifique, veuillez vous référer au site officiel de RabbitMQ. 🎜🎜🎜🎜Résumé🎜🎜L'utilisation régulière de laravel+redis queue+Supervisor peut déjà répondre à nos besoins quotidiens. Selon "Engineering Cybernetics" de Qian Lao - pour un système, la technologie la plus récente ou la plus avancée n'est peut-être pas la meilleure. Ce qui convient au système et garantit la stabilité du système est le meilleur. 🎜🎜Bien sûr, à l'inverse, nous ne pouvons pas nous en tenir aux anciennes règles. Nos ensembles de compétences doivent être mis à jour et améliorés en temps opportun, afin que nous puissions être dignes de nous-mêmes et de la carrière que nous aimons. 🎜🎜🎜Recommandations associées : 🎜Les cinq derniers didacticiels vidéo Laravel🎜🎜🎜

Ce qui précède est le contenu détaillé de. pour plus d'informations, suivez d'autres articles connexes sur le site Web de PHP en chinois!