Découvrez le système de messagerie multi-processus swoole dans un seul article

Scénario : applicable à la plupart des scénarios de file d'attente de messages, je vais énumérer quelques endroits courants : annulation automatique des commandes et retour des stocks, réception automatique, e-mail de masse, modèle de message push WeChat, e-mail asynchrone Envoyer , annuler automatiquement à l'expiration de l'adhésion, etc.

1. Commençons par examiner le processus de mise en œuvre de ce système côté message.

Écrivez ensuite la logique métier dans la classe Job, avec deux méthodes [doJob => Custom business, after=> Opérations de suivi métier]

2. Serve-Queue explique le processus en détail :

1. Installez git clone https://github.com/twomiao/Serve.git, puis exécutez la commande : Composer install

2. cd Serve/app/ Ouvrez le répertoire, rendu :

3. Introduction au répertoire : Config, Services, Utils, Job, Func

(1 ) Répertoire de fichiers de configuration de configuration (Redis, MySQL, Serve-Queue)

(2) Couche métier Services (OrderService)

(3) Classe d'outils Utils (mail, SMS, etc. etc.), Helper est équivalent à

(4) Répertoire de tâches (Job::doJob() business y est écrit, ne changez pas le nom de la classe de tâches)

(5) Func Fonctions couramment utilisées (env, db par exemple)

(6) répertoire log log et répertoire TEST (les fichiers de données de simulation s'y trouvent)

3. Processus de fonctionnement de Serve-Queue ：

commande php serve start :

Livrer des données simulées via php test/placeOrder.php 1000

swoole démarre le traitement multi-processus, les données de commande

rechargement du service php : redémarre en douceur le processus de tâche, équivalent pour mettre à jour (nouvelle méthode Job())->doJob( ) ;

Ajout d'un nouveau rappel textuel "2333, redémarrage en douceur réussi" ; Haha, en fait, la description a pris effet !

Démon en cours d'exécution : exécution de la commande php serve start -d

Envoyer une commande, on la teste ? -1 Le statut de paiement en attente 0 a été automatiquement annulé

Rappel : Le fichier de test est dans Serve/data/sp_order.sql

4. Pour implémenter le processus ci-dessus, vous avez besoin des éléments suivants Installer ces environnements

1 Installer Redis en tant que file d'attente, base de données MySQL

2 Terminez l'installation étendue via la commande pecl install swoole, pecl install. La commande seaslog

php --ini détermine l'emplacement de php.ini et ajoute swoole.so et seaslog.so

3. Utilisez l'outil Mix Delayer (pour atteindre le délai)

Adresse de téléchargement : https://github.com/mix-basic/delayer/releases

Instructions d'utilisation : https://github.com /mix-basic/delayer-client-php

4. Commandes Management Serve, respectivement : php serve start | reload | reload

5. adresse de l'entrepôt :

https://github.com/twomiao/Serve.git (file d'attente Redis)

https://github.com/twomiao/Jober

Site Web PHP chinois, beaucoup de tutoriel d'introduction au swoole gratuit, bienvenue pour apprendre en ligne !

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!