Heim > Artikel > Web-Frontend > Einführung in das Socket.io-Lerntutorial in node.js (2)
Socket.io bietet bidirektionale Echtzeitkommunikation basierend auf Ereignissen. Der folgende Artikel stellt hauptsächlich relevante Informationen zu den grundlegenden Anwendungen von socket.io vor. Er hat einen bestimmten Referenz- und Lernwert, den jeder lesen kann es zusammen.
Vorwort
Socket.IO unterstützt zeitnahe, wechselseitige und ereignisbasierte Kommunikation. Es funktioniert auf jeder Plattform, jedem Browser und jedem Gerät mit der gleichen Zuverlässigkeit und Geschwindigkeit.
Echtzeitanalyse: Übertragen Sie Daten an Clients, wo sie als Echtzeitzähler, Diagramme oder Protokoll-Clients dargestellt werden.
Echtzeitkommunikation und Chat: Es sind nur wenige Codezeilen erforderlich, um eine Socket.IO-Chat-Anwendung „Hello, World“ zu schreiben.
Binäre Streaming-Übertragung: Ab Version 1.0 unterstützt Socket.IO jede Form der binären Dateiübertragung, wie zum Beispiel: Bilder, Videos, Audio usw.
Dokumentenzusammenführung: Ermöglichen Sie mehreren Benutzern die gleichzeitige Bearbeitung eines Dokuments und sehen Sie die von jedem Benutzer vorgenommenen Änderungen.
Server- und Client-Verbindung
socket.io bietet sowohl Server- als auch Client-Verbindungs-API
Der Server socket.io muss eine http.Server-Instanz binden
HTTP.Server binden
1. Implizite Bindung
ist implizit gebunden, indem der Port bei der Instanziierung übergeben oder die Listen- oder Attach-Funktion nach der Instanziierung aufgerufen wird. Socket.io instanziiert und lauscht http.Server
Beim Instanziieren wird der eingehende Port
let io = require('socket.io')(3000)
direkt über die Listen- oder Attach-Funktion gebunden. listen ist gleichbedeutend mit attachment
let io = require('socket.io') io.listen(3000) // io.attach(3000)
2. Bindung anzeigen
Sie können http.Server
Bind beim Instanziieren manuell angeben
let server = require('http').Server(); let io = require('socket.io')(server) server.listen(3000)
Binden durch Abhören oder Anhängen
let server = require('http').Server(); let io = require('socket.io')() io.listen(server) // io.attach(server) server.listen(3000)
Kann Express oder Koa und andere http-Frameworks binden
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)
Überwachen Sie den Verbindungsstatus
Wenn der Server und der Client erfolgreich verbunden sind, überwacht der Server die Verbindung und Verbindungsereignisse ( Verbindung und Verbindung sind synonym), der Client hört auf das Verbindungsereignis. Wenn die Verbindung getrennt wird, hören sowohl der dem Client entsprechende Server-Socket als auch der Client auf das Trennungsereignis
Servercode
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() })
Nach Ausführung drucken
connect disconnect
Client-Code
let socket = io('http://localhost:3000') socket.on('connect', () => { console.log('connect') }) socket.on('disconnect', () => { console.log('disconnect') })
Nach Ausführung drucken
connect disconnect
Daten übertragen
Die Server- und Client-Sockets sind ein zugehöriges EventEmitter-Objekt. Vom Client-Socket gesendete Ereignisse können vom Server-Socket empfangen werden, und vom Server-Socket gesendete Ereignisse können ebenfalls empfangen werden . vom Kunden akzeptiert. Basierend auf diesem Mechanismus kann eine bidirektionale Kommunikation erreicht werden.
Simulieren Sie nun eine Situation wie diese: Der Client sendet weiterhin Zufallszahlen. Wenn die Zufallszahl größer als 0,95 ist, verzögert der Server 1 Sekunde und sendet eine Warnung und die Anzahl der Warnungen an den Client
Servercode
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) } }) })
Socket-Objekte können zum Speichern von Statusinformationen und benutzerdefinierten Daten verwendet werden, wie z. B. socket.warning
Clientcode
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) })
Transportstrom
socket.io kann den Stream verarbeiten
Servercode
io.on('connection', function (socket) { let stream = ss.createStream() ss(socket).emit('script', stream) fs.createReadStream(__filename).pipe(stream) })
Clientcode
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) }) })
Das obige ist der detaillierte Inhalt vonEinführung in das Socket.io-Lerntutorial in node.js (2). Für weitere Informationen folgen Sie bitte anderen verwandten Artikeln auf der PHP chinesischen Website!