Estratégias de Cache Redis Que Realmente Funcionam em Produção

import Redis from "ioredis";
 
const redis = new Redis({
  host: process.env.REDIS_HOST || "127.0.0.1",
  port: Number(process.env.REDIS_PORT) || 6379,
  password: process.env.REDIS_PASSWORD || undefined,
  db: Number(process.env.REDIS_DB) || 0,
  maxRetriesPerRequest: 3,
  retryStrategy(times) {
    const delay = Math.min(times * 200, 5000);
    return delay;
  },
  lazyConnect: true,
  enableReadyCheck: true,
  connectTimeout: 10000,
});
 
redis.on("error", (err) => {
  console.error("[Redis] Connection error:", err.message);
});
 
redis.on("connect", () => {
  console.log("[Redis] Connected");
});
 
export default redis;

import redis from "./redis";
 
interface CacheOptions {
  ttl?: number; // segundos
  prefix?: string;
}
 
async function cacheAside<T>(key: string, fetcher: () => Promise<T>, options: CacheOptions = {}): Promise<T> {
  const { ttl = 3600, prefix = "cache" } = options;
  const cacheKey = `${prefix}:${key}`;
 
  // Passo 1: Tentar ler do cache
  const cached = await redis.get(cacheKey);
 
  if (cached !== null) {
    try {
      return JSON.parse(cached) as T;
    } catch {
      // Entrada de cache corrompida, deletar e continuar
      await redis.del(cacheKey);
    }
  }
 
  // Passo 2: Cache miss — buscar da fonte
  const result = await fetcher();
 
  // Passo 3: Armazenar no cache (não await — fire and forget)
  redis.set(cacheKey, JSON.stringify(result), "EX", ttl).catch((err) => {
    console.error(`[Cache] Failed to set ${cacheKey}:`, err.message);
  });
 
  return result;
}

interface User {
  id: string;
  name: string;
  email: string;
  plan: "free" | "pro" | "enterprise";
}
 
async function getUser(userId: string): Promise<User | null> {
  return cacheAside<User | null>(
    `user:${userId}`,
    async () => {
      const row = await db.query("SELECT * FROM users WHERE id = $1", [userId]);
      return row[0] ?? null;
    },
    { ttl: 1800 }, // 30 minutos
  );
}

async function getUserSafe(userId: string): Promise<User | null> {
  return cacheAside<User | null>(
    `user:${userId}`,
    async () => {
      const row = await db.query("SELECT * FROM users WHERE id = $1", [userId]);
      return row[0] ?? null;
    },
    {
      // TTL mais curto para resultados nulos para limitar uso de memória
      // mas longo o suficiente para absorver misses repetidos
      ttl: row ? 1800 : 300,
    },
  );
}

async function getUserWithDynamicTTL(userId: string): Promise<User | null> {
  const cacheKey = `cache:user:${userId}`;
 
  const cached = await redis.get(cacheKey);
  if (cached !== null) {
    return JSON.parse(cached) as User | null;
  }
 
  const row = await db.query("SELECT * FROM users WHERE id = $1", [userId]);
  const user: User | null = row[0] ?? null;
 
  // Cachear resultados existentes por 30 min, resultados nulos por 5 min
  const ttl = user ? 1800 : 300;
  await redis.set(cacheKey, JSON.stringify(user), "EX", ttl);
 
  return user;
}

async function updateUser(userId: string, updates: Partial<User>): Promise<User> {
  // Passo 1: Atualizar o banco de dados
  const updated = await db.query(
    "UPDATE users SET name = COALESCE($2, name), email = COALESCE($3, email) WHERE id = $1 RETURNING *",
    [userId, updates.name, updates.email],
  );
  const user: User = updated[0];
 
  // Passo 2: Atualizar o cache imediatamente
  const cacheKey = `cache:user:${userId}`;
  await redis.set(cacheKey, JSON.stringify(user), "EX", 1800);
 
  return user;
}

async function updateUserWriteBehind(userId: string, updates: Partial<User>): Promise<User> {
  const cacheKey = `cache:user:${userId}`;
 
  // Ler estado atual
  const current = await redis.get(cacheKey);
  const user = current ? (JSON.parse(current) as User) : null;
  if (!user) throw new Error("User not in cache");
 
  // Atualizar cache imediatamente
  const updated = { ...user, ...updates };
  await redis.set(cacheKey, JSON.stringify(updated), "EX", 1800);
 
  // Enfileirar escrita no banco de dados para processamento assíncrono
  await redis.rpush("write_behind:users", JSON.stringify({ userId, updates, timestamp: Date.now() }));
 
  return updated;
}

async function processWriteBehindQueue(): Promise<void> {
  while (true) {
    const item = await redis.blpop("write_behind:users", 5);
 
    if (item) {
      const { userId, updates } = JSON.parse(item[1]);
      try {
        await db.query("UPDATE users SET name = COALESCE($2, name), email = COALESCE($3, email) WHERE id = $1", [
          userId,
          updates.name,
          updates.email,
        ]);
      } catch (err) {
        // Re-enfileirar em caso de falha com contagem de tentativas
        console.error("[WriteBehind] Failed:", err);
        await redis.rpush("write_behind:users:dlq", item[1]);
      }
    }
  }
}

const TTL = {
  // Camada 1: Raramente muda, caro de computar
  // Exemplos: catálogo de produtos, config do site, feature flags
  STATIC: 86400, // 24 horas
 
  // Camada 2: Muda ocasionalmente, custo moderado
  // Exemplos: perfis de usuário, configurações de time, permissões
  MODERATE: 1800, // 30 minutos
 
  // Camada 3: Muda frequentemente, barato de computar mas chamado frequentemente
  // Exemplos: dados de feed, contagem de notificações, info de sessão
  VOLATILE: 300, // 5 minutos
 
  // Camada 4: Efêmero, usado para rate limiting e locks
  EPHEMERAL: 60, // 1 minuto
 
  // Resultados nulos: sempre de curta duração
  NOT_FOUND: 120, // 2 minutos
} as const;

function ttlWithJitter(baseTtl: number, jitterPercent = 0.1): number {
  const jitter = baseTtl * jitterPercent;
  const offset = Math.random() * jitter * 2 - jitter;
  return Math.max(1, Math.round(baseTtl + offset));
}
 
// Em vez de: redis.set(key, value, "EX", 3600)
// Use:        redis.set(key, value, "EX", ttlWithJitter(3600))
 
// 3600 ± 10% = valor aleatório entre 3240 e 3960

const ttl = ttlWithJitter(3600, 0.2); // 2880–4320 segundos

async function getWithSlidingExpiry<T>(key: string, ttl: number): Promise<T | null> {
  // GETEX atomicamente obtém o valor E reseta o TTL
  const value = await redis.getex(key, "EX", ttl);
  if (value === null) return null;
  return JSON.parse(value) as T;
}

async function getWithSlidingExpiryCompat<T>(key: string, ttl: number): Promise<T | null> {
  const pipeline = redis.pipeline();
  pipeline.get(key);
  pipeline.expire(key, ttl);
  const results = await pipeline.exec();
 
  if (!results || !results[0] || results[0][1] === null) return null;
  return JSON.parse(results[0][1] as string) as T;
}

async function cacheAsideWithMutex<T>(key: string, fetcher: () => Promise<T>, ttl: number = 3600): Promise<T | null> {
  const cacheKey = `cache:${key}`;
  const lockKey = `lock:${key}`;
 
  // Tentar cache primeiro
  const cached = await redis.get(cacheKey);
  if (cached !== null) {
    return JSON.parse(cached) as T;
  }
 
  // Tentar adquirir lock (NX = apenas se não existir, EX = auto-expirar)
  const acquired = await redis.set(lockKey, "1", "EX", 10, "NX");
 
  if (acquired) {
    try {
      // Conseguimos o lock — buscar e cachear
      const result = await fetcher();
      await redis.set(cacheKey, JSON.stringify(result), "EX", ttlWithJitter(ttl));
      return result;
    } finally {
      // Liberar lock
      await redis.del(lockKey);
    }
  }
 
  // Outra requisição detém o lock — esperar e tentar novamente
  await sleep(100);
 
  const retried = await redis.get(cacheKey);
  if (retried !== null) {
    return JSON.parse(retried) as T;
  }
 
  // Ainda sem cache — ir direto ao banco de dados
  // (isso lida com o caso onde o detentor do lock falhou)
  return fetcher();
}
 
function sleep(ms: number): Promise<void> {
  return new Promise((resolve) => setTimeout(resolve, ms));
}

import { randomUUID } from "crypto";
 
async function acquireLock(lockKey: string, ttl: number): Promise<string | null> {
  const token = randomUUID();
  const acquired = await redis.set(lockKey, token, "EX", ttl, "NX");
  return acquired ? token : null;
}
 
async function releaseLock(lockKey: string, token: string): Promise<boolean> {
  // Script Lua garante check-and-delete atômico
  const script = `
    if redis.call("get", KEYS[1]) == ARGV[1] then
      return redis.call("del", KEYS[1])
    else
      return 0
    end
  `;
  const result = await redis.eval(script, 1, lockKey, token);
  return result === 1;
}

interface CachedValue<T> {
  data: T;
  cachedAt: number;
  ttl: number;
}
 
async function cacheWithEarlyExpiration<T>(key: string, fetcher: () => Promise<T>, ttl: number = 3600): Promise<T> {
  const cacheKey = `cache:${key}`;
  const cached = await redis.get(cacheKey);
 
  if (cached !== null) {
    const entry = JSON.parse(cached) as CachedValue<T>;
    const age = (Date.now() - entry.cachedAt) / 1000;
    const remaining = entry.ttl - age;
 
    // Algoritmo XFetch: regenerar probabilisticamente conforme a expiração se aproxima
    // beta * Math.log(Math.random()) produz um número negativo
    // que cresce (mais negativo) conforme a expiração se aproxima
    const beta = 1; // parâmetro de ajuste, 1 funciona bem
    const shouldRegenerate = remaining - beta * Math.log(Math.random()) * -1 <= 0;
 
    if (!shouldRegenerate) {
      return entry.data;
    }
 
    // Continuar para regenerar
    console.log(`[Cache] Early regeneration triggered for ${key}`);
  }
 
  const data = await fetcher();
  const entry: CachedValue<T> = {
    data,
    cachedAt: Date.now(),
    ttl,
  };
 
  // Definir com buffer extra para que o Redis não expire antes de podermos regenerar
  await redis.set(cacheKey, JSON.stringify(entry), "EX", Math.round(ttl * 1.1));
 
  return data;
}

async function staleWhileRevalidate<T>(
  key: string,
  fetcher: () => Promise<T>,
  options: {
    freshTtl: number; // quanto tempo o dado é "fresco"
    staleTtl: number; // quanto tempo dados obsoletos podem ser servidos
  },
): Promise<T | null> {
  const cacheKey = `cache:${key}`;
  const metaKey = `meta:${key}`;
 
  const [cached, meta] = await redis.mget(cacheKey, metaKey);
 
  if (cached !== null) {
    const parsedMeta = meta ? JSON.parse(meta) : null;
    const isFresh = parsedMeta && Date.now() - parsedMeta.cachedAt < options.freshTtl * 1000;
 
    if (!isFresh) {
      // Dado está obsoleto — servir mas disparar refresh em segundo plano
      revalidateInBackground(key, cacheKey, metaKey, fetcher, options);
    }
 
    return JSON.parse(cached) as T;
  }
 
  // Cache miss completo — precisa buscar sincronamente
  return fetchAndCache(key, cacheKey, metaKey, fetcher, options);
}
 
async function fetchAndCache<T>(
  key: string,
  cacheKey: string,
  metaKey: string,
  fetcher: () => Promise<T>,
  options: { freshTtl: number; staleTtl: number },
): Promise<T> {
  const data = await fetcher();
  const totalTtl = options.freshTtl + options.staleTtl;
 
  const pipeline = redis.pipeline();
  pipeline.set(cacheKey, JSON.stringify(data), "EX", totalTtl);
  pipeline.set(metaKey, JSON.stringify({ cachedAt: Date.now() }), "EX", totalTtl);
  await pipeline.exec();
 
  return data;
}
 
function revalidateInBackground<T>(
  key: string,
  cacheKey: string,
  metaKey: string,
  fetcher: () => Promise<T>,
  options: { freshTtl: number; staleTtl: number },
): void {
  // Usar um lock para prevenir múltiplos refreshes em segundo plano
  const lockKey = `revalidate_lock:${key}`;
 
  redis
    .set(lockKey, "1", "EX", 30, "NX")
    .then((acquired) => {
      if (!acquired) return;
 
      return fetchAndCache(key, cacheKey, metaKey, fetcher, options).finally(() => redis.del(lockKey));
    })
    .catch((err) => {
      console.error(`[SWR] Background revalidation failed for ${key}:`, err);
    });
}

const user = await staleWhileRevalidate<User>("user:123", fetchUserFromDB, {
  freshTtl: 300, // 5 minutos fresco
  staleTtl: 3600, // servir obsoleto por até 1 hora enquanto revalida
});

async function updateUserAndInvalidate(userId: string, updates: Partial<User>): Promise<User> {
  const user = await db.query("UPDATE users SET name = $2 WHERE id = $1 RETURNING *", [userId, updates.name]);
 
  // Invalidar o cache
  await redis.del(`cache:user:${userId}`);
 
  return user[0];
}

async function setWithTags<T>(key: string, value: T, ttl: number, tags: string[]): Promise<void> {
  const pipeline = redis.pipeline();
 
  // Armazenar o valor
  pipeline.set(`cache:${key}`, JSON.stringify(value), "EX", ttl);
 
  // Adicionar a chave ao set de cada tag
  for (const tag of tags) {
    pipeline.sadd(`tag:${tag}`, `cache:${key}`);
    pipeline.expire(`tag:${tag}`, ttl + 3600); // Sets de tags vivem mais que os valores
  }
 
  await pipeline.exec();
}
 
async function invalidateByTag(tag: string): Promise<number> {
  const keys = await redis.smembers(`tag:${tag}`);
 
  if (keys.length === 0) return 0;
 
  const pipeline = redis.pipeline();
  for (const key of keys) {
    pipeline.del(key);
  }
  pipeline.del(`tag:${tag}`);
 
  await pipeline.exec();
  return keys.length;
}

// Ao cachear dados do time, etiquetar com todos os IDs de membros
const team = await fetchTeam(teamId);
await setWithTags(`team:${teamId}`, team, 1800, [
  `entity:team:${teamId}`,
  ...team.members.map((m) => `entity:user:${m.id}`),
]);
 
// Quando usuário 42 atualiza seu perfil, invalidar tudo que o contém
await invalidateByTag("entity:user:42");

// Publisher (no seu serviço de API)
async function publishInvalidation(entityType: string, entityId: string): Promise<void> {
  await redis.publish("cache:invalidate", JSON.stringify({ entityType, entityId, timestamp: Date.now() }));
}
 
// Subscriber (em cada instância da aplicação)
const subscriber = new Redis(/* mesma config */);
 
subscriber.subscribe("cache:invalidate", (err) => {
  if (err) console.error("[PubSub] Subscribe error:", err);
});
 
subscriber.on("message", async (_channel, message) => {
  const { entityType, entityId } = JSON.parse(message);
  await invalidateByTag(`entity:${entityType}:${entityId}`);
  console.log(`[Cache] Invalidated ${entityType}:${entityId}`);
});

async function invalidateByPattern(pattern: string): Promise<number> {
  let cursor = "0";
  let deletedCount = 0;
 
  do {
    const [nextCursor, keys] = await redis.scan(cursor, "MATCH", pattern, "COUNT", 100);
    cursor = nextCursor;
 
    if (keys.length > 0) {
      await redis.del(...keys);
      deletedCount += keys.length;
    }
  } while (cursor !== "0");
 
  return deletedCount;
}
 
// Invalidar todos os dados cacheados para um time específico
await invalidateByPattern("cache:team:42:*");

// Armazenar usuário como hash
async function setUserHash(user: User): Promise<void> {
  const key = `user:${user.id}`;
  await redis.hset(key, {
    name: user.name,
    email: user.email,
    plan: user.plan,
    updatedAt: Date.now().toString(),
  });
  await redis.expire(key, 1800);
}
 
// Ler campos específicos
async function getUserPlan(userId: string): Promise<string | null> {
  return redis.hget(`user:${userId}`, "plan");
}
 
// Atualizar um único campo
async function upgradeUserPlan(userId: string, plan: string): Promise<void> {
  await redis.hset(`user:${userId}`, "plan", plan);
}
 
// Ler hash inteiro como objeto
async function getUserHash(userId: string): Promise<User | null> {
  const data = await redis.hgetall(`user:${userId}`);
  if (!data || Object.keys(data).length === 0) return null;
 
  return {
    id: userId,
    name: data.name,
    email: data.email,
    plan: data.plan as User["plan"],
  };
}

// Ranking
async function addScore(leaderboard: string, userId: string, score: number): Promise<void> {
  await redis.zadd(leaderboard, score, userId);
}
 
async function getTopPlayers(
  leaderboard: string,
  count: number = 10,
): Promise<Array<{ userId: string; score: number }>> {
  const results = await redis.zrevrange(leaderboard, 0, count - 1, "WITHSCORES");
 
  const players: Array<{ userId: string; score: number }> = [];
  for (let i = 0; i < results.length; i += 2) {
    players.push({
      userId: results[i],
      score: parseFloat(results[i + 1]),
    });
  }
  return players;
}
 
async function getUserRank(leaderboard: string, userId: string): Promise<number | null> {
  const rank = await redis.zrevrank(leaderboard, userId);
  return rank !== null ? rank + 1 : null; // 0-indexed para 1-indexed
}

async function slidingWindowRateLimit(
  identifier: string,
  windowMs: number,
  maxRequests: number,
): Promise<{ allowed: boolean; remaining: number }> {
  const key = `ratelimit:${identifier}`;
  const now = Date.now();
  const windowStart = now - windowMs;
 
  const pipeline = redis.pipeline();
 
  // Remover entradas fora da janela
  pipeline.zremrangebyscore(key, 0, windowStart);
 
  // Adicionar requisição atual
  pipeline.zadd(key, now, `${now}:${Math.random()}`);
 
  // Contar requisições na janela
  pipeline.zcard(key);
 
  // Definir expiração na chave inteira
  pipeline.expire(key, Math.ceil(windowMs / 1000));
 
  const results = await pipeline.exec();
  const count = results?.[2]?.[1] as number;
 
  return {
    allowed: count <= maxRequests,
    remaining: Math.max(0, maxRequests - count),
  };
}

interface Job {
  id: string;
  type: string;
  payload: Record<string, unknown>;
  createdAt: number;
}
 
// Produtor
async function enqueueJob(queue: string, type: string, payload: Record<string, unknown>): Promise<string> {
  const job: Job = {
    id: randomUUID(),
    type,
    payload,
    createdAt: Date.now(),
  };
 
  await redis.lpush(`queue:${queue}`, JSON.stringify(job));
  return job.id;
}
 
// Consumidor (bloqueia até um job estar disponível)
async function dequeueJob(queue: string, timeout: number = 5): Promise<Job | null> {
  const result = await redis.brpop(`queue:${queue}`, timeout);
  if (!result) return null;
 
  return JSON.parse(result[1]) as Job;
}

// Rastrear visitantes únicos por dia
async function trackVisitor(page: string, visitorId: string): Promise<boolean> {
  const key = `visitors:${page}:${new Date().toISOString().split("T")[0]}`;
  const isNew = await redis.sadd(key, visitorId);
 
  // Auto-expirar após 48 horas
  await redis.expire(key, 172800);
 
  return isNew === 1; // 1 = novo membro, 0 = já existia
}
 
// Obter contagem de visitantes únicos
async function getUniqueVisitors(page: string, date: string): Promise<number> {
  return redis.scard(`visitors:${page}:${date}`);
}
 
// Verificar se usuário já executou uma ação
async function hasUserVoted(pollId: string, userId: string): Promise<boolean> {
  return (await redis.sismember(`votes:${pollId}`, userId)) === 1;
}

// HyperLogLog para contagens únicas aproximadas
async function trackVisitorApprox(page: string, visitorId: string): Promise<void> {
  const key = `hll:visitors:${page}:${new Date().toISOString().split("T")[0]}`;
  await redis.pfadd(key, visitorId);
  await redis.expire(key, 172800);
}
 
async function getApproxUniqueVisitors(page: string, date: string): Promise<number> {
  return redis.pfcount(`hll:visitors:${page}:${date}`);
}

const user = {
  id: "usr_abc123",
  name: "Ahmet Kousa",
  email: "ahmet@example.com",
  plan: "pro",
  preferences: {
    theme: "dark",
    language: "tr",
    notifications: true,
  },
};
 
// JSON: 189 bytes
const jsonStr = JSON.stringify(user);
console.log(Buffer.byteLength(jsonStr)); // 189
 
// JSON.parse em um caminho quente: ~0.02ms por chamada
// A 10.000 requisições/seg: 200ms de tempo total de CPU por segundo

npm install msgpackr

import { pack, unpack } from "msgpackr";
 
// MessagePack: ~140 bytes (25% menor)
const packed = pack(user);
console.log(packed.length); // ~140
 
// Armazenar como Buffer
await redis.set("user:123", packed);
 
// Ler como Buffer
const raw = await redis.getBuffer("user:123");
if (raw) {
  const data = unpack(raw);
}

import { promisify } from "util";
import { gzip, gunzip } from "zlib";
 
const gzipAsync = promisify(gzip);
const gunzipAsync = promisify(gunzip);
 
async function setCompressed<T>(key: string, value: T, ttl: number): Promise<void> {
  const json = JSON.stringify(value);
 
  // Só comprimir se maior que 1KB (overhead da compressão não vale para valores pequenos)
  if (Buffer.byteLength(json) > 1024) {
    const compressed = await gzipAsync(json);
    await redis.set(key, compressed, "EX", ttl);
  } else {
    await redis.set(key, json, "EX", ttl);
  }
}
 
async function getCompressed<T>(key: string): Promise<T | null> {
  const raw = await redis.getBuffer(key);
  if (!raw) return null;
 
  try {
    // Tentar descomprimir primeiro
    const decompressed = await gunzipAsync(raw);
    return JSON.parse(decompressed.toString()) as T;
  } catch {
    // Não comprimido, parsear como JSON normal
    return JSON.parse(raw.toString()) as T;
  }
}

// app/api/products/route.ts
import { NextResponse } from "next/server";
import redis from "@/lib/redis";
 
export async function GET(request: Request) {
  const url = new URL(request.url);
  const category = url.searchParams.get("category") || "all";
  const cacheKey = `api:products:${category}`;
 
  // Verificar cache
  const cached = await redis.get(cacheKey);
  if (cached) {
    return NextResponse.json(JSON.parse(cached), {
      headers: {
        "X-Cache": "HIT",
        "Cache-Control": "public, s-maxage=60",
      },
    });
  }
 
  // Buscar do banco de dados
  const products = await db.products.findMany({
    where: category !== "all" ? { category } : undefined,
    orderBy: { createdAt: "desc" },
    take: 50,
  });
 
  // Cachear por 5 minutos com jitter
  await redis.set(cacheKey, JSON.stringify(products), "EX", ttlWithJitter(300));
 
  return NextResponse.json(products, {
    headers: {
      "X-Cache": "MISS",
      "Cache-Control": "public, s-maxage=60",
    },
  });
}

// lib/session.ts
import { randomUUID } from "crypto";
import redis from "./redis";
 
interface Session {
  userId: string;
  role: string;
  createdAt: number;
  data: Record<string, unknown>;
}
 
const SESSION_TTL = 86400; // 24 horas
const SESSION_PREFIX = "session:";
 
export async function createSession(userId: string, role: string): Promise<string> {
  const sessionId = randomUUID();
  const session: Session = {
    userId,
    role,
    createdAt: Date.now(),
    data: {},
  };
 
  await redis.set(`${SESSION_PREFIX}${sessionId}`, JSON.stringify(session), "EX", SESSION_TTL);
 
  return sessionId;
}
 
export async function getSession(sessionId: string): Promise<Session | null> {
  const key = `${SESSION_PREFIX}${sessionId}`;
 
  // Usar GETEX para refrescar TTL a cada acesso (expiração deslizante)
  const raw = await redis.getex(key, "EX", SESSION_TTL);
  if (!raw) return null;
 
  return JSON.parse(raw) as Session;
}
 
export async function destroySession(sessionId: string): Promise<void> {
  await redis.del(`${SESSION_PREFIX}${sessionId}`);
}
 
// Destruir todas as sessões de um usuário (útil para "deslogar de tudo")
export async function destroyAllUserSessions(userId: string): Promise<void> {
  // Isso requer manter um índice usuário->sessões
  const sessionIds = await redis.smembers(`user_sessions:${userId}`);
 
  if (sessionIds.length > 0) {
    const pipeline = redis.pipeline();
    for (const sid of sessionIds) {
      pipeline.del(`${SESSION_PREFIX}${sid}`);
    }
    pipeline.del(`user_sessions:${userId}`);
    await pipeline.exec();
  }
}

// middleware.ts (ou um helper usado pelo middleware)
import redis from "@/lib/redis";
 
interface RateLimitResult {
  allowed: boolean;
  remaining: number;
  resetAt: number;
}
 
export async function rateLimit(
  identifier: string,
  limit: number = 60,
  windowSeconds: number = 60,
): Promise<RateLimitResult> {
  const key = `rate:${identifier}`;
  const now = Math.floor(Date.now() / 1000);
  const windowStart = now - windowSeconds;
 
  // Script Lua para rate limiting atômico
  const script = `
    redis.call('ZREMRANGEBYSCORE', KEYS[1], 0, ARGV[1])
    redis.call('ZADD', KEYS[1], ARGV[2], ARGV[3])
    local count = redis.call('ZCARD', KEYS[1])
    redis.call('EXPIRE', KEYS[1], ARGV[4])
    return count
  `;
 
  const count = (await redis.eval(
    script,
    1,
    key,
    windowStart,
    now,
    `${now}:${Math.random()}`,
    windowSeconds,
  )) as number;
 
  return {
    allowed: count <= limit,
    remaining: Math.max(0, limit - count),
    resetAt: now + windowSeconds,
  };
}

// lib/distributed-lock.ts
import { randomUUID } from "crypto";
import redis from "./redis";
 
export async function withLock<T>(
  lockName: string,
  fn: () => Promise<T>,
  options: { ttl?: number; retryDelay?: number; maxRetries?: number } = {},
): Promise<T | null> {
  const { ttl = 30, retryDelay = 200, maxRetries = 10 } = options;
  const token = randomUUID();
  const lockKey = `dlock:${lockName}`;
 
  // Tentar adquirir lock
  for (let attempt = 0; attempt < maxRetries; attempt++) {
    const acquired = await redis.set(lockKey, token, "EX", ttl, "NX");
 
    if (acquired) {
      try {
        // Estender lock automaticamente para tarefas de longa duração
        const extender = setInterval(
          async () => {
            const script = `
            if redis.call("get", KEYS[1]) == ARGV[1] then
              return redis.call("expire", KEYS[1], ARGV[2])
            else
              return 0
            end
          `;
            await redis.eval(script, 1, lockKey, token, ttl);
          },
          (ttl * 1000) / 3,
        );
 
        const result = await fn();
        clearInterval(extender);
        return result;
      } finally {
        // Liberar lock apenas se ainda somos donos
        const releaseScript = `
          if redis.call("get", KEYS[1]) == ARGV[1] then
            return redis.call("del", KEYS[1])
          else
            return 0
          end
        `;
        await redis.eval(releaseScript, 1, lockKey, token);
      }
    }
 
    // Esperar antes de tentar novamente
    await new Promise((r) => setTimeout(r, retryDelay));
  }
 
  // Não conseguiu adquirir lock após todas as tentativas
  return null;
}

// Em uma API route disparada por cron
export async function POST() {
  const result = await withLock("daily-report", async () => {
    // Apenas uma instância executa isso
    const report = await generateDailyReport();
    await sendReportEmail(report);
    return report;
  });
 
  if (result === null) {
    return NextResponse.json({ message: "Another instance is already processing" }, { status: 409 });
  }
 
  return NextResponse.json({ success: true });
}

// lib/cache-metrics.ts
import redis from "./redis";
 
const METRICS_KEY = "metrics:cache";
 
export async function recordCacheHit(): Promise<void> {
  await redis.hincrby(METRICS_KEY, "hits", 1);
}
 
export async function recordCacheMiss(): Promise<void> {
  await redis.hincrby(METRICS_KEY, "misses", 1);
}
 
export async function getCacheStats(): Promise<{
  hits: number;
  misses: number;
  hitRate: number;
}> {
  const stats = await redis.hgetall(METRICS_KEY);
  const hits = parseInt(stats.hits || "0", 10);
  const misses = parseInt(stats.misses || "0", 10);
  const total = hits + misses;
 
  return {
    hits,
    misses,
    hitRate: total > 0 ? hits / total : 0,
  };
}
 
// Resetar métricas diariamente
export async function resetCacheStats(): Promise<void> {
  await redis.del(METRICS_KEY);
}

redis-cli INFO memory

redis-cli INFO stats

# NUNCA deixe isso rodando em produção
# Adiciona overhead significativo e pode registrar dados sensíveis
redis-cli MONITOR

# Habilitar notificações de keyspace para eventos de expiração e evicção
redis-cli CONFIG SET notify-keyspace-events Ex

const subscriber = new Redis(/* config */);
 
// Escutar eventos de expiração de chave
subscriber.subscribe("__keyevent@0__:expired", (err) => {
  if (err) console.error("Subscribe error:", err);
});
 
subscriber.on("message", (_channel, expiredKey) => {
  console.log(`Key expired: ${expiredKey}`);
 
  // Regenerar proativamente chaves importantes
  if (expiredKey.startsWith("cache:homepage")) {
    regenerateHomepageCache().catch(console.error);
  }
});

# Amostrar as 10 maiores chaves
redis-cli --bigkeys

# Uso de memória de uma chave específica (em bytes)
redis-cli MEMORY USAGE "cache:search:electronics"

// Análise de memória programática
async function analyzeMemory(pattern: string): Promise<void> {
  let cursor = "0";
  const stats: Array<{ key: string; bytes: number }> = [];
 
  do {
    const [nextCursor, keys] = await redis.scan(cursor, "MATCH", pattern, "COUNT", 100);
    cursor = nextCursor;
 
    for (const key of keys) {
      const bytes = await redis.memory("USAGE", key);
      if (bytes) {
        stats.push({ key, bytes: bytes as number });
      }
    }
  } while (cursor !== "0");
 
  // Ordenar por tamanho decrescente
  stats.sort((a, b) => b.bytes - a.bytes);
 
  console.log("Top 20 keys by memory usage:");
  for (const { key, bytes } of stats.slice(0, 20)) {
    const mb = (bytes / 1024 / 1024).toFixed(2);
    console.log(`  ${key}: ${mb} MB`);
  }
}

# Em redis.conf ou via CONFIG SET
maxmemory 512mb
maxmemory-policy allkeys-lru

// lib/cache.ts
import Redis from "ioredis";
 
const redis = new Redis({
  host: process.env.REDIS_HOST || "127.0.0.1",
  port: Number(process.env.REDIS_PORT) || 6379,
  password: process.env.REDIS_PASSWORD || undefined,
  maxRetriesPerRequest: 3,
  retryStrategy(times) {
    return Math.min(times * 200, 5000);
  },
});
 
// Camadas de TTL
const TTL = {
  STATIC: 86400,
  MODERATE: 1800,
  VOLATILE: 300,
  EPHEMERAL: 60,
  NOT_FOUND: 120,
} as const;
 
type TTLTier = keyof typeof TTL;
 
function ttlWithJitter(base: number, jitter = 0.1): number {
  const offset = base * jitter * (Math.random() * 2 - 1);
  return Math.max(1, Math.round(base + offset));
}
 
// Cache-aside core com proteção contra stampede
async function get<T>(
  key: string,
  fetcher: () => Promise<T>,
  options: {
    tier?: TTLTier;
    ttl?: number;
    tags?: string[];
    swr?: { freshTtl: number; staleTtl: number };
  } = {},
): Promise<T> {
  const { tier = "MODERATE", tags } = options;
  const baseTtl = options.ttl ?? TTL[tier];
  const cacheKey = `c:${key}`;
 
  // Verificar cache
  const cached = await redis.get(cacheKey);
 
  if (cached !== null) {
    try {
      const parsed = JSON.parse(cached);
      recordHit();
      return parsed as T;
    } catch {
      await redis.del(cacheKey);
    }
  }
 
  recordMiss();
 
  // Adquirir lock para prevenir stampede
  const lockKey = `lock:${key}`;
  const acquired = await redis.set(lockKey, "1", "EX", 10, "NX");
 
  if (!acquired) {
    // Outro processo está buscando — esperar brevemente e tentar cache novamente
    await new Promise((r) => setTimeout(r, 150));
    const retried = await redis.get(cacheKey);
    if (retried) return JSON.parse(retried) as T;
  }
 
  try {
    const result = await fetcher();
    const ttl = ttlWithJitter(baseTtl);
 
    const pipeline = redis.pipeline();
    pipeline.set(cacheKey, JSON.stringify(result), "EX", ttl);
 
    // Armazenar associações de tags
    if (tags) {
      for (const tag of tags) {
        pipeline.sadd(`tag:${tag}`, cacheKey);
        pipeline.expire(`tag:${tag}`, ttl + 3600);
      }
    }
 
    await pipeline.exec();
    return result;
  } finally {
    await redis.del(lockKey);
  }
}
 
// Invalidação
async function invalidate(...keys: string[]): Promise<void> {
  if (keys.length === 0) return;
  await redis.del(...keys.map((k) => `c:${k}`));
}
 
async function invalidateByTag(tag: string): Promise<number> {
  const keys = await redis.smembers(`tag:${tag}`);
  if (keys.length === 0) return 0;
 
  const pipeline = redis.pipeline();
  for (const key of keys) {
    pipeline.del(key);
  }
  pipeline.del(`tag:${tag}`);
  await pipeline.exec();
  return keys.length;
}
 
// Métricas
function recordHit(): void {
  redis.hincrby("metrics:cache", "hits", 1).catch(() => {});
}
 
function recordMiss(): void {
  redis.hincrby("metrics:cache", "misses", 1).catch(() => {});
}
 
async function stats(): Promise<{
  hits: number;
  misses: number;
  hitRate: string;
}> {
  const raw = await redis.hgetall("metrics:cache");
  const hits = parseInt(raw.hits || "0", 10);
  const misses = parseInt(raw.misses || "0", 10);
  const total = hits + misses;
 
  return {
    hits,
    misses,
    hitRate: total > 0 ? ((hits / total) * 100).toFixed(1) + "%" : "N/A",
  };
}
 
export const cache = {
  get,
  invalidate,
  invalidateByTag,
  stats,
  redis,
  TTL,
};

import { cache } from "@/lib/cache";
 
// Cache-aside simples
const products = await cache.get("products:featured", fetchFeaturedProducts, {
  tier: "VOLATILE",
  tags: ["entity:products"],
});
 
// Com TTL customizado
const config = await cache.get("app:config", fetchAppConfig, {
  ttl: 43200, // 12 horas
});
 
// Após atualizar um produto
await cache.invalidateByTag("entity:products");
 
// Verificar saúde
const metrics = await cache.stats();
console.log(`Cache hit rate: ${metrics.hitRate}`);

async function resilientGet<T>(key: string, fetcher: () => Promise<T>): Promise<T> {
  try {
    return await cache.get(key, fetcher);
  } catch (err) {
    console.error(`[Cache] Degraded mode for ${key}:`, err);
    return fetcher(); // Contornar cache inteiramente
  }
}