NodeJS Redis - 在后台重新连接

Question

我的情况是 - 我正在尝试通过 REDIS 密钥检索资源。如果密钥不存在，则从 API 获取它。

遇到一个问题，如果 Redis 连接断开或者我无法从启动连接到 Redis，那么 nodejs 库（'redis'）将继续尝试重新连接。它阻止我通过 API 获取我需要的信息，因为重试逻辑将接管并且不会继续获取所需信息。

我希望此功能在后台运行 - 可能吗？

意思是，如果 Redis 关闭/无法从 NodeJs 连接到 REDIS，那么它将尝试重新连接。然而，当它关闭并且应用程序将尝试定期重新连接时，我希望能够通过备份计划获取数据，即通过 API，正如我上面提到的。

任何关于这种情况的指示将不胜感激 - 在此先感谢您。

Answer 1

您可以围绕您的 redis 连接创建一个包装器/代理，以确保所有 redis 操作都连接了 redis。如果不是，您可以抛出一个错误（您可以在调用者中处理）或返回未定义。基本上，您可以侦听ready和error事件并更新status该包装器内的 - 标志，以便始终了解当前的连接状态。现在，这肯定会涵盖初始连接不成功或调用之间发生断开连接的情况。问题是在您status成功检查 -flag 后断开连接的罕见情况。要解决这个问题，您可以为 redis 调用定义一个最长等待时间，如果达到超时则返回/抛出错误并忽略 redis 结果。下面是一些可以帮助您入门的基本代码：class RedisService {    isConnected = false;    client;    constructor() {        this.client = redis.createClient();        this.client.get = promisify(this.client.get).bind(this.client);        this.client.set = promisify(this.client.set).bind(this.client);        this.attachHandlers();    }    attachHandlers() {        this.client.on("ready", () => {            this.isConnected = true;        });                   this.client.on("error", (err) => {            this.isConnected = false;            console.log(err);        });    }    async tryGet(key) {        if (!this.isConnected) {            return undefined; // or throw an error        }        return Promise.race([this.client.get(key), this.wait()]);    }    async trySet(key, val) {        if (!this.isConnected) {            return undefined; // or throw an error        }        return Promise.race([this.client.set(key, val), this.wait()]);    }    wait(ms = 200) {        return new Promise(resolve => {            setTimeout(resolve, ms);        })    }}然后在你的来电者中你可以这样做：async someMethodThatCallsRedisOrApi() {    let result;    try {        result = await redisService.tryGet('testkey');    } catch (e) {        console.log(e);    }    if (!result) {        result = apiService.get(...); // call the actual api to get the result        await redisService.trySet('testkey', result);    }    res.json(result)});