Introduction au didacticiel d'apprentissage socket.io dans node.js (2)

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!