如何在 socket.io 中获取所有连接的客户端

Question

我有 socket.io v2.3，我正在尝试从不同的文件中获取所有连接的套接字。这是我的设置：

const io = require('socket.io');
let IO;
let myNameIO;

module.exports = {
    create: (server) => {
        IO = io(server, { cors: { origin: '*' } });
        const redisConnection = redisAdapter({ host: redisHost, port: redisPort });
        IO.adapter(redisConnection);

        IO.on('connection', (socket) => {
            console.log('a user connected');
        });
        IO.on('disconnect', (socket) => {
            console.log('disconnected');
        });

        myNameIO = IO.of('/my-name');
        myNameIO.on('connection', function (socket) {
            console.log('someone connected');
        });
    },
    getIO: () => IO,
    getMyNameIO: () => myNameIO,
};

在一个差异文件中，我导入 getMyNameIO 并尝试获取所有已连接的客户端，但我遇到了麻烦。试过了

getMyNameIO().clients((error, clients) => {
    console.log(clients, '-=--=-=');
});

但客户端不是函数。然后我尝试导入 socket.io 和 use.of，但这并没有返回任何东西。哪里做错了，我该如何解决？

Answer 1

试试这个。我怀疑是范围问题或操作顺序问题。无论哪种方式，这都应该解决它或给你一个更有用的错误。我试图维护你的命名方案，这让我有点头疼。 =)

const io = require('socket.io');
const socketServer = {
    _initialized: false,
    _myNameIO: null,
    _IO: null,
    _myNameIOClients: new Map(),
    get myNameIO() {
        if (!socketServer._initialized) throw new Error('socketServer.create not called!')
        return socketServer._myNameIO
    },
    get IO() {
        if (!socketServer._initialized) throw new Error('socketServer.create not called!')
        return socketServer._IO
    },
    create: (server) => {
        IO = io(server, { cors: { origin: '*' } });
        const redisConnection = redisAdapter({ host: redisHost, port: redisPort });
        IO.adapter(redisConnection);

        IO.on('connection', (socket) => {
            console.log('a user connected');
        });
        IO.on('disconnect', (socket) => {
            console.log('disconnected');
        });

        myNameIO = IO.of('/my-name');
        myNameIO.on('connection', function (socket) {
            console.log('someone connected');
            socketServer._myNameIOClients.set(socket.id, socket)
        });

    },
    //getIO: () => IO,
    //getMyNameIO: () => myNameIO,
    getIO: () => socketServer._IO,
    getMyNameIO: () => socketServer._myNameIO,
    get myNameIOClients() {
       return socketServer._myNameIOClients
    },
    getClients: () => new Promise((resolve,reject)=>socketServer._myNameIO.clients((error, clients)=> error ? reject(error) : resolve(clients))
}),
};
module.exports = socketServer

当我执行 console.log(socketServer.myNameIO.sockets);我得到一个带有所有套接字的对象。我怎样才能得到一个数组？

查看 API https://socket.io/docs/v2/server-api/#Namespace 我没有看到对 Namespace.sockets 的引用。这并不意味着它不存在。我添加了一个 getClients 函数，该函数将返回一组客户端 ID。

const socketServer = require('./socketServer ')
socketServer.getClients()
    .then(clients=>{
       // clients an array of client IDs
    })
    .catch(e=>console.error('Error is socketServer.getClients()', e))

我认为您真正想要的是管理连接。一种方法是在连接进入时对其进行映射。

const socketServer = require('./socketServer ')

// This is a Map
let myNameIOClients = socketServer.myNameIOClients
// We can easily turn it into an array if needed
let myNameIOClientsArray = Array.from(socketServer.myNameIOClients)