Guide de développement PHP WebSocket : analyse des étapes d'implémentation des fonctions clés

Guide de développement pour PHP WebSocket : analyse des étapes d'implémentation des fonctions clés

Avec le développement continu des applications Internet, WebSocket, en tant que protocole de communication en temps réel, est devenu un outil important dans le développement Web. Dans le domaine de PHP, le chat en temps réel, les notifications push et d'autres fonctions peuvent être réalisées en utilisant WebSocket. Cet article présentera en détail comment utiliser PHP pour développer des applications WebSocket et fournira une analyse étape par étape de certaines fonctions clés.

1. Introduction à WebSocket
WebSocket est un protocole de communication full-duplex qui permet au serveur de transmettre activement des données au client sans que ce dernier n'ait à envoyer en permanence des requêtes pour obtenir des données. WebSocket est basé sur le protocole HTTP, partage des ports avec celui-ci, convient à n'importe quel navigateur et prend en charge la communication entre domaines.

2. Environnement de développement PHP WebSocket
Le développement d'applications WebSocket nécessite la prise en charge de l'extension WebSocket de PHP, qui peut être installée à l'aide de la commande suivante :

pecl install swoole

3. Établir un serveur WebSocket
À l'aide de l'extension PHP Swoole, vous pouvez simplement créer un serveur WebSocket. . Le code est le suivant :

$server = new SwooleWebSocketServer("0.0.0.0", 8080);

$server->on('open', function (SwooleWebSocketServer $server, $request) {
    echo "new connection: {$request->fd}
";
});

$server->on('message', function (SwooleWebSocketServer $server, $frame) {
    echo "received message: {$frame->data}
";
});

$server->on('close', function ($ser, $fd) {
    echo "connection closed: {$fd}
";
});

$server->start();

Quatre. Implémenter les fonctions clés

1. Diffuser un message
   La diffusion d'un message est une fonction qui envoie des messages à tous les clients connectés. Une fonction peut être définie pour implémenter la fonction de diffusion. Le code spécifique est le suivant :

   function broadcast($server, $message) {
    foreach ($server->connections as $fd) {
        $server->push($fd, $message);
    }
   }

2. Gestion des connexions clients
   Le serveur WebSocket permet plusieurs connexions client, les connexions client doivent donc être gérées. Un tableau peut être utilisé pour enregistrer les clients actuellement connectés. Le code spécifique est le suivant :

   $connections = [];
   
   $server->on('open', function (SwooleWebSocketServer $server, $request) use (&$connections) {
    echo "new connection: {$request->fd}
   ";
    $connections[$request->fd] = $request->fd;
   });
   
   $server->on('close', function ($ser, $fd) use (&$connections) {
    echo "connection closed: {$fd}
   ";
    unset($connections[$fd]);
   });

3. Fonction de chat privé
   La fonction de chat privé est une fonction qui envoie des messages aux clients spécifiés. L'identifiant du client peut être utilisé pour identifier le client de manière unique. Le code spécifique est le suivant :

   function sendToClient($server, $clientId, $message) {
    $server->push($clientId, $message);
   }

4. Détection des battements cardiaques
   La détection des battements cardiaques est une fonction qui permet au client de rester connecté. le client est dans un certain délai. Si aucun paquet de battement de cœur n'est reçu dans le délai imparti, la connexion est considérée comme déconnectée. Le code spécifique est le suivant :

   $server->on('message', function (SwooleWebSocketServer $server, $frame) {
    echo "received message: {$frame->data}
   ";
    $connections[$frame->fd]['lastTime'] = time();
    // 处理收到的消息
   });
   
   $server->tick(2000, function () use (&$connections) {
    foreach ($connections as $fd => $info) {
        if (time() - $info['lastTime'] > 5) {
            $server->close($fd);
            unset($connections[$fd]);
        }
    }
   });

   5. Résumé
   Cet article présente comment utiliser PHP pour développer des applications WebSocket et fournit une analyse étape par étape des fonctions clés. Grâce aux étapes ci-dessus, les développeurs peuvent implémenter les messages diffusés par WebSocket, la gestion des connexions client, les fonctions de chat privé, la détection des battements de cœur et d'autres fonctions. J'espère que cet article sera utile aux développeurs PHP WebSocket.

   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!