local_cache_items

Author: snowinszu

.github/workflows/docker-build.yml

@@ -36,4 +36,4 @@ jobs:
                     push: true
                     platforms: linux/amd64
 #                    tags: cdnbye/cbsignal_uws:latest
-                    tags: cdnbye/cbsignal_uws:5.4.5
+                    tags: cdnbye/cbsignal_uws:5.4.6

lib/broker/redis.js

@@ -14,34 +14,34 @@ let stats = {
     curCount: 0,
 }
 
-async function connectUrl(_selfAddr, url) {
+async function connectUrl(_selfAddr, url, maxCacheItems) {
     redisCli = new Redis(url);
-    initRedis(redisCli, _selfAddr);
+    initRedis(redisCli, _selfAddr, maxCacheItems);
 }
 
-async function connect(_selfAddr, host, port, username, password, db = 0) {
+async function connect(_selfAddr, host, port, username, password, db = 0, maxCacheItems) {
     redisCli = new Redis({
         port: port, // Redis port
         host: host, // Redis host
         username: username, // needs Redis >= 6
         password: password,
         db: db, // Defaults to 0
     });
-    initRedis(redisCli, _selfAddr);
+    initRedis(redisCli, _selfAddr, maxCacheItems);
 }
 
-async function connectCluster(_selfAddr, addrs, username, password) {
+async function connectCluster(_selfAddr, addrs, username, password, maxCacheItems) {
     redisCli = new Redis.Cluster(addrs, {
         redisOptions: {
             username,
             password,
         },
     });
-    initRedis(redisCli, _selfAddr);
+    initRedis(redisCli, _selfAddr, maxCacheItems);
 }
 
-function initRedis(redisCli, _selfAddr) {
-    initCache();
+function initRedis(redisCli, _selfAddr, maxCacheItems) {
+    initCache(maxCacheItems);
     isAlive = true;
     selfAddr = _selfAddr;
 }
@@ -134,9 +134,16 @@ async function blockPopMQ(cli, timeout, addr) {
     return result[1]
 }
 
-function initCache() {
+function initCache(max = 100000) {
+    if (max <= 0) {
+        cache = {
+            get: () => {},
+            set: () => {},
+        }
+        return
+    }
     const options = {
-        max: 100000,
+        max,
 
         // for use with tracking overall storage size
         // maxSize: 5000,

lib/worker.js

@@ -48,16 +48,16 @@ const startWorker = async (config = {}) => {
         }
     }
     if (config.redis) {
-        const { url, host, port, dbname, is_cluster: isCluster, cluster, password, username } = config.redis
+        const { url, host, port, dbname, is_cluster: isCluster, cluster, password, username, local_cache_items } = config.redis
         if (url) {
             logger.info(`start connect redis url ${url}`);
-            await redis.connectUrl(selfAddr, url);
+            await redis.connectUrl(selfAddr, url, local_cache_items);
         } else if (isCluster) {
             logger.info(`start connect redis cluster`);
-            await redis.connectCluster(selfAddr, cluster, username, password);
+            await redis.connectCluster(selfAddr, cluster, username, password, local_cache_items);
         } else {
             logger.info(`start connect redis ${host}:${port} db ${dbname}`);
-            await redis.connect(selfAddr, host, port, username, password, dbname);
+            await redis.connect(selfAddr, host, port, username, password, dbname, local_cache_items);
         }
         logger.info(`redis connected`);
         redis.updateClientCount(hub.numClient);

package.json

@@ -1,6 +1,6 @@
 {
   "name": "cbsignal_uws",
-  "version": "5.4.5",
+  "version": "5.4.6",
   "description": "SwarmCloud signaling server using uWebSockets.js",
   "main": "index.js",
   "bin": "index.js",