socket.io学习教程之深入学习篇（三）

let app = require('http').createServer() 
let io = require('socket.io')(app)

app.listen(3000); 

let io = require('socket.io')(app, { 
 serveClient: false
})

let app = require('http').createServer() 
let io = require('socket.io')() 
io.serveClient(false) 
io.listen(app) // 或者io.attach(app) 

let io = require('socket.io')(app, { 
 path: '/io'
})

let app = require('http').createServer() 
let io = require('socket.io')() 
io.path('/io') 
io.listen(app) 

let socket = io('http://localhost:3000"htmlcode">

let app = require('http').createServer() 
let io = require('socket.io')(app, { 
 allowRequest: (req, cb) => {
 if (req._query && req._query.token === 'abc') return cb(null, true)
 cb(null, false)
 }
});


origins


可以对源进行限制
1、实例化时限制源




let app = require('http').createServer() 
let io = require('socket.io')(app, { 
 origins: 'http://localhost:3000'
})


2、origins函数设置源


origins函数有两种形式 


origins(string) : 设置运行的源 


origins(string, fn(err, success)) : 通过函数判断源是否允许


io.origins('http://localhost:*')

io.origins((origin, cb) => { 
 if (origin === 'http://localhost:3000/') return cb(null, true)
 cb(null, false)
})


名称空间


名称空间用来对服务端/客户端的连接隔离,有些地方，也称呼名称空间(namespace)为通道(channel)。下面举例对其意义进行说明
我们需要实现一个协同应用,这个应用有两个功能:

  
协同编辑: 多个用户可以同时编辑一个文档
  
消息: 用户间可以发送消息

  

用socket.io实现这个应用，有如下几种形式
1、完全独立: 协同编辑有一个独立服务edit.socket.test ,消息系统一个独立服务message.socket.test




let editSocket = io('edit.socket.test') 
let messageSocket = io('message.socket.test') 


2、名称空间: 只运行一个独立服务,通过名称空间进行隔离




let app = require('http').createServer() 
let io = require('socket.io')(app) 
let editServer = io.of('/edit') 
let messsageServer = io.of('/message') 
editServer.on('connection', socket => { 
 //编辑相关
})
messsageServer.on('connection', socket => { 
 /消息相关
})




let editSocket = io('socket.test/edit') 
let messageSocket = io('socket.test/message') 


3、事件名约定: 通过为事件名添加进行隔离




let app = require('http').createServer() 
let io = require('socket.io')(app)

io.on('connection', socket => { 
 //编辑相关
 io.emit('edit:test')
 io.on('edit:test', data => {

 })
 //消息相关
 io.emit('message:test')
 io.on('message:test', data => {

 })
}


通过事件名约定程序的侵入性太大，不利于拆分和重组，不推荐。 而完全独立的模式需要使用两个socket连接，即浪费浏览器允许的并发连接数，又更多消耗服务器资源。使用名称空间即能实现很好的隔离，又不会对资源造成浪费。
默认名称空间


socket.io实例化时自动绑定路径为/的名称空间


let app = require('http').createServer() 
let io = require('socket.io')(app)

io.sockets // io.of('/').sockets 
io.emit // 代理io.of('/').emit, 类似函数有'to', 'in', 'use', 'send', 'write', 'clients', 'compress' 


中间件


socket.io的名空间通过use注册中间件,中间件在客户端与服务端建立连接成功后,connet事件派发前调用一次。
利用中间件数据校验


io.use((socket, next) => { 
 if (socket.request.headers.cookie) return next()
 next(new Error('Authentication error'))
})


利用中间件提取或转换数据 io.use((socket, next) => { 

getInfo(socket.request.query.id, (err, data) => { if (err) return next(err) socket.custom = data next() }) })
与allowRequest对比


allowRequest可以进行一些校验,提取,为什么还要需要中间件"color: #ff0000">聊天室


聊天室是对当前连接的socket集合根据特定规则进行归组,方便群发消息。可以类比QQ群的概率.


socket.join('room name') //进入 
socket.leave('room name') //退出 




io.to('some room').emit('some event') // io.to与io.in同义，向某个聊天室的所有成员发送消息


默认聊天室


每个socket在连接成功后会自动创建一个默认个聊天室,这个聊天室的名字是当前socket的id,可以通过默认聊天室实现向特定用户发送消息


socket.on('say to someone', (id, msg) => { 
 socket.broadcast.to(id).emit('my message', msg)
})


消息发送


应答消息


普通消息不需要回应,而应答消息提供了应答机制


io.on('connection', socket => { 
 socket.emit('an event', { some: 'data' }) //普通消息

 socket.emit('ferret', 'tobi', function (data) { //应答消息
 console.log(data); // data will be 'woot'
 })
})




socket.on('ferret', (name, fn) => { 
 fn('woot')
})


压缩


socket.compress(true)启用压缩,调用后当前连接的所有数据在传递给客户端前都会进行压缩
volatile标志


socket.io在正常情况下对发送的消息进行追踪，确保消息发送成功,而设置volatile后发送消息,socket.io不会对消息追踪,消息可能丢失
分类




// 客户端发送消息
socket.emit('hello', 'can you hear me"let's play a game");

// 同时向game1和game2聊天室发送消息，自己不算
socket.to('game1').to('game2').emit('nice game', "let's play a game (too)");

// 向game聊天室的所有人发送消息
io.in('game').emit('big-announcement', 'the game will start soon');

// 发送消息到<socketid>客户端
socket.to(<socketid>).emit('hey', 'I just met you');

// 发送应答消息
socket.emit('question', 'do you think so"color: #ff0000">总结

以上就是这篇文章的全部内容了，希望本文的内容对大家的学习或者工作能带来一定的帮助，如果有疑问大家可以留言交流，谢谢大家对的支持。