recherche

Maison >développement back-end >tutoriel php >Analyse de cas réels de PHP implémentant la fonction push de messages en temps réel

Analyse de cas réels de PHP implémentant la fonction push de messages en temps réel

PHPz
PHPzoriginal
2023-08-10 18:06:211091parcourir

Analyse de cas réels de PHP implémentant la fonction push de messages en temps réel

Une analyse de cas pratique de PHP implémentant la fonction de transmission de messages en temps réel

Introduction :
La transmission de messages en temps réel est une exigence fonctionnelle courante dans les applications Web modernes. Elle peut réaliser les fonctions de messagerie instantanée et de mise à jour en temps réel. de messages. Cet article présentera comment utiliser PHP pour implémenter la fonction de transmission de messages en temps réel à travers une analyse de cas pratique et fournira des exemples de code correspondants.

Contexte du cas :
Supposons qu'il existe une application Web dans laquelle les utilisateurs peuvent envoyer des messages à d'autres utilisateurs en ligne via le navigateur et recevoir des messages d'autres utilisateurs en ligne. Nous utiliserons PHP comme langage côté serveur et jQuery et HTML5 WebSocket comme support technique côté client.

Implémentation du code côté serveur :
Tout d'abord, nous devons créer un serveur WebSocket pour recevoir et traiter les demandes de connexion client et la communication des messages. Voici un exemple de code d'implémentation PHP simplifié : 

<?php
class ChatServer {
    private $clients = [];
  
    public function __construct($host, $port) {
        $socket = socket_create(AF_INET, SOCK_STREAM, SOL_TCP);
        socket_bind($socket, $host, $port);
        socket_listen($socket);
        $this->clients[] = $socket;
        
        while (true) {
            $sockets = $this->clients;
            socket_select($sockets, $write = NULL, $except = NULL, NULL);
          
            foreach ($sockets as $socket) {
                if ($socket == $this->clients[0]) {
                    $newSocket = socket_accept($socket);
                    $this->clients[] = $newSocket;
                    $this->sendResponse($newSocket, "Connected successfully!
");
                } else {
                    $bytes = socket_recv($socket, $buffer, 2048, 0);
                  
                    if ($bytes == 0) {
                        $index = array_search($socket, $this->clients);
                        unset($this->clients[$index]);
                        $this->sendResponse($socket, "Disconnected from server!
");
                        socket_close($socket);
                    } else {
                        $this->sendMessageToClients($socket, $buffer);
                    }
                }
            }
        }
    }
  
    private function sendResponse($socket, $message) {
        socket_write($socket, $message, strlen($message));
    }
  
    private function sendMessageToClients($senderSocket, $message) {
        foreach ($this->clients as $clientSocket) {
            if ($clientSocket != $this->clients[0] && $clientSocket != $senderSocket) {
                $this->sendResponse($clientSocket, $message);
            }
        }
    }
}
 
new ChatServer('localhost', 8080);
?>

Dans l'exemple de code ci-dessus, nous avons créé une classe ChatServer pour gérer les connexions et les communications client. Cette classe crée et gère les connexions socket à l’aide de la bibliothèque de fonctions socket. Dans la boucle principale du serveur, nous utilisons la fonction socket_select pour implémenter une communication asynchrone, recevoir et traiter les messages client.

Implémentation du code côté client :
Ensuite, nous devons créer une page HTML et le code JavaScript correspondant pour implémenter les fonctions d'envoi et de réception de messages du client. Voici un exemple de code simplifié : 

<!DOCTYPE html>
<html>
<head>
    <title>Real-time Chat Application</title>
</head>
<body>
    <input type="text" id="messageInput" placeholder="Enter your message" />
    <button onclick="sendMessage()">Send</button>
    <div id="messages"></div>
 
    <script src="https://code.jquery.com/jquery-3.6.0.min.js"></script>
    <script>
        var socket = new WebSocket("ws://localhost:8080");
 
        socket.onopen = function(event) {
            console.log("Connection established!");
        };
 
        socket.onmessage = function(event) {
            var message = event.data;
            $("#messages").append("<p>" + message + "</p>");
        };
 
        socket.onerror = function(event) {
            console.log("Error: " + event.data);
        };
 
        function sendMessage() {
            var message = $("#messageInput").val();
            socket.send(message);
            $("#messageInput").val("");
        }
    </script>
</body>
</html>

Dans l'exemple de code ci-dessus, nous avons créé une page HTML qui contient une zone de saisie de message, un bouton d'envoi et une zone d'affichage de message. En utilisant la technologie WebSocket, nous pouvons établir un canal de communication bidirectionnel persistant entre le client et le serveur. Le code JavaScript côté client écoute les événements WebSocket et envoie et traite les messages en conséquence.

Résumé :
Grâce à l'exemple d'analyse ci-dessus, nous avons appris à utiliser PHP pour implémenter la fonction push de messages en temps réel. Côté serveur, nous utilisons la bibliothèque de fonctions socket pour créer et gérer des connexions socket, et implémentons une communication asynchrone via la fonction socket_select. Côté client, nous utilisons la technologie WebSocket pour établir un canal de communication bidirectionnel persistant et envoyer et recevoir des messages via du code JavaScript.

Bien sûr, l'exemple de code ci-dessus n'est qu'une implémentation simplifiée, et de nombreux autres facteurs doivent être pris en compte dans les projets réels, tels que le stockage et le contrôle des messages, l'authentification des utilisateurs et la gestion des autorisations, etc. Cependant, en comprenant les exemples ci-dessus, nous pouvons comprendre les principes de base et les méthodes de mise en œuvre de la fonction de transmission de messages en temps réel, fournissant ainsi certaines références et idées pour le développement ultérieur des applications Web.

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!

php JavaScript html5 jquery html 循环 事件 异步 websocket
Déclaration：
Le contenu de cet article est volontairement contribué par les internautes et les droits d'auteur appartiennent à l'auteur original. Ce site n'assume aucune responsabilité légale correspondante. Si vous trouvez un contenu suspecté de plagiat ou de contrefaçon, veuillez contacter admin@php.cn
Article précédent：Étudier le modèle d'adaptateur dans la programmation orientée objet PHPArticle suivant：Étudier le modèle d'adaptateur dans la programmation orientée objet PHP

Articles Liés

Voir plus