processus de gestion des événements swoole

Le contenu principal de cet article concerne l'analyse du processus de traitement des événements swoole. Les amis intéressés peuvent en apprendre davantage. J'espère que cet article pourra vous être utile.

Pour comprendre le processus de traitement des événements swoole, comprenez d'abord les deux modes de traitement des événements réseau.

Mode Réacteur

Il nécessite que le thread principal (unité de traitement d'E/S) surveille uniquement si un événement se produit sur le descripteur de fichier et, si c'est le cas, informe immédiatement le thread/processus de travail de l’événement (unité logique). A part cela, le thread principal ne fait aucun autre travail. La lecture et l'écriture de données, l'acceptation de nouvelles connexions et le traitement des demandes des clients s'effectuent dans des threads de travail.

Mode Proactor

Deux implémentations

Utilisez le modèle asynchrone d'E/S pour implémenter le mode Proactor. Principe : toutes les opérations d'E/S sont confiées au thread principal, qui coopère avec le noyau pour les gérer, et les opérations de logique métier sont confiées à l'unité logique. Par exemple, utilisez aio_read pour y parvenir.

Workflow :

1. Le thread principal appelle la fonction aio_read pour enregistrer l'événement de fin de lecture sur le socket avec le noyau.
2. Le thread principal continue de traiter les autres événements d'E/S.
3. Lorsque les données sur le socket sont lues dans le tampon utilisateur, le noyau envoie un signal à l'application (unité logique) pour informer l'application que les données sont disponibles.
4. L'application lit les données (demande du client), et après traitement, appelle la fonction aio_write pour enregistrer l'événement d'écriture sur le socket auprès du noyau.
5. Le thread principal continue de traiter une autre logique.
6. Lorsque les données dans le tampon utilisateur sont écrites dans le socket, le noyau envoie un signal à l'application pour informer l'application que les données ont été envoyées.
7. L'application dispose de fonctions de traitement du signal prédéfinies pour gérer les conséquences, telles que la fermeture du socket

Utilisez le modèle de synchronisation d'E/S pour implémenter le mode Proactor. Principe : Le thread principal effectue les opérations de lecture et d'écriture des données d'événements d'E/S, et les opérations de logique métier sont transmises à l'unité logique. Par exemple, utilisez epoll pour y parvenir.

Workflow :

1. Le thread principal enregistre l'événement prêt en lecture sur le socket dans la table des événements du noyau epoll.
2. Le thread principal appelle epoll_wait pour attendre que les données soient lues sur le socket.
3. Après le retour d'epoll_wait, le thread principal lit les données du socket, puis encapsule les données lues dans un objet de requête (demande du client) et l'insère dans la file d'attente des requêtes.
4. Ensuite, le thread consommateur de la file d'attente traite l'objet de requête, puis enregistre l'événement prêt à écrire sur le socket dans la table des événements du noyau epoll.
5. Le thread principal appelle epoll_wait pour attendre que le socket soit accessible en écriture.
6. Lorsque le socket est accessible en écriture, epoll_wait en informe le thread principal. Le thread principal écrit le résultat de la requête sur le socket.

schéma d'architecture d'événements swoole

Comme le montre la figure, si nous combinons le thread Reactor et le processus Work, ils sont considérés en tant que threads de travail, swoole utilise le mode de traitement des événements du réacteur.

Les étapes par lesquelles passe une requête sont les suivantes :

1. Le thread principal du serveur attend que le client se connecte.

2. Le thread Reactor traite le socket connecté, lit les données de la requête sur le socket (Receive), encapsule la requête et la transmet au processus de travail.

3. Le processus Travail est une unité logique qui traite les données métiers.

4. Les résultats du processus de travail sont renvoyés au thread Reactor.

5. Le thread Reactor réécrit le résultat dans le socket (Send).

Tutoriels associés : tutoriel vidéo swoole

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!