Added keep-alive for clients.

Author: fenying

CHANGES.md

@@ -1,5 +1,9 @@
 # Changes Logs
 
+## v0.1.7
+
+- Added keep-alive for clients.
+
 ## v0.1.6
 
 - Auto switch to the selected database.

package-lock.json

@@ -1,6 +1,6 @@
 {
   "name": "@litert/redis",
-  "version": "0.1.6",
+  "version": "0.1.7",
   "description": "A redis protocol implement for Node.js.",
   "main": "./dist/index.js",
   "scripts": {

package.json

@@ -35,6 +35,8 @@ implements Abstract.RedisClient {
 
     private _listeners!: Dict<Array<Abstract.SubscriptionCallback | Readable>>;
 
+    private _keepAlive: any;
+
     public constructor(
         connection: Net.Socket,
         host: string,
@@ -45,6 +47,14 @@ implements Abstract.RedisClient {
 
         super(connection, host, port, createDecoder, createEncoder);
 
+        this._keepAlive = setInterval(() => {
+
+            if (this._status === Abstract.ClientStatus.NORMAL) {
+
+                this.executeNow("PING").catch((e) => this.emit("error", e));
+            }
+        }, 5000);
+
         this._database = 0;
     }
 
@@ -1313,6 +1323,8 @@ implements Abstract.RedisClient {
             delete this._subscriber;
         }
 
+        clearInterval(this._keepAlive);
+
         return super.close();
     }
 

sources/lib/RedisClient.ts

@@ -34,6 +34,8 @@ implements Abstract.ProtocolClient {
 
     protected _password: string;
 
+    private _keepAlive: any;
+
     public constructor(
         connection: Net.Socket,
         host: string,
@@ -44,6 +46,14 @@ implements Abstract.ProtocolClient {
     ) {
         super(connection, host, port, createDecoder, createEncoder);
 
+        this._keepAlive = setInterval(() => {
+
+            if (this._status === Abstract.ClientStatus.NORMAL) {
+
+                this.executeNow("PING").catch((e) => this.emit("error", e));
+            }
+        }, 5000);
+
         this._subjects = [];
         this._patterns = [];
         this._password = password;
@@ -316,6 +326,13 @@ implements Abstract.ProtocolClient {
 
         return ret;
     }
+
+    public async close(): Promise<void> {
+
+        clearInterval(this._keepAlive);
+
+        return super.close();
+    }
 }
 
 export default SubscriberClient;