socket.io with socket.io-redis: 获取房间中的所有套接字对象
socket.io with socket.io-redis: get all socket object in a room
我想在服务器端检索房间中连接的所有套接字。
我找到了方法 clients
如果在方法 in
return 之后链接到一个房间中的所有插座:
import * as express from 'express';
import * as SocketIO from 'socket.io';
import * as redisSocket from 'socket.io-redis';
import * as sharedsession from 'express-socket.io-session';
const app = express();
const redisOption = {port: 6379, host: 'XXX'};
// use the RedisStore as express session
const session = session({
name: 'SESSIONID',
store: new RedisStore(redisOption),
secret: 'Ashg8hV77bxFeyLVec',
resave: false,
saveUninitialized: false
});
app.use(session);
// start express server
const httpServer = app.listen(80);
// attach the express app to socket.io server
const socketServer = SocketIO(httpServer, { path: '/api/socket.io', origins: '*:*' });
// set redis as socket adpter for multi instance/nodes
socketServer.adapter(redisSocket(redisOption));
// share the express session with socket.io
socketServer.use(sharedsession(session, {autoSave: true}));
// get all client in a room
socketServer.in(room_id).clients((err, clients) => {
for (let i = 0, e = clients.length; i < e; i++) {
const client = clients[i];
console.log(client); // print the socket id
// HOW RETRIVE THE SOCKET OBJECT???
}
});
但我需要检索所有套接字session/handshake。
有一种方法可以检索所有套接字session/handshake?
旁注:套接字服务器是多个 instance/nodes 和 socket.io-redis
- socket.io: 2.3.0
- socket.io-redis: 5.2.0
Object.keys(io.sockets.sockets);它为您提供了房间中所有已连接的插座。
我不确定下面的代码是否有效,但我认为通过使用 socket.io-redis 提供的 customHook,我们可以获得基于 redis 的多节点 socket.handshake.session.
希望下面的代码对您有所帮助。
// get all client in a room
socketServer.in(room_id).clients((err, clients) => {
for (let i = 0, e = clients.length; i < e; i++) {
const client = clients[i];
console.log(client); // print the socket id
// HOW RETRIVE THE SOCKET OBJECT???
}
});
// set root namespace
const rootNamespace = socketServer.of('/');
// define customHook
rootNamespace.adapter.customHook = (request, cb) => {
// every socket.io server execute below, when customRequest requested
const type = request.type;
if(type === 'getHandShakeSession'){
// get all socket objects on local socket.io server
const sockets = rootNamespace.connected;
const socketIDs = Object.keys(sockets);
// get all socket.handshak.session array on local socket.io server
const sessions = socketIDs.map(socketID => sockets[socketID].handshake.session);
cb(sessions)
}
cb()
}
// request customRequest
rootNamespace.adapter.customRequest({type:'getHandShakeSession'},(err,replies) => {
//replies are array which element was pushed by cb(element) on individual socket.io server
//remove empty reply
const filtered = replies.filter(reply => reply !== undefined)
// filtered seems like [[session1,session2,...],[sesssion3,session4,...],..]
console.log(filtered)
} )
我想在服务器端检索房间中连接的所有套接字。
我找到了方法 clients
如果在方法 in
return 之后链接到一个房间中的所有插座:
import * as express from 'express';
import * as SocketIO from 'socket.io';
import * as redisSocket from 'socket.io-redis';
import * as sharedsession from 'express-socket.io-session';
const app = express();
const redisOption = {port: 6379, host: 'XXX'};
// use the RedisStore as express session
const session = session({
name: 'SESSIONID',
store: new RedisStore(redisOption),
secret: 'Ashg8hV77bxFeyLVec',
resave: false,
saveUninitialized: false
});
app.use(session);
// start express server
const httpServer = app.listen(80);
// attach the express app to socket.io server
const socketServer = SocketIO(httpServer, { path: '/api/socket.io', origins: '*:*' });
// set redis as socket adpter for multi instance/nodes
socketServer.adapter(redisSocket(redisOption));
// share the express session with socket.io
socketServer.use(sharedsession(session, {autoSave: true}));
// get all client in a room
socketServer.in(room_id).clients((err, clients) => {
for (let i = 0, e = clients.length; i < e; i++) {
const client = clients[i];
console.log(client); // print the socket id
// HOW RETRIVE THE SOCKET OBJECT???
}
});
但我需要检索所有套接字session/handshake。
有一种方法可以检索所有套接字session/handshake?
旁注:套接字服务器是多个 instance/nodes 和 socket.io-redis
- socket.io: 2.3.0
- socket.io-redis: 5.2.0
Object.keys(io.sockets.sockets);它为您提供了房间中所有已连接的插座。
我不确定下面的代码是否有效,但我认为通过使用 socket.io-redis 提供的 customHook,我们可以获得基于 redis 的多节点 socket.handshake.session.
希望下面的代码对您有所帮助。
// get all client in a room
socketServer.in(room_id).clients((err, clients) => {
for (let i = 0, e = clients.length; i < e; i++) {
const client = clients[i];
console.log(client); // print the socket id
// HOW RETRIVE THE SOCKET OBJECT???
}
});
// set root namespace
const rootNamespace = socketServer.of('/');
// define customHook
rootNamespace.adapter.customHook = (request, cb) => {
// every socket.io server execute below, when customRequest requested
const type = request.type;
if(type === 'getHandShakeSession'){
// get all socket objects on local socket.io server
const sockets = rootNamespace.connected;
const socketIDs = Object.keys(sockets);
// get all socket.handshak.session array on local socket.io server
const sessions = socketIDs.map(socketID => sockets[socketID].handshake.session);
cb(sessions)
}
cb()
}
// request customRequest
rootNamespace.adapter.customRequest({type:'getHandShakeSession'},(err,replies) => {
//replies are array which element was pushed by cb(element) on individual socket.io server
//remove empty reply
const filtered = replies.filter(reply => reply !== undefined)
// filtered seems like [[session1,session2,...],[sesssion3,session4,...],..]
console.log(filtered)
} )