今天就跟大家聊聊有關(guān)socket的io怎么應(yīng)用，可能很多人都不太了解，為了讓大家更加了解，小編給大家總結(jié)了以下內(nèi)容，希望大家根據(jù)這篇文章可以有所收獲。

旺蒼網(wǎng)站建設(shè)公司成都創(chuàng)新互聯(lián),旺蒼網(wǎng)站設(shè)計制作，有大型網(wǎng)站制作公司豐富經(jīng)驗。已為旺蒼上1000家提供企業(yè)網(wǎng)站建設(shè)服務(wù)。企業(yè)網(wǎng)站搭建\成都外貿(mào)網(wǎng)站制作要多少錢，請找那個售后服務(wù)好的旺蒼做網(wǎng)站的公司定做！

Socket.IO支持及時、雙向與基于事件的交流。它可以在每個平臺、每個瀏覽器和每個設(shè)備上工作，可靠性和速度同樣穩(wěn)定。

• 實(shí)時分析：將數(shù)據(jù)推送到客戶端，這些客戶端會被表示為實(shí)時計數(shù)器，圖表或日志客戶。

• 實(shí)時通信和聊天：只需幾行代碼便可寫成一個Socket.IO的”Hello,World”聊天應(yīng)用。

• 二進(jìn)制流傳輸：從1.0版本開始，Socket.IO支持任何形式的二進(jìn)制文件傳輸，例如：圖片，視頻，音頻等。

• 文檔合并：允許多個用戶同時編輯一個文檔，并且能夠看到每個用戶做出的修改。

服務(wù)端與客戶端連接

socket.io同時提供了服務(wù)端和客戶端的API

服務(wù)端socket.io必須綁定一個http.Server實(shí)例

綁定http.Server

1、隱式綁定

通過實(shí)例化時傳入端口或?qū)嵗笳{(diào)用listen或attach函數(shù)進(jìn)行隱式綁定。socket.io內(nèi)部實(shí)例化并監(jiān)聽http.Server

實(shí)例化時傳入端口

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

直接通過listen或attach函數(shù)綁定。listen與attach同義

let io = require('socket.io') 
io.listen(3000) // io.attach(3000)

2、顯示綁定

可以手動指定http.Server

實(shí)例化時綁定

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)

監(jiān)聽連接狀態(tài)

當(dāng)服務(wù)器端與客戶端連接成功時，服務(wù)端會監(jiān)聽到connection和connect事件(connection與connect同義), 客戶端會監(jiān)聽到connect事件, 斷開連接時服務(wù)端的對應(yīng)到客戶端的socket與客戶端均會均會監(jiān)聽到disconnect事件

服務(wù)端代碼

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()
})

運(yùn)行后打印

connect 
disconnect

客戶端代碼

let socket = io('http://localhost:3000') 
socket.on('connect', () => { 
 console.log('connect')
})
socket.on('disconnect', () => { 
 console.log('disconnect')
})

運(yùn)行后打印

connect 
disconnect

傳輸數(shù)據(jù)

服務(wù)器與客戶端的socket是一個關(guān)聯(lián)的EventEmitter對象，客戶端socket派發(fā)的事件可以通以被服務(wù)端的socket接收，服務(wù)器端socket派發(fā)的事件也可以被客戶端接受。基于這種機(jī)制，可以實(shí)現(xiàn)雙向交流。

現(xiàn)在模擬這樣一種情況：客戶端不停發(fā)送隨機(jī)數(shù)，當(dāng)隨機(jī)數(shù)大于0.95時，服務(wù)端延時1s后向客戶端發(fā)送警告以及警告次數(shù)

服務(wù)端代碼

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對象可以用來存儲狀態(tài)信息和自定義數(shù)據(jù),如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可以處理流

服務(wù)端代碼

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)
 })
})

看完上述內(nèi)容，你們對socket的io怎么應(yīng)用有進(jìn)一步的了解嗎？如果還想了解更多知識或者相關(guān)內(nèi)容，請關(guān)注創(chuàng)新互聯(lián)行業(yè)資訊頻道，感謝大家的支持。