前言
Socket.IO支持及時、雙向與基于事件的交流。它可以在每個平臺、每個瀏覽器和每個設備上工作，可靠性和速度同樣穩定。
服務端與客戶端連接
socket.io同時提供了服務端和客戶端的API
服務端socket.io必須綁定一個http.Server實例
綁定http.Server
1、隱式綁定
通過實例化時傳入端口或實例化后調用listen或attach函數進行隱式綁定。socket.io內部實例化并監聽http.Server
實例化時傳入端口
let io = require('socket.io')(3000)直接通過listen或attach函數綁定。listen與attach同義
let io = require('socket.io') io.listen(3000) // io.attach(3000) 2、顯示綁定
可以手動指定http.Server
實例化時綁定
let server = require('http').Server(); let io = require('socket.io')(server)server.listen(3000) 通過listen或attach綁定
let server = require('http').Server(); let io = require('socket.io')()io.listen(server) // io.attach(server)server.listen(3000) 可以綁定express或koa等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) 監聽連接狀態
當服務器端與客戶端連接成功時，服務端會監聽到connection和connect事件(connection與connect同義), 客戶端會監聽到connect事件, 斷開連接時服務端的對應到客戶端的socket與客戶端均會均會監聽到disconnect事件
服務端代碼
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()})運行后打印
connect disconnect
客戶端代碼
let socket = io('http://localhost:3000') socket.on('connect', () => { console.log('connect')})socket.on('disconnect', () => { console.log('disconnect')})運行后打印
connect disconnect
傳輸數據
服務器與客戶端的socket是一個關聯的EventEmitter對象，客戶端socket派發的事件可以通以被服務端的socket接收，服務器端socket派發的事件也可以被客戶端接受。基于這種機制，可以實現雙向交流。
現在模擬這樣一種情況：客戶端不停發送隨機數，當隨機數大于0.95時，服務端延時1s后向客戶端發送警告以及警告次數
服務端代碼
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對象可以用來存儲狀態信息和自定義數據,如socket.warning
客戶端代碼
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)})傳輸流
socket.io可以處理流
服務端代碼
io.on('connection', function (socket) { let stream = ss.createStream() ss(socket).emit('script', stream) fs.createReadStream(__filename).pipe(stream)})客戶端代碼
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) })})總結
以上就是這篇文章的全部內容了，希望本文的內容對大家的學習或者工作能帶來一定的幫助，如果有疑問大家可以留言交流，謝謝大家對VeVb武林網的支持。
新聞熱點
疑難解答
