监听 Redis 连接事件 - 让不可见的脆弱变得可见

import Redis from 'ioredis'

const redis = new Redis({
  host: 'localhost',
  port: 6379,
  retryStrategy: (times) => {
    // 重试延迟随次数增加
    return Math.min(times * 50, 2000)
  }
})

// 连接建立成功
redis.on('connect', () => {
  console.log('Redis 连接已建立')
})

// 准备好接收命令
redis.on('ready', () => {
  console.log('Redis 已就绪，可以执行命令')
})

// 连接发生错误
redis.on('error', (err) => {
  console.error('Redis 连接错误:', err.message)
})

// 连接关闭
redis.on('close', () => {
  console.log('Redis 连接已关闭')
})

// 连接完全断开
redis.on('end', () => {
  console.log('Redis 连接已终止，不会重连')
})

// 开始重连
redis.on('reconnecting', (delay) => {
  console.log(`Redis 正在重连，延迟 ${delay}ms`)
})

let isRedisAvailable = false
let failedCommandCount = 0

redis.on('ready', () => {
  isRedisAvailable = true
  failedCommandCount = 0
  console.log('Redis 服务恢复')
})

redis.on('error', (err) => {
  isRedisAvailable = false
  failedCommandCount++

  // 错误累积到一定程度，触发告警
  if (failedCommandCount > 10) {
    sendAlert('Redis 连接持续失败')
  }
})

// 在执行命令前检查状态
async function safeGet(key) {
  if (!isRedisAvailable) {
    // 降级到本地缓存或直接返回 null
    return null
  }

  try {
    return await redis.get(key)
  } catch (err) {
    console.error('Redis 命令执行失败:', err)
    return null
  }
}

const redis = new Redis({
  host: 'localhost',
  port: 6379,
  retryStrategy: (times) => {
    // 重试超过 10 次，放弃重连
    if (times > 10) {
      console.error('Redis 重连次数超限，停止重连')
      return null // 返回 null 停止重连
    }

    // 指数退避，最长等待 2 秒
    const delay = Math.min(times * 50, 2000)
    console.log(`第 ${times} 次重连，延迟 ${delay}ms`)
    return delay
  },

  // 连接超时设置
  connectTimeout: 10000,

  // 最大重连次数
  maxRetriesPerRequest: 3
})

redis.on('connect', () => {
  logger.info('Redis 连接建立', {
    host: redis.options.host,
    port: redis.options.port
  })
})

redis.on('error', (err) => {
  logger.error('Redis 连接错误', {
    error: err.message,
    stack: err.stack,
    host: redis.options.host
  })
})

redis.on('close', () => {
  logger.warn('Redis 连接关闭', {
    host: redis.options.host,
    time: new Date().toISOString()
  })
})

let reconnectCount = 0
let lastReconnectTime = null

redis.on('reconnecting', () => {
  reconnectCount++
  lastReconnectTime = Date.now()

  // 1 分钟内重连超过 5 次，触发告警
  if (reconnectCount > 5) {
    sendAlert({
      level: 'critical',
      message: 'Redis 连接不稳定，频繁重连',
      count: reconnectCount
    })
  }
})

redis.on('ready', () => {
  // 连接恢复，重置计数
  if (reconnectCount > 0) {
    logger.info(`Redis 连接恢复，之前重连了 ${reconnectCount} 次`)
    reconnectCount = 0
  }
})