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 !
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
调用函数后执行结果：
队列消费成功，查看数据库，数据也写入正常。
到这里，会有一个问题，既然方法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 运行在许多操作系统和云环境中，并为大多数流行语言提供了广泛的开发工具。
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 : 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 :<. li>À 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
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!
Quelle est la différence entre RabbitMQ et Kafka
Introduction aux composants Laravel
Introduction au middleware Laravel
Quels sont les modèles de conception utilisés par Laravel ?
Lequel est le plus simple, thinkphp ou laravel ?
Tutoriel Laravel
Comment lire les données d'un fichier Excel en python
emplacement.hash
![[Web front-end] Démarrage rapide de Node.js](https://img.php.cn/upload/course/000/000/067/662b5d34ba7c0227.png)
