Блог

Я использую сокет.ввод-вывод вместе с redis и мне нужно получить объект сокета, так как мне нужно получить доступ к данным, добавленным во время промежуточного программного обеспечения.

Когда я это сделаю:

 const { socketServer } = require('../../socket/socket');
const allSockets = await socketServer.myNamespace.adapter.sockets(new Set());
 

Я получаю только идентификатор сокета, а не объект сокета. Как я могу получить объект сокета?

Используя:
socket.io: 4.0.1.
socket.io-redis: 6.1.0

Обновить

 const socketServer = {
    _initialized: false,
    _IO: null,
    _myNamespace: null,
    get IO() {
        if (!socketServer._initialized) throw new Error('socketServer.create not called!');
        return socketServer._IO;
    },
    get myNamespace() {
        if (!socketServer._initialized) throw new Error('socketServer.create not called!');
        return socketServer._myNamespace;
    },
    create: (server) => {
        const { initMyNamespace } = require('./setupHandler');

        socketServer._IO = io(server, { cors: { origin: '*' } });

        const redisPort = config.get('redisPort');
        const redisHost = config.get('redisHost');

        const redisConnection = redisAdapter({ host: redisHost, port: redisPort });

        socketServer._IO.adapter(redisConnection);

        // inits
        socketServer._myNamespace = socketServer._IO.of('myNamespace');

        // Middlewares
        socketServer._myNamespace.use(auth);

        socketServer._myNamespace.on('connection', function (socket) {
            initMyNamespace(socket);
        });
    
        socketServer._initialized = true;
    },
};
 

В другом файле при вызове api:

 router.post('/', async (req, res) => {
    const { socketServer } = require('../../socket/socket');

    let selectedSockets = [];
    const allSockets = await socketServer.myNamespace.adapter.sockets(new Set());
    
    const userCoordinates = req.body.coordinates;
    for (const currentSocketObj of allSockets) {
        if (isNear(userCoordinates, currentSocketObj.user.coordinates)) {
            const distanceToLocation = distanceCalc(userCoordinates, currentSocketObj.user.coordinates);
            currentSocketObj.distanceToLocation = distanceToLocation;
            selectedSockets.push(currentSocketObj);
        }
    }
    
    for (const currentSocketObj of selectedSockets) {
        currentSocketObj.emit('testing123', {distance: currentSocketObj.distanceToLocation} );
    }
});
 

В socket.io v4, вы можете сделать:

 // return all Socket instances
const sockets = await io.fetchSockets();
 

или, если у вас есть сокет, вы можете получить сокет для этого с помощью этого:

 // return all Socket instances in the "room1" room of the main namespace
const sockets = await io.in(theSocketID).fetchSockets();
 

Оба вызова возвращают итерацию сокетов.

Если (согласно вашему комментарию) вы пытаетесь получить конкретный сокет, который находится в процессе подключения, то socket он уже должен быть в области действия на основе обработчика событий, который вызвал вас в первую очередь. Если вы покажете этот код в контексте, мы, вероятно, сможем показать socket , что в нем содержится ссылка.