Swoole prend-il en charge le multithreading ?

Thread du réacteur

Le processus principal de SwooleServer est un programme multithread. Il existe un groupe de threads très important appelés threads Reactor. C'est le thread qui gère réellement les connexions TCP et envoie et reçoit des données.

Après avoir accepté une nouvelle connexion, le thread principal de Swoole attribuera la connexion à un thread Reactor fixe, et ce thread sera responsable de la surveillance du socket. Lisez les données lorsque le socket est lisible, effectuez une analyse de protocole et envoyez la demande au processus Worker. Envoie des données au client TCP lorsque le socket est accessible en écriture.

L'allocation est calculée comme fd % serv->reactor_num

Le langage PHP ne prenant pas en charge le multi-threading, Swoole utilise le mode multi-processus. Il existe une isolation de la mémoire de processus en mode multi-processus. Lorsque les variables globales et les variables super-globales sont modifiées dans le processus de travail, elles ne seront pas valides dans d'autres processus.

Lorsque worker_num=1 est défini, il n'y a pas d'isolation de processus et vous pouvez utiliser des variables globales pour enregistrer les données

Isolation de processus

$fds = array();
$server->on('connect', function ($server, $fd){
    echo "connection open: {$fd}\n";
    global $fds;
    $fds[] = $fd;
    var_dump($fds);
});

Bien que $fds soit une variable globale, elle n'est valide que dans le processus en cours. La couche inférieure du serveur Swoole créera plusieurs processus Worker. La valeur imprimée dans var_dump ($ fds) ne contient que des fds connectés partiels.

La solution correspondante est d'utiliser des services de stockage externes :

Base de données, telle que : MySQL, MongoDB
Serveur de cache, tel que : Redis, Memcache
Les fichiers disque doivent être verrouillés lorsque plusieurs processus lisent et écrivent simultanément

Les opérations ordinaires de base de données et de fichiers disque ont beaucoup de temps d'attente d'E/S. Par conséquent, il est recommandé d'utiliser :

Base de données en mémoire Redis, vitesses de lecture et d'écriture très rapides
/dev/shm système de fichiers en mémoire, toutes les opérations de lecture et d'écriture sont terminés en mémoire, pas de consommation d'E/S, performances extrêmement élevées
En plus d'utiliser le stockage, vous pouvez également utiliser la mémoire partagée pour enregistrer des données

Apprentissage recommandé : 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!