Redis NodeJs server error,client is closed

Question

I am developing an application where chats has to cached and monitored, currently it is an local application where i have installed redis and redis-cli. The problem i'm facing is (node:5368) UnhandledPromiseRejectionWarning: Error: The client is closed Attaching code snippet below

//redis setup
const redis = require('redis');
const client = redis.createClient()//kept blank so that default options are available
  

//runs when client connects
io.on("connect", function (socket) {

  //this is client side socket
  //console.log("a new user connected...");

  socket.on("join", function ({ name, room }, callback) {
    //console.log(name, room);
    const { msg, user } = addUser({ id: socket.id, name, room });
   // console.log(user);
    if (msg) return callback(msg); //accessible in frontend

    //emit to all users
    socket.emit("message", {
      user: "Admin",
      text: `Welcome to the room ${user.name}`,
    });
    //emit to all users except current one
  
    socket.broadcast
      .to(user.room)
      .emit("message", { user: "Admin", text: `${user.name} has joined` });

    socket.join(user.room); //pass the room that user wants to join

    //get all users in the room
    io.to(user.room).emit("roomData", {
      room: user.room,
      users: getUsersInRoom(user.room),
    });

    callback();
  }); //end of join

  //user generated messages
  socket.on("sendMessage",  async(message, callback)=>{
    const user = getUser(socket.id);

    //this is where we can store the messages in redis
    await client.set("messages",message);

    io.to(user.room).emit("message", { user: user.name, text: message });
    console.log(client.get('messages'));
    callback();
  }); //end of sendMessage

  //when user disconnects
  socket.on("disconnect", function () {
    const user = removeUser(socket.id);
    if (user) {
     
      console.log(client)

      io.to(user.room).emit("message", {
        user: "Admin",
        text: `${user.name} has left `,
      });
    }
  }); //end of disconnect

I am getting above error when user sends a message to the room or when socket.on("sendMessage") is called.

Where am I going wrong?

Thank you in advance.

Leibale Eidelman · Accepted Answer · 2021-12-01 20:16:19Z

93

You should await client.connect() before using the client

answered Dec 1, 2021 at 20:16

Leibale Eidelman

3,2951 gold badge20 silver badges31 bronze badges

Sign up to request clarification or add additional context in comments.

1 Comment

Makarand Over a year ago

Thank you for your answer @Leibale Eidelman :)

SemperFi · Accepted Answer · 2025-06-21 06:38:50Z

51

In node-redis V4, the client does not automatically connect to the server, you need to run .connect() before any command, or you will receive error ClientClosedError: The client is closed.

To solve the issue, do the following:-

import { createClient } from 'redis';

const client = createClient();

await client.connect();

Or you can use legacy mode to preserve the backwards compatibility

const client = createClient({
    legacyMode: true
});

edited Jun 21 at 6:38

SemperFi

2,3786 gold badges35 silver badges53 bronze badges

answered Jan 13, 2022 at 8:03

Asad Fida

6834 silver badges10 bronze badges

3 Comments

hane Smitter Over a year ago

you are calling await outside of an async function

Asad Fida Over a year ago

you can wrap in async method like (async () => { await client.connect(); })();

SemperFi Jun 21 at 6:37

really helped me

Taylor Maxwell · Accepted Answer · 2022-12-02 21:32:46Z

7

I was having a similar problem and was able to change the connect code as follows.

const client = redis.createClient({
  legacyMode: true,
  PORT: 5001
})
client.connect().catch(console.error)

answered Dec 2, 2022 at 21:32

Taylor Maxwell

1561 silver badge10 bronze badges

Comments

cnminhh · Accepted Answer · 2022-06-22 13:31:31Z

6

client.connect() returns a promise. You gotta use .then() because you cannot call await outside of a function.

const client = createClient();  
client.connect().then(() => {
  ...
})

edited Jun 22, 2022 at 13:31

answered Jun 16, 2022 at 17:06

cnminhh

612 silver badges3 bronze badges

1 Comment

Tyler2P Over a year ago

Your answer could be improved by adding more information on what the code does and how it helps the OP.

Sachitha Hirushan · Accepted Answer · 2022-09-27 17:59:05Z

3

You cannot call await outside of a function.

const redis = require('redis');
const client = redis.createClient();

client
  .connect()
  .then(async (res) => {
    console.log('connected');
    // Write your own code here

    // Example
    const value = await client.lRange('data', 0, -1);
    console.log(value.length);
    console.log(value);
    client.quit();
  })
  .catch((err) => {
    console.log('err happened' + err);
  });

answered Sep 27, 2022 at 17:59

Sachitha Hirushan

6656 silver badges13 bronze badges

Comments

Okere chinedu · Accepted Answer · 2023-04-20 23:22:22Z

you cannot call await outside of a function. This is what i did that worked me.

const redis = require('redis');

const redisClient = redis.createClient()

redisClient.on('connect', () => {
    console.log('Connected to Redis12345');
})

redisClient.on('error', (err) => {
    console.log(err.message);
})

redisClient.on('ready', () => {
    console.log('Redis is ready');
})

redisClient.on('end', () => {
    console.log('Redis connection ended');
})

process.on('SIGINT', () => {
    redisClient.quit();
})

redisClient.connect().then(() => {
    console.log('Connected to Redis');
}).catch((err) => {
    console.log(err.message);
})

In app.js

//just for testing

const redisClient = require('./init_redis')

redisClient.SET('elon', 'musk', redisClient.print)

mesutpiskin · Accepted Answer · 2023-03-26 20:22:40Z

2

use "redis": "3.1.2", version.

answered Mar 26, 2023 at 20:22

mesutpiskin

1,9672 gold badges28 silver badges30 bronze badges

3 Comments

Lin Du Over a year ago

Why? Please explain.

mesutpiskin Over a year ago

github.com/redis/node-redis/issues/1780

Amit K. Over a year ago

using 3.1.2 version fixed my issue . I am using redis 3.2.12 Cant i use redis latest npm package with this version ? @mesutpiskin

Raviraj Gardi · Accepted Answer · 2023-11-15 11:34:12Z

1

It may happen that another instance is using the port and hence it won't allow us to use the same port. You can try the new port or you can check using

netstat -ano | find "6379"

this will return PID

if there is a process on that port you can kill it using

taskkill /F /PID <pid>

Then restart the process of connecting.

answered Nov 15, 2023 at 11:34

Raviraj Gardi

3383 silver badges11 bronze badges

Comments

Dm Mh · Accepted Answer · 2024-02-21 10:03:41Z

1

My setup for redis v4.6.13 package

const { createClient } = require('redis');
const { config } = require('../../config');
const redisConfig = config.redis;

exports.redisClientInit = async () => {
   const client = await createClient({
      socket: {
        host: redisConfig.host,
        rejectUnauthorized: true
      },
      username: redisConfig.user,
      password: redisConfig.password
   });

  await client.connect();

  return client;
};

And I use it like that

const redis = await redisClientInit();

redis.set('new test 3', 'abc');

Result

answered Feb 21, 2024 at 10:03

Dm Mh

8407 silver badges10 bronze badges

Collectives™ on Stack Overflow

Redis NodeJs server error,client is closed

9 Answers 9

1 Comment

3 Comments

Comments

1 Comment

Comments

Comments

3 Comments

Comments

Comments

Your Answer

Linked

Hot Network Questions

Collectives™ on Stack Overflow

9 Answers 9

1 Comment

3 Comments

Comments

1 Comment

Comments

Comments

3 Comments

Comments

Comments

Your Answer

Sign up or log in

Post as a guest

Linked

Related