Redis Caching: Complete Guide to Performance Optimization

import Redis from 'ioredis';

const redis = new Redis({
  host: 'localhost',
  port: 6379
});

// Set
await redis.set('user:1', JSON.stringify({ name: 'John' }));

// Get
const user = await redis.get('user:1');

// Set with expiration
await redis.setex('session:123', 3600, 'active');

// Set field
await redis.hset('user:1', 'name', 'John');
await redis.hset('user:1', 'email', 'john@example.com');

// Get all fields
const user = await redis.hgetall('user:1');

// Get specific field
const name = await redis.hget('user:1', 'name');

// Push
await redis.lpush('tasks', 'task1');
await redis.rpush('tasks', 'task2');

// Pop
const task = await redis.lpop('tasks');

// Get range
const tasks = await redis.lrange('tasks', 0, -1);

// Add members
await redis.sadd('tags', 'javascript', 'nodejs', 'redis');

// Get all members
const tags = await redis.smembers('tags');

// Check membership
const exists = await redis.sismember('tags', 'javascript');

async function getUser(id) {
  // Check cache
  const cached = await redis.get(`user:${id}`);
  if (cached) return JSON.parse(cached);

  // Fetch from database
  const user = await db.findUser(id);

  // Store in cache
  await redis.setex(`user:${id}`, 3600, JSON.stringify(user));

  return user;
}

async function updateUser(id, data) {
  // Update database
  const user = await db.updateUser(id, data);

  // Update cache
  await redis.setex(`user:${id}`, 3600, JSON.stringify(user));

  return user;
}

await redis.setex('key', 3600, 'value'); // Expires in 1 hour

async function invalidateUser(id) {
  await redis.del(`user:${id}`);
}