Maison > Article > interface Web > Nodejs peut-il implémenter la messagerie instantanée ?

Nodejs peut-il implémenter la messagerie instantanée ?

WBOYoriginal: 2023-05-16 20:34:35507parcourir

Node.js est une bibliothèque asynchrone basée sur les événements, ce qui la rend idéale pour créer des applications en temps réel telles que la messagerie instantanée.

Dans les applications Web traditionnelles, la transmission des données est généralement basée sur le protocole HTTP. Mais le protocole HTTP est un protocole de requête-réponse, ce qui signifie que le client doit envoyer une nouvelle requête à chaque fois qu'il souhaite obtenir de nouvelles données du serveur. Cela entraînera un certain retard, ce qui n'est pas idéal pour les demandes nécessitant une réponse immédiate.

Pour résoudre les problèmes ci-dessus, il est recommandé d'utiliser le protocole WebSocket. WebSocket est un nouveau protocole introduit par HTML5. Il permet au serveur de transmettre des données au client en temps réel, et le client peut également traiter les données directement après les avoir reçues. Ce mécanisme est implémenté sur la base d'une connexion TCP de longue durée, et sa latence et son efficacité d'utilisation de la bande passante sont meilleures que la technologie push et pull basée sur HTTP.

Dans Node.js, l'utilisation du protocole WebSocket peut être implémentée via plusieurs bibliothèques, parmi lesquelles les plus couramment utilisées sont les bibliothèques Socket.IO et ws.

Socket.IO est une bibliothèque basée sur WebSocket, qui fournit une API pratique pour gérer des opérations telles que les connexions WebSocket, le déclenchement d'événements et la transmission de données. Il prend également en charge le service de fichiers statiques, le stockage local et la communication entre plusieurs processus. Ces fonctions permettent de mettre en œuvre facilement des applications en temps réel telles que la messagerie instantanée.

Voici quelques exemples de code qui utilisent Socket.IO pour implémenter des applications de messagerie instantanée de base :

Créer un serveur

const app = require('express')();
const server = require('http').createServer(app);
const io = require('socket.io')(server);
const port = process.env.PORT || 3000;

server.listen(port, () => {
  console.log(`Server listening at http://localhost:${port}`);
});

Écouter les événements de connexion et de déconnexion, envoyer des messages

io.on('connection', (socket) => {
  console.log('a user connected');
  socket.on('disconnect', () => {
    console.log('user disconnected');
  });
  socket.on('chat message', (msg) => {
    console.log('message: ' + msg);
    io.emit('chat message', msg);
  });
});

Dans ce code, io. on( 'connection') écoute l'événement de connexion. Lorsqu'un client est connecté, le message 'un utilisateur connecté' sera imprimé et l'événement 'disconnect' sera surveillé. Lorsque la connexion est déconnectée, le 'utilisateur déconnecté'. Le message sera imprimé. En même temps, écoutez l'événement 'chat message'. Lorsqu'un message est reçu, imprimez son journal et appelez io.emit('chat message', msg) pour diffuser le message à tous les clients.

Code de la page client

<html>
  <head>
    <title>Chat Room</title>
  </head>
  <body>
    <ul id="messages"></ul>
    <form action="">
      <input id="m" autocomplete="off" /><button>Send</button>
    </form>
    <script src="/socket.io/socket.io.js"></script>
    <script>
      const socket = io();
      const form = document.querySelector('form');
      const input = document.querySelector('#m');
      const messages = document.querySelector('#messages');

      form.addEventListener('submit', (e) => {
        e.preventDefault(); // 防止页面跳转
        socket.emit('chat message', input.value); // 将消息发送给服务器
        input.value = ''; // 清空消息框
        return false;
      });

      socket.on('chat message', (msg) => {
        const li = document.createElement('li'); // 创建新条目
        li.textContent = msg; // 设置新条目的文本内容
        messages.appendChild(li); // 将新条目添加到列表中
      });
    </script>
  </body>
</html>

Ce code comprend une simple page HTML pour afficher l'historique des messages du salon de discussion, et un formulaire pour envoyer de nouveaux messages. Lorsque l'utilisateur soumet le formulaire, Socket.IO enverra un événement « message » au serveur, et le serveur diffusera le message à tous les clients après avoir traité l'événement. Tous les clients écoutent l'événement « message » et ajoutent les messages reçus à l'historique des discussions.

En général, Node.js peut être très pratique pour implémenter des applications de messagerie instantanée basées sur WebSocket. Il est facile d'implémenter des applications simples telles que des salons de discussion à l'aide de Socket.IO, mais pour les applications complexes, Node.js peut également être utilisé avec une variété d'autres bibliothèques et frameworks pour fournir des fonctionnalités de niveau supérieur.

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!

node.js html5 html JS 事件异步 http 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：Comment envoyer des données en temps réel dans nodejsArticle suivant：Comment envoyer des données en temps réel dans nodejs

Articles Liés

Voir plus