根据 Node.js 事件循环关闭 Redis 连接

Question

问题/我是如何运行进入的

我正在 Node.JS 中编写一个批处理 Lambda 函数，它在两个不同的地方调用 Redis。一些批处理项可能永远不会到达第二次 Redis 调用。这一切都是异步发生的，所以如果我在批处理队列为空时立即关闭连接，任何未来的 Redis 调用都会失败。如何关闭连接？

我试过的

process.on('beforeExit', callback) -- 不会被调用，因为事件循环仍然包含 Redis 连接
client.unref() -- 如果没有待处理的命令，则关闭连接。不处理未来的电话。
client.on('idle', callback) -- 有效但已弃用，可能仍会错过未来的电话

我现在在做什么

一旦批处理队列为空，我调用：

intervalId = setInterval(closeRedis, 1000);

我关闭Redis连接并在超时后清除回调中的间隔：

function closeRedis() {
    redis.client('list', (err, result) => {
        var idle = parseClientList(result, 'idle');

        if (idle > timeout) {
            redis.quit();
            clearInterval(intervalId);
        }
    });
}

这种方法大部分可行，但如果只是检查超时，仍有可能其他进程正在进行，并且将来可能会调用 Redis。当事件循环中只剩下一个空闲连接时，我想关闭连接。有办法吗？

Answer 1

我最终使用了 process._getActiveHandles()。一旦批处理队列为空，我将设置一个时间间隔以每半秒检查一次是否只剩下最少的进程。如果是这样，我取消引用 redisClient。

redisIntervalId = setInterval(closeRedis, 500);

// close redis client connection if it's the last required process
function closeRedis() {
    // 2 core processes plus Redis and interval
    var minimumProcesses = 4;
    if (process._getActiveHandles().length > minimumProcesses)
        return;

    clearInterval(redisIntervalId);
    redisClient.unref();
}

这种方法的优点是我可以确定 Redis 客户端不会在其他重要进程 [=20=] 时关闭连接。我也可以确定客户端不会在所有重要进程完成后保持事件循环处于活动状态。

缺点是 _getActiveHandles() 是一个未记录的节点函数，因此它可能会在以后更改或删除。此外，unref() 是实验性的，在关闭连接时不考虑某些 Redis 命令。

根据 Node.js 事件循环关闭 Redis 连接

Close a Redis connection based on Node.js Event loop

redis

node.js

node-redis

aws-lambda