Socket.io fournit une communication bidirectionnelle en temps réel basée sur des événements. L'article suivant présente principalement des informations pertinentes sur les applications de base de socket.io. Il a une certaine valeur de référence et d'apprentissage pour tous les amis qui en ont besoin. ensemble. Jetez un oeil.
Avant-propos
Socket.IO prend en charge la communication opportune, bidirectionnelle et basée sur les événements. Il fonctionne sur toutes les plateformes, tous les navigateurs et tous les appareils avec la même fiabilité et la même vitesse.
Analyse en temps réel : envoyez les données aux clients où elles seront représentées sous forme de compteurs en temps réel, de graphiques ou de journaux clients.
Communication et chat en temps réel : il suffit de quelques lignes de code pour écrire une application de chat Socket.IO "Hello, World".
Transmission en streaming binaire : à partir de la version 1.0, Socket.IO prend en charge toute forme de transmission de fichiers binaires, tels que : images, vidéos, audio, etc.
Fusion de documents : permettez à plusieurs utilisateurs de modifier un document en même temps et de voir les modifications apportées par chaque utilisateur.
Connexion serveur et client
socket.io fournit une API de connexion serveur et client
Le serveur socket.io doit lier une instance http.Server
Lier http.Server
Liaison implicite
est implicitement lié en passant le port lors de l'instanciation ou de l'appel de la fonction d'écoute ou d'attachement après l'instanciation. Socket.io instancie et écoute en interne http.Server
Lors de l'instanciation, le port entrant
let io = require('socket.io')(3000)
est directement lié via la fonction d'écoute ou d'attachement. écouter est synonyme de attach
let io = require('socket.io') io.listen(3000) // io.attach(3000)
2. Afficher la liaison
Vous pouvez spécifier manuellement http.Server
Lier lors de l'instanciation
let server = require('http').Server(); let io = require('socket.io')(server) server.listen(3000)
Lier par écoute ou attachement
let server = require('http').Server(); let io = require('socket.io')() io.listen(server) // io.attach(server) server.listen(3000)
Peut lier express ou koa et d'autres frameworks http
express
let app = require('express') let server = require('http').Server(app) let io = require('socket.io')(server) app.listen(3000)
koa
let app = require('koa')() let server = require('http').Server(app.callback()) let io = require('socket.io')(server) app.listen(3000)
Écouter l'état de la connexion
Lorsque le serveur et le client sont connectés avec succès, le serveur écoutera la connexion et connectera les événements ( connection et connect sont synonymes), le client écoutera l'événement connect Lorsque la connexion est déconnectée, le socket du serveur correspondant au client et le client écouteront l'événement de déconnexion
Code du serveur
let server = require('http').Server() let io = require('socket.io')(server) server.listen(3000); io.on('connection', socket => { console.log('connect') socket.on('disconnect', () => { console.log('disconnect') }) socket.disconnect() })
Imprimer après l'exécution
connect disconnect
Code client
let socket = io('http://localhost:3000') socket.on('connect', () => { console.log('connect') }) socket.on('disconnect', () => { console.log('disconnect') })
Imprimer après l'exécution
connect disconnect
Transférer les données
Les sockets serveur et client sont un objet EventEmitter associé. Les événements envoyés par le socket client peuvent être reçus par le socket serveur, et les événements envoyés par le socket serveur peuvent également être reçus. . accepté par le client. Sur la base de ce mécanisme, une communication bidirectionnelle peut être réalisée.
Simulez maintenant une situation comme celle-ci : le client continue d'envoyer des nombres aléatoires lorsque le nombre aléatoire est supérieur à 0,95, le serveur attend 1 s et envoie un avertissement et le nombre d'avertissements au client
Code serveur
let server = require('http').Server() let io = require('socket.io')(server) server.listen(3000); io.on('connection', socket => { socket.on('random', value => { console.log(value) if (value > 0.95) { if (typeof socket.warning === 'undefined') socket.warning = 0 setTimeout(() => { socket.emit('warn', ++socket.warning) }, 1000) } }) })
Les objets socket peuvent être utilisés pour stocker des informations d'état et des données personnalisées, telles que socket.warning
Code client
let socket = io('http://localhost:3000') let interval = setInterval(() => { socket.emit('random', Math.random()) }, 500) socket.on('warn', count => { console.log('warning count: ' + count) }) socket.on('disconnect', () => { clearInterval(interval) })
Flux de transport
socket.io peut gérer le flux
Code du serveur
io.on('connection', function (socket) { let stream = ss.createStream() ss(socket).emit('script', stream) fs.createReadStream(__filename).pipe(stream) })
Code client
let socket = io('http://localhost:3000') ss(socket).on('script', stream => { let buffer = '' stream.on('data', data => { buffer += data.toString() }) stream.on('end', () => { console.log(buffer) }) })
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!