2

我正在将 ioredis 与节点应用程序一起使用，由于集群中的一些问题，我开始得到：

集群重定向过多。最后一个错误：错误：连接已关闭。

因此，我所有的 redis 调用都失败了，并且在很长一段时间后，从 1 秒到 130 秒不等。

ioredis 库是否有任何默认超时，用于在向 redis 服务器发送执行命令后断言调用？

向redis服务器发送命令的失败时间更长，范围为100秒，是因为集群故障导致redis的队列大小高吗？

示例代码：

this.getData = function(bucketName, userKey) {
  let cacheKey = cacheHelper.formCacheKey(userKey, bucketName);
  let serviceType = cacheHelper.getServiceType(bucketName, cacheConfig.service_config);
  let log_info = _.get(cacheConfig.service_config, 'logging_options.cache_info_level', true);
  let startTime = moment();
  let dataLength = null;
  return Promise.try(function(){
    validations([cacheKey], ['cache_key'], bucketName, serviceType, that.currentService);
    return cacheStore.get(serviceType, cacheKey);
  })
  .then(function(data) {
    dataLength = (data || '').length;
    return cacheHelper.uncompress(data);
  })
  .then(function(uncompressedData) {
    let endTime = moment();
    let responseTime = endTime.diff(startTime, 'miliseconds');
    if(!uncompressedData) {
      if(log_info) logger.consoleLog(bucketName, 'getData', 'miss', cacheKey, that.currentService,
        responseTime, dataLength);
    } else {
      if(log_info) logger.consoleLog(bucketName, 'getData', 'success', cacheKey, that.currentService,
        responseTime, dataLength);
    }
    return uncompressedData;
  })
  .catch(function(err) {
    let endTime = moment();
    let responseTime = endTime.diff(startTime, 'miliseconds');
    logger.error(bucketName, 'getData', err.message, userKey, that.currentService, responseTime);
    throw cacheResponse.error(err);
  });
};

这里 logger.error(bucketName, 'getData', err.message, userKey, that.currentService, responseTime);

开始给出 1061ms 到 109939ms 范围内的响应时间。

请提供一些输入。

4

2 回答 2

2

正如您可以从这个ioredis 问题中看到的那样，没有每个命令的超时配置。

正如链接评论中所建议的那样，您可以使用基于 Promise 的策略作为解决方法。顺便说一句，这与ioredis-timeout 插件使用的策略相同，它将原始命令包装在一个Promise.race()方法中：

//code from the ioredis-timeout lib
return Promise.race([
      promiseDelay(ms, command, args),
      originCommand.apply(redis, args)
]);

因此，您可以使用插件或这种不错的race超时技术在 redis 客户端之上添加超时功能。请记住，底层命令不会被中断。

于 2019-03-28T08:53:41.807 回答
0

我遇到了一个类似的问题，我在这里详细描述了：如何配置 Node Redis 客户端以在连接失败时立即抛出错误？[阅读详情]

修复实际上非常简单，只需设置enable_offline_queue为 false。这是使用 Node Redis 的，所以你必须找出 IORedis 的等价物。将此设置为 false，将使所有命令立即抛出异常，您可以在 catch 块中处理并继续，而不是等待超时。

请记住，enable_offline_queue设置为 false 时，您在与服务器存在连接问题时发出的命令将永远不会被执行。

于 2021-03-31T20:12:15.663 回答