You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
How can I use the Redis adapter (@socket.io/redis-adapter) with the Redis cluster?
import { Server } from "socket.io";
import dotenv from 'dotenv';
import { createCluster, createClient } from 'redis';
import { createAdapter } from "@socket.io/redis-adapter";
import startTrackingDevices from './src/sockets/startTrackingDevices';
import stopTrackingDevices from './src/sockets/stopTrackingDevices';
import onDisconnecting from './src/sockets/onDisconnecting';
import { logger } from './src/services/loggingService';
import corsConfig from './src/configs/cors';
dotenv.config();
const httpServer = http.createServer();
const io = new Server(httpServer, corsConfig);
const pubClient = createCluster({
rootNodes: [{"url":"redis://x.x.x.184:6379"},{"url":"redis://x.x.x.179:6379"},{"url":"redis://x.x.x.176:6379"},{"url":"redis://x.x.x.178:6379"},{"url":"redis://x.x.x.181:6379"},{"url":"redis://x.x.x.177:6379"}]
});
const subClient = pubClient.duplicate();
// use the cluster adapter
io.adapter(createAdapter(pubClient, subClient));
io.on("connection", (socket: any) => {
logger.info(`New user connected with id: ${socket.id}`);
try {
startTrackingDevices(io, socket);
stopTrackingDevices(io, socket);
onDisconnecting(io, socket);
} catch (error) {
logger.error(`Error on socket IO event: ${error}`);
}
});
I have this error:
[1] /home/inikolov/projects/websocket-server-nodejs/node_modules/@redis/client/dist/lib/cluster/cluster-slots.js:394
[1] address: node.address,
[1] ^
[1]
[1] TypeError: Cannot read properties of undefined (reading 'address')
[1] at RedisClusterSlots._RedisClusterSlots_initiatePubSubClient (/home/inikolov/projects/websocket-server-nodejs/node_modules/@redis/client/dist/lib/cluster/cluster-slots.js:394:23)
[1] at RedisClusterSlots.getPubSubClient (/home/inikolov/projects/websocket-server-nodejs/node_modules/@redis/client/dist/lib/cluster/cluster-slots.js:133:118)
[1] at Commander.PSUBSCRIBE (/home/inikolov/projects/websocket-server-nodejs/node_modules/@redis/client/dist/lib/cluster/index.js:158:78)
[1] at new RedisAdapter (/home/inikolov/projects/websocket-server-nodejs/node_modules/@socket.io/redis-adapter/dist/index.js:89:28)
[1] at new <anonymous> (/home/inikolov/projects/websocket-server-nodejs/node_modules/@socket.io/redis-adapter/dist/index.js:49:16)
[1] at Namespace._initAdapter (/home/inikolov/projects/websocket-server-nodejs/node_modules/socket.io/dist/namespace.js:93:24)
[1] at Server.adapter (/home/inikolov/projects/websocket-server-nodejs/node_modules/socket.io/dist/index.js:188:17)
[1] at Object.<anonymous> (/home/inikolov/projects/websocket-server-nodejs/dist/server.js:26:4)
[1] at Module._compile (node:internal/modules/cjs/loader:1241:14)
[1] at Module._extensions..js (node:internal/modules/cjs/loader:1295:10)
reacted with thumbs up emoji reacted with thumbs down emoji reacted with laugh emoji reacted with hooray emoji reacted with confused emoji reacted with heart emoji reacted with rocket emoji reacted with eyes emoji
-
How can I use the Redis adapter (@socket.io/redis-adapter) with the Redis cluster?
I have this error:
What I'm doing wrong?
Beta Was this translation helpful? Give feedback.
All reactions