PHP utilise Socket et EPOLL pour envoyer et recevoir des messages dans les systèmes de messagerie instantanée en ligne

Avec le développement continu d'Internet, les systèmes de messagerie instantanée (MI) sont devenus un outil indispensable dans la vie et le travail des gens. Parmi eux, la manière de garantir la transmission rapide et l’exécution en temps réel des messages est devenue un élément crucial de la conception du système. Cet article explique comment utiliser Socket et EPOLL de PHP pour envoyer et recevoir des messages dans un système de messagerie instantanée en ligne.

1. Présentation de Socket
Socket, ou socket, est un moyen de communication entre ordinateurs. Il a été initialement développé par BSD (Berkeley Software Distribution), une startup d'AT&T Bell Labs, et est maintenant devenu une méthode populaire en réseau. programmation. Une des techniques qu’il faut maîtriser. Grâce à la technologie Socket, les applications peuvent utiliser le protocole TCP/IP pour la communication réseau afin de réaliser la transmission et la réception de données.

2. Présentation d'EPOLL
EPOLL est un mécanisme de multiplexage d'E/S efficace fourni par le noyau Linux. Dans le mécanisme traditionnel de sélection et d'interrogation, la totalité de la table des descripteurs de fichiers doit être parcourue pour chaque opération de lecture et d'écriture, ce qui est inefficace. EPOLL adopte la méthode d'enregistrement des fonctions de rappel, qui ne fonctionne que lorsque les données sont prêtes. En comparaison, cela peut améliorer la concurrence et les performances du système.

3. Utilisez Socket et EPOLL pour implémenter le système de messagerie instantanée dans PHP
1. Programme serveur
Dans le programme serveur, vous pouvez utiliser la fonction socket_create() pour créer une nouvelle ressource socket et lier l'hôte dans le nom de la fonction socket_bind(). ou adresse IP et numéro de port pour associer le socket à une adresse locale. Ensuite, appelez la fonction socket_listen() pour attendre que le client se connecte. Lorsqu'il y a une demande de connexion, la fonction socket_accept() est appelée pour recevoir la connexion. À ce stade, la nouvelle connexion doit être ajoutée à la liste des tâches.

$socket = socket_create(AF_INET, SOCK_STREAM, SOL_TCP);
socket_bind($socket,"0.0.0.0", 8888);
socket_listen($socket);

while(true){

$epoll_events = epoll_wait($epoll, $events, $timeout);
foreach($events as $event){
    if($event['resource'] == $socket){
        $client = socket_accept($socket);
        $client_id = uniqid();
        $client_list[$client_id] = array(
            'socket' => $client,
            'buffer' => '',
        );
        $fd = socket_import_stream($client);
        stream_set_blocking($client, false);
        $event = stream_socket_create($fd, -1);
        stream_set_blocking($event, 0);
        epoll_ctl($epoll, EPOLL_CTL_ADD, $fd, EPOLLIN);
    }

2.
Créez l'objet epoll au démarrage du programme, puis ajoutez le socket serveur à sa liste d'événements. Une fois qu'une nouvelle connexion est acceptée, elle peut être convertie en descripteur de fichier à l'aide de stream_socket_create() puis ajoutée à la liste d'événements de l'objet epoll. Et dans chaque boucle d'écoute d'événement, utilisez la fonction socket_recv() pour recevoir des messages et les stocker dans la liste des tâches.

if($event['events'] & EPOLLIN){

if($event['resource'] == $socket){
    $client = socket_accept($socket);
    $client_id = uniqid();
    $client_list[$client_id] = array(
        'socket' => $client,
        'buffer' => '',
    );
    $fd = socket_import_stream($client);
    stream_set_blocking($client, false);
    $event = stream_socket_create($fd, -1);
    stream_set_blocking($event, 0);
    epoll_ctl($epoll, EPOLL_CTL_ADD, $fd, EPOLLIN);
} else {
    $fd = intval($event['fd']);
    $client_id = array_search($fd, array_column($client_list, 'socket'));
    $buffer = '';
    while(socket_recv($event['resource'], $recv, 1024, MSG_DONTWAIT)){
        $buffer .= $recv;
    }
    $client_list[$client_id]['buffer'] .= $buffer;
}

}

3. Envoyer un message
Après avoir reçu le message, vous pouvez utiliser socket_write() pour envoyer les données de réponse au client.

function send_message($client_id, $message){

global $client_list;
if(isset($client_list[$client_id])){
    $message .= "

";

    socket_write($client_list[$client_id]['socket'], $message, strlen($message));
}

}

IV. Résumé
En utilisant la technologie PHP Socket et EPOLL, nous pouvons simplement implémenter l'envoi et la réception de messages du système de messagerie instantanée, améliorant ainsi considérablement Cela améliore la concurrence et les performances du système. Dans le même temps, lors de la conception du système de messagerie instantanée, de nombreux aspects tels que la sécurité et la fiabilité de la transmission des données doivent être pris en compte. Par conséquent, dans les applications réelles, il doit être ajusté et optimisé en fonction. besoins spécifiques. .

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!