15

First, let me tell you how I'm using Redis connection in my NodeJS application:

  • I'm re-using one connection throughout the app using a singleton class.
class RDB {

    static async getClient() {
        if (this.client) {
            return this.client
        }

        let startTime = Date.now();

        this.client = createClient({
            url: config.redis.uri
        });

        await this.client.connect();

        return this.client;
    }

}

For some reason - that I don't know - time to time my application crashes giving an error without any reason - this happens about once or twice a week:

Error: Socket closed unexpectedly

Now, my questions:

  1. Is using Redis connections like this alright? Is there something wrong with my approach?
  2. Why does this happen? Why is my socket closing unexpectedly?
  3. Is there a way to catch this error (using my approach) or any other good practice for implementing Redis connections?

6 Answers 6

13

I solved this using the 'error' listener. Just listening to it - saves the node application from crashing.

client.on("error", function(error) {
   console.error(error);
   // I report it onto a logging service like Sentry. 
});
Sign up to request clarification or add additional context in comments.

3 Comments

Does the error say why its crashing?
Probably a timeout from an unused socket.
Does the client reconnect automatically?
6

I had similar issue of socket close unexpectedly. The issue started while I upgraded node-redis from 3.x to 4.x. The issue was gone after I upgraded my redis-server from 5.x to 6.x.

Comments

4

You should declare a private static member 'client' of the RDB class, like this:

private static client;

In a static method, you can't reference instance of 'this', you need to reference the static class member like this:

RDB.client

And it would be better to check, whether the client's connection is open, rather than simply checking if the client exists (considering you are using the 'redis' npm library). Like this:

if (RDB.client && RDB.client.isOpen)

After the changes, your code should look like this:

class RDB {
    private static client;

    static async getClient() {
        if (RDB.client && RDB.client.isOpen) {
            return RDB.client;
        }

        RDB.client = createClient({
            url: config.redis.uri
        });

        await RDB.client.connect();

        return RDB.client;
    }
}

Note: the connect() method and isOpen property only exist in redis version ^4.0.0.

Comments

4

I got the same issue (Socket Closed Unexpectedly) but only with the remote Redis servers, so I figured out that maybe there is a problem with the TLS. So I tried to use redis:// instead of rediss://, and yes it was working stable.

Comments

1

There is option pingInterval you can pass to createClient function to keep socket alive. Ping server every 3 seconds.

export const redis = createClient({
    url: 'redis://localhost:6379',
    pingInterval: 3000,
});

Comments

0

I switched to ioredis with the same configuration and this issue is gone.

Comments

Your Answer

By clicking “Post Your Answer”, you agree to our terms of service and acknowledge you have read our privacy policy.

Start asking to get answers

Find the answer to your question by asking.

Ask question

Explore related questions

See similar questions with these tags.