Для чего нужен Redis?

Для чего нужен Redis?

Redis — это высокопроизводительное хранилище данных в памяти (in-memory data store), которое используется как кэш, очередь сообщений, сессионное хранилище и для синхронизации между сервисами.

Основные характеристики Redis

Redis работает с данными в оперативной памяти, что делает его невероятно быстрым:

• Скорость: микросекунды для большинства операций
• Надежность: поддерживает персистентность (RDB снимки, AOF логи)
• Масштабируемость: встроенная поддержка репликации и кластеризации
• Простота: минимальный оверхед на сетевом протоколе (RESP)

Основные сценарии использования

1. Кэширование данных

Это самый частый сценарий. Redis кэширует результаты дорогостоящих операций, чтобы не обращаться к БД.

Пример:

const redis = require('redis');
const client = redis.createClient();

async function getUserWithCache(userId) {
  const cacheKey = `user:${userId}`;
  
  // Проверяем кэш
  const cached = await client.get(cacheKey);
  if (cached) return JSON.parse(cached);
  
  // Если нет в кэше, получаем из БД
  const user = await db.users.findById(userId);
  
  // Сохраняем в кэш на 1 час
  await client.setex(cacheKey, 3600, JSON.stringify(user));
  
  return user;
}

Паттерны кэширования:

• Cache-aside: проверить кэш, если нет — загрузить в БД, сохранить в кэш
• Write-through: при записи обновляем и кэш, и БД
• Write-behind: асинхронная запись в БД после обновления кэша

2. Сессии пользователей

Redis идеален для хранения сессий благодаря скорости и возможности автоматического истечения.

Пример:

const session = require('express-session');
const RedisStore = require('connect-redis').default;

app.use(session({
  store: new RedisStore({ client: redisClient }),
  secret: process.env.SESSION_SECRET,
  resave: false,
  saveUninitialized: false,
  cookie: { 
    httpOnly: true, 
    maxAge: 24 * 60 * 60 * 1000 // 24 часа
  }
}));

3. Очереди сообщений (Job Queues)

Redis используется для асинхронной обработки задач через очереди.

Пример:

const Bull = require('bull');

// Создаём очередь
const emailQueue = new Bull('email-sending', {
  redis: { host: 'localhost', port: 6379 }
});

// Добавляем задачу в очередь
await emailQueue.add(
  { email: 'user@example.com', subject: 'Hello' },
  { delay: 5000, attempts: 3 } // Попробуем 3 раза
);

// Обработчик задач
emailQueue.process(async (job) => {
  await sendEmail(job.data);
  return { success: true };
});

// Слушаем события
emailQueue.on('completed', (job) => {
  console.log(`Письмо отправлено: ${job.id}`);
});

emailQueue.on('failed', (job, err) => {
  console.error(`Ошибка отправки: ${err.message}`);
});

4. Подсчёт и счётчики в реальном времени

Redis отлично подходит для счётчиков просмотров, лайков, кликов.

Пример:

// Увеличиваем счётчик просмотров
await client.incr(`page:${pageId}:views`);

// Получаем количество просмотров
const views = await client.get(`page:${pageId}:views`);

// Счётчик с автоистечением (за последний час)
await client.incr(`analytics:hourly:${hour}`);
await client.expire(`analytics:hourly:${hour}`, 3600);

// Инкремент на несколько единиц
await client.incrby(`user:${userId}:score`, 100);

5. Pub/Sub (издатель-подписчик)

Redis поддерживает паттерн издатель-подписчик для real-time коммуникации.

Пример:

// Издатель
await client.publish('notifications', JSON.stringify({
  userId: 123,
  message: 'Новое сообщение'
}));

// Подписчик
const subscriber = redis.createClient();
await subscriber.subscribe('notifications');

subscriber.on('message', (channel, message) => {
  const data = JSON.parse(message);
  console.log(`Уведомление для пользователя ${data.userId}`);
});

6. Рейт-лимитинг (Rate Limiting)

Redis используется для отслеживания количества запросов от пользователя.

Пример (Token Bucket Algorithm):

async function checkRateLimit(userId, limit = 100, windowSeconds = 60) {
  const key = `ratelimit:${userId}`;
  const current = await client.incr(key);
  
  if (current === 1) {
    // Первый запрос в окне — устанавливаем TTL
    await client.expire(key, windowSeconds);
  }
  
  return current <= limit;
}

// Использование
app.use(async (req, res, next) => {
  const allowed = await checkRateLimit(req.user.id, 100, 60);
  if (!allowed) {
    return res.status(429).json({ error: 'Too many requests' });
  }
  next();
});

7. Распределённые блокировки (Distributed Locks)

Redis позволяет реализовать блокировки для синхронизации между сервисами.

Пример:

const { createClient } = require('redis');
const { Lock } = require('redis-lock');

async function transferMoney(fromId, toId, amount) {
  const lock = new Lock(client, `transfer:${fromId}:${toId}`);
  
  try {
    await lock.acquire(5000); // Получаем блокировку на 5 сек
    
    // Критическая секция
    const balance = await client.get(`user:${fromId}:balance`);
    if (balance >= amount) {
      await client.decrby(`user:${fromId}:balance`, amount);
      await client.incrby(`user:${toId}:balance`, amount);
    }
  } finally {
    await lock.release();
  }
}

8. Гео-данные (Geospatial Queries)

Redis поддерживает гео-запросы для поиска точек в радиусе.

Пример:

// Добавляем координаты
await client.geoadd('stores', 55.7558, 37.6173, 'store_1');
await client.geoadd('stores', 55.8542, 37.6213, 'store_2');

// Ищем магазины в радиусе 10 км от точки
const nearby = await client.georadius(
  'stores',
  55.7558, 37.6173,
  10, 'km'
);

Проблемы и ограничения Redis

Памяти: все данные в оперативной памяти, поэтому нельзя хранить всю БД

Персистентность: по умолчанию нет, нужно настраивать RDB/AOF

Single-threaded: обработка происходит в одном потоке (в Redis 6+ есть многопоточность для I/O)

Потеря данных: при сбое сервера возможна потеря недавних данных

Лучшие практики

1. Используй Lua скрипты для атомарных операций
2. Устанавливай TTL (Time To Live) для автоматической очистки
3. Мониторь использование памяти и настраивай maxmemory-policy
4. Используй репликацию для надежности
5. Кэшируй только часто запрашиваемые данные
6. Проектируй ключи логически: entity:id:field

Вывод: Redis — это швейцарский нож для backend-разработчика. Правильное его применение может в 100+ раз улучшить производительность приложения.