


Résolvez les défis de la consommation de messages RabbitMQ à l'aide du compositeur
Apr 18, 2025 am 09:15 AMDans le développement de projets, je dois consommer des messages à partir de la file d'attente de messages RabbitMQ et exécuter différentes logiques de traitement en fonction du contenu du message, et enfin stocker les résultats de traitement dans MySQL et ElasticSearch. Ce processus semble simple, mais il est plein de défis dans la pratique. Tout d'abord, le message dans la file d'attente de messages ne contient que id
dans MySQL et quelques informations supplémentaires, ce qui signifie que je dois lire les détails de MySQL avant le traitement et le stockage. De plus, différents projets peuvent avoir des exigences de logique de traitement et de stockage différentes, ce qui rend la réutilisabilité et la maintenabilité du code très importantes.
Pour résoudre ces problèmes, j'ai choisi d'utiliser la bibliothèque mysic/phpamqplib-consumer
. Cette bibliothèque fournit un cadre flexible qui me permet de personnaliser la consommation de messages et le traitement de la logique en fonction des différents besoins du projet. Voici les étapes à installer et à configurer cette bibliothèque à l'aide du compositeur:
-
Installation de la bibliothèque : L'installation de
mysic/phpamqplib-consumer
via Composer est très simple, il suffit de l'exécuter sur la ligne de commande:<code>composer require mysic/phpamqplib-consumer</code>
-
Configurer la structure du projet : Une fois l'installation terminée, organisez le code de projet en fonction de la structure du répertoire de la bibliothèque. Les fichiers et classes de base sont situés dans
core/
répertoire, tandis que la logique métier spécifique de chaque projet est placée dans le dossier correspondant soustask/
répertoire. Par exemple:<code>/ core/ Db.php Dispatcher.php MqConnector.php Processor.php Storage.php task/ project_1/ config/ processor/ storage/ project_n/ config/ processor/ storage/ run.php</code>
-
Fichier de configuration : Dans le dossier
config/
dans chaque répertoire de projet, configurez les paramètres pertinents de la source de données, de la file d'attente de messages et du stockage de données. Par exemple:<code>config/ db.php messageQueue.php storage.php</code>
-
Logique de traitement d'écriture : dans
processor/
dossier, écrivez une logique de traitement de message spécifique. Par exemple, pour la logique qui gère le stockage des documents dans Elasticsearch, il peut être implémenté dansDocument.php
:<code class="php">// Document.php class Document extends Processor { public function process($message) { // 從MySQL中讀取詳細(xì)信息$data = $this->db->fetch($message['id']); // 處理數(shù)據(jù)并存儲(chǔ)到Elasticsearch $this->storage->save($data, $message['extra']); } }</code>
-
Run Consumer : Enfin, démarrez le consommateur de messages via le fichier
run.php
, en spécifiant le nom du projet, le nom du processeur et le nom de stockage:<code>php run.php project_name processor_name storage_name</code>
Après avoir utilisé la bibliothèque mysic/phpamqplib-consumer
, j'ai pu facilement gérer et étendre la logique de consommation de messages. Sa conception modulaire me permet d'ajouter de nouveaux processeurs et de nouveaux processeurs en fonction des besoins de différents projets, améliorant considérablement la maintenabilité et la réutilisabilité du code. De plus, la classe Dispatcher
fournie par la bibliothèque peut gérer efficacement la distribution et le traitement des messages, garantissant la stabilité et l'efficacité de la file d'attente de messages.
En général, mysic/phpamqplib-consumer
résout non seulement le problème de consommation de messages RabbitMQ rencontré dans mon projet, mais fournit également une base solide pour une expansion future. Si vous traitez également des besoins de consommation de files d'attente de messages similaires, vous pourriez aussi bien essayer cette bibliothèque, cela vous aidera à obtenir deux fois le résultat avec la moitié de l'effort.
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!

Outils d'IA chauds

Undress AI Tool
Images de déshabillage gratuites

Undresser.AI Undress
Application basée sur l'IA pour créer des photos de nu réalistes

AI Clothes Remover
Outil d'IA en ligne pour supprimer les vêtements des photos.

Clothoff.io
Dissolvant de vêtements AI

Video Face Swap
échangez les visages dans n'importe quelle vidéo sans effort grace à notre outil d'échange de visage AI entièrement gratuit?!

Article chaud

Outils chauds

Bloc-notes++7.3.1
éditeur de code facile à utiliser et gratuit

SublimeText3 version chinoise
Version chinoise, très simple à utiliser

Envoyer Studio 13.0.1
Puissant environnement de développement intégré PHP

Dreamweaver CS6
Outils de développement Web visuel

SublimeText3 version Mac
Logiciel d'édition de code au niveau de Dieu (SublimeText3)

Sujets chauds

MySQLDump est un outil commun pour effectuer des sauvegardes logiques des bases de données MySQL. Il génère des fichiers SQL contenant des instructions de création et d'insertion pour reconstruire la base de données. 1. Il ne sauvegarde pas le fichier d'origine, mais convertit la structure de la base de données et le contenu en commandes SQL portables; 2. Il convient aux petites bases de données ou à la récupération sélective et ne convient pas à la récupération rapide des données de niveau TB; 3. 4. Utilisez la commande MySQL pour importer pendant la récupération et peut désactiver les vérifications des clés étrangères pour améliorer la vitesse; 5. Il est recommandé de tester régulièrement la sauvegarde, d'utiliser la compression et de régler automatiquement.

Lorsque vous utilisez un compositeur dans un environnement de production, vous devez prêter attention à la sécurité, à la stabilité et aux performances. 1. Utilisez Composerinstall-no-DEV pour réduire les dépendances de développement inutiles et réduire les risques d'environnement en ligne; 2. Soumettez et comptez toujours sur Composer.LOCK Fichiers pour assurer la cohérence de la version et éviter d'utiliser des mises à jour pendant le déploiement; 3. 4. Permettre à APCU d'accélérer le chargement automatique pour améliorer les performances, en particulier adapté aux services de concurrence élevés, tout en faisant attention à l'unicité de l'espace de noms pour éviter les conflits de cache.

MySQL prend en charge le traitement des transactions et utilise le moteur de stockage InNODB pour garantir la cohérence et l'intégrité des données. 1. Les transactions sont un ensemble d'opérations SQL, soit tous réussissent ou ne parviennent pas à reculer; 2. Les attributs acides comprennent l'atomicité, la cohérence, l'isolement et la persistance; 3. Les déclarations qui contr?lent manuellement les transactions sont StartTransaction, Commit and Rollback; 4. Les quatre niveaux d'isolement incluent la lecture non engagée, la lecture soumise, la lecture reproductible et la sérialisation; 5. Utilisez correctement les transactions pour éviter le fonctionnement à long terme, désactiver les validations automatiques et gérer raisonnablement les verrous et les exceptions. Grace à ces mécanismes, MySQL peut obtenir une forte fiabilité et un contr?le simultané.

Les problèmes de règles de jeu de caractères et de tri sont courants lors de la migration multiplateforme ou du développement multi-personnes, entra?nant un code brouillé ou une requête incohérente. Il existe trois solutions principales: d'abord, vérifiez et unifiez le jeu de caractères de la base de données, de la table et des champs vers UTF8MB4, affichez via ShowCreateDatabase / Table, et modifiez-le avec une instruction alter; Deuxièmement, spécifiez le jeu de caractères UTF8MB4 lorsque le client se connecte et le définissez dans les paramètres de connexion ou exécutez SetNames; Troisièmement, sélectionnez les règles de tri raisonnablement et recommandez d'utiliser UTF8MB4_UNICODE_CI pour assurer la précision de la comparaison et du tri, et spécifiez ou modifiez-la via ALTER lors de la construction de la bibliothèque et du tableau.

Pour configurer la réplication ma?tre-esclave asynchrone pour MySQL, suivez ces étapes: 1. Préparez le serveur ma?tre, activez les journaux binaires et définissez un serveur unique, créez un utilisateur de réplication et enregistrez l'emplacement du journal actuel; 2. Utilisez MySQLDump pour sauvegarder les données de la bibliothèque ma?tre et l'importez-les au serveur esclave; 3. Configurez le serveur-ID et le log-log du serveur esclave, utilisez la commande Changemaster pour vous connecter à la bibliothèque ma?tre et démarrer le thread de réplication; 4. Vérifiez les problèmes communs, tels que le réseau, les autorisations, la cohérence des données et les conflits d'auto-augmentation, et surveiller les retards de réplication. Suivez les étapes ci-dessus pour vous assurer que la configuration est terminée correctement.

La fa?on la plus directe de se connecter à la base de données MySQL consiste à utiliser le client de la ligne de commande. Entrez d'abord le nom d'utilisateur MySQL-U -P et entrez correctement le mot de passe pour entrer l'interface interactive; Si vous vous connectez à la base de données distante, vous devez ajouter le paramètre -H pour spécifier l'adresse h?te. Deuxièmement, vous pouvez directement passer à une base de données spécifique ou exécuter des fichiers SQL lors de la connexion, tels que le nom de la base de données MySQL-U Username-P ou le nom de la base de données MySQL-U Username-P-P

Le réglage des jeux de caractères et des règles de collation dans MySQL est crucial, affectant le stockage des données, l'efficacité de la requête et la cohérence. Premièrement, le jeu de caractères détermine la gamme de caractères storable, telle que UTF8MB4 prend en charge les chinois et les emojis; Les règles de tri contr?lent la méthode de comparaison des caractères, telle que UTF8MB4_UNICODE_CI est sensible à la casse, et UTF8MB4_BIN est une comparaison binaire. Deuxièmement, le jeu de caractères peut être défini à plusieurs niveaux de serveur, de base de données, de table et de colonne. Il est recommandé d'utiliser UTF8MB4 et UTF8MB4_UNICODE_CI de manière unifiée pour éviter les conflits. En outre, le problème du code brouillé est souvent causé par des jeux de caractères incohérents de connexions, de stockage ou de terminaux de programme, et doit être vérifié par calque par calque et définir uniformément. De plus, les ensembles de caractères doivent être spécifiés lors de l'exportation et de l'importation pour éviter les erreurs de conversion

Pour vérifier si le compositeur est installé correctement, exécutez d'abord la commande Composer - Version pour afficher les informations de version. Si le numéro de version s'affiche, cela signifie qu'il est installé. Deuxièmement, utilisez la commande ComposerDiagnosmose pour détecter les problèmes de configuration et vous assurer que les variables et les autorisations d'environnement sont normales. Enfin, essayez de vérifier l'intégrité fonctionnelle via le package d'installation ComposerRequireRemolog / Monolog. Si le répertoire du fournisseur est créé avec succès et que la dépendance est téléchargée, cela signifie que le compositeur est entièrement disponible. Si les étapes ci-dessus échouent, vous devrez peut-être vérifier si PHP a été installé à l'échelle mondiale ou ajusté les paramètres du chemin du système.
