可以通过io.use()为socket.io服务器提供任意函数,该函数在创建socket时运行。查看此示例:
const srv=require('http').createServer();
const io = require('socket.io')(srv)
let run=0;
io.use((socket,next)=>{
run++; //0->1
next()
});
io.use((socket,next)=>{
run++;// 1->2
next();
})
const socket=require('socket.io-client')();
socket.io('connect',()=>{
// run 此时等于2
})
旧的io.set()
和io.get()
已弃用,只能支持向后兼容。下面是一个将旧的授权示例转换为中间件样式的转换:
io.set('authorization',(handshakeData,callback)=>{
//确保握手数据看起来不错
callback(null,true)//出错,'authorized' boolean second
})
新的:
io.use((socket,next)=>{
const handshakeData= socket.request;
// 确保握手数据看起来和以前一样好
// 如果错误,则执行这个:
// next(new Error('not authorized'));
// 否则回调next
next();
})
io.of('/namespace').use((socket,next)=>{
const handshakeData= socket.request;
next()
})