Maison > interface Web > js tutoriel > le corps du texte

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

零下一度
Libérer: 2017-05-03 10:02:04
original
1338 Les gens l'ont consulté

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)
Copier après la connexion

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)
Copier après la connexion

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)
Copier après la connexion

Lier par écoute ou attachement

let server = require('http').Server(); 
let io = require('socket.io')()

io.listen(server) // io.attach(server)

server.listen(3000)
Copier après la connexion

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)
Copier après la connexion

koa

let app = require('koa')() 
let server = require('http').Server(app.callback())

let io = require('socket.io')(server)

app.listen(3000)
Copier après la connexion

É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()
})
Copier après la connexion

Imprimer après l'exécution

connect 
disconnect
Copier après la connexion
Copier après la connexion

Code client

let socket = io('http://localhost:3000') 
socket.on('connect', () => { 
 console.log('connect')
})
socket.on('disconnect', () => { 
 console.log('disconnect')
})
Copier après la connexion

Imprimer après l'exécution

connect 
disconnect
Copier après la connexion
Copier après la connexion

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)
 }
 })
})
Copier après la connexion

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)
})
Copier après la connexion

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)
})
Copier après la connexion

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)
 })
})
Copier après la connexion

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!

Étiquettes associées:
source:php.cn
Déclaration de ce site Web
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
Tutoriels populaires
Plus>
Derniers téléchargements
Plus>
effets Web
Code source du site Web
Matériel du site Web
Modèle frontal
À propos de nous Clause de non-responsabilité Sitemap
Site Web PHP chinois:Formation PHP en ligne sur le bien-être public,Aidez les apprenants PHP à grandir rapidement!