Redis Stream的XReadGroup设Block为0时闲置后无法读取新消息

• 检查连接超时与自动重连：Block=0的永久阻塞依赖稳定的Redis连接，若网络中间件（防火墙、代理）或Redis服务器有空闲连接超时机制，超过10-12小时会断开连接，导致阻塞请求静默失效。需在客户端配置中开启自动重连，同时在XReadGroup调用后增加错误检测，若捕获到连接类错误，主动重建连接后再发起读取请求。

• 调整Redis的TCP保活配置：Redis默认tcp-keepalive为300秒，若网络环境对空闲连接限制更严格，可将该值调至更大（如3600秒），让Redis主动发送心跳包维持连接，避免被中间设备断开。修改Redis配置文件后重启生效。

• 改用短阻塞循环替代永久阻塞：放弃Block=0的永久阻塞，设置合理的短阻塞时长（如30秒），通过循环持续发起XReadGroup请求。即使某次连接异常，下一次循环会重新建立连接，不会长期卡住。调整后的示例代码：

  for {
      data, err := w.rdb.XReadGroup(ctx, &redis.XReadGroupArgs{
          Group:    w.opts.group,
          Consumer: w.opts.consumer,
          Streams:  []string{w.opts.streamName, ">"},
          Count:    1,
          Block:    30000, // 30秒超时
      }).Result()
      if err != nil {
          // 日志记录错误，短暂重试后继续
          time.Sleep(time.Second)
          continue
      }
      // 处理消息业务逻辑
  }
  

• 维护消费者组状态：Redis消费者组会自动清理长时间未活动的消费者（默认10分钟），闲置过久可能导致当前消费者被移除。可通过XGROUP SETIDLE延长消费者超时时间，或在循环中定期用XINFO CONSUMERS检查状态，确保消费者持续有效。

• 升级Redis客户端库：若使用的是go-redis等客户端，旧版本可能存在永久阻塞场景下的连接泄漏或重连bug，升级到最新稳定版可解决这类兼容性问题。

内容的提问来源于stack exchange，提问作者Sanketh Kini