Что такое Redis и для чего его используют в Java-приложениях?

Что такое Redis и для чего его используют в Java-приложениях

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

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

1. In-Memory (в памяти)

Данные хранятся в RAM, что обеспечивает очень быстрый доступ (микросекунды вместо миллисекунд для БД):

Оперативная память: ~100,000 ops/sec
SSD БД: ~10,000 ops/sec
HDD БД: ~1,000 ops/sec

2. Key-Value структура

Данные хранятся как пары ключ-значение:

Ключ: "user:123:name"
Значение: "Иван"

3. Поддержка различных типов данных

• Strings (строки)
• Lists (списки)
• Sets (множества)
• Sorted Sets (отсортированные множества)
• Hashes (хеши)
• HyperLogLog, Streams, Bitmaps и др.

4. Персистентность (опциональная)

Можно сохранять данные на диск для восстановления после перезагрузки.

Основные use cases в Java

1. Кеширование (Cache)

import org.springframework.data.redis.core.RedisTemplate;

@Service
public class UserService {
    @Autowired
    private RedisTemplate<String, User> redisTemplate;
    
    @Autowired
    private UserRepository userRepository; // БД
    
    public User getUserById(Long userId) {
        String cacheKey = "user:" + userId;
        
        // 1. Сначала ищем в Redis (быстро)
        User cachedUser = (User) redisTemplate.opsForValue()
            .get(cacheKey);
        
        if (cachedUser != null) {
            return cachedUser; // Нашли в кеше
        }
        
        // 2. Не нашли — ищем в БД (медленно)
        User user = userRepository.findById(userId)
            .orElseThrow(() -> new NotFoundException());
        
        // 3. Кешируем результат на 1 час
        redisTemplate.opsForValue().set(
            cacheKey, 
            user, 
            1, 
            TimeUnit.HOURS
        );
        
        return user;
    }
}

2. Сессии (Session Store)

// Spring Session with Redis
@Configuration
@EnableRedisHttpSession(maxInactiveIntervalInSeconds = 3600)
public class SessionConfig {
}

// Результат: все сессии автоматически сохраняются в Redis
// Это позволяет горизонтально масштабировать приложение

3. Счётчики и рейтинги

@Service
public class PostService {
    @Autowired
    private RedisTemplate<String, Long> redisTemplate;
    
    public void incrementViewCount(Long postId) {
        String viewKey = "post:" + postId + ":views";
        // Атомарное инкрементирование
        redisTemplate.opsForValue().increment(viewKey);
    }
    
    public void addLike(Long postId, Long userId) {
        String likeKey = "post:" + postId + ":likes";
        // Добавляем userId в множество лайков
        redisTemplate.opsForSet().add(likeKey, userId.toString());
    }
    
    public Long getLikeCount(Long postId) {
        String likeKey = "post:" + postId + ":likes";
        return redisTemplate.opsForSet().size(likeKey);
    }
}

4. Очереди (Message Queue)

@Service
public class TaskProcessor {
    @Autowired
    private RedisTemplate<String, String> redisTemplate;
    
    // Добавить задачу в очередь
    public void enqueueTask(String taskData) {
        redisTemplate.opsForList()
            .rightPush("tasks:queue", taskData);
    }
    
    // Обработать задачу (из другого потока/приложения)
    public String dequeueTask() throws InterruptedException {
        // Блокирующая операция с таймаутом
        return redisTemplate.opsForList()
            .leftPop("tasks:queue", 5, TimeUnit.SECONDS);
    }
}

5. Distributed Lock (распределённая блокировка)

@Service
public class PaymentService {
    @Autowired
    private RedisTemplate<String, String> redisTemplate;
    
    public void processPayment(Long orderId, double amount) {
        String lockKey = "payment:lock:" + orderId;
        String lockValue = UUID.randomUUID().toString();
        
        try {
            // Пытаемся захватить lock
            Boolean locked = redisTemplate.opsForValue()
                .setIfAbsent(lockKey, lockValue, 30, TimeUnit.SECONDS);
            
            if (!locked) {
                throw new PaymentInProgressException();
            }
            
            // Выполняем платёж
            charge(orderId, amount);
            
        } finally {
            // Освобождаем lock
            redisTemplate.delete(lockKey);
        }
    }
}

6. Pub/Sub (Publisher/Subscriber)

@Configuration
public class RedisConfig {
    @Bean
    public MessageListenerAdapter messageListener(MessageHandler handler) {
        return new MessageListenerAdapter(handler);
    }
}

@Service
public class EventPublisher {
    @Autowired
    private RedisTemplate<String, String> redisTemplate;
    
    public void publishEvent(String event) {
        redisTemplate.convertAndSend("notifications:channel", event);
    }
}

@Service
public class EventSubscriber {
    @RedisListener(topics = "notifications:channel")
    public void handleMessage(String message) {
        System.out.println("Получено сообщение: " + message);
    }
}

Архитектура с Redis

// Типичная архитектура
public class Architecture {
    /*
    
    Java Application
         |
         v
    [Request Layer]
         |
         v
    [Service Layer]
         |
         +---> Redis (Cache, Sessions, Queues)
         |
         +---> PostgreSQL (Primary Data Store)
         |
         +---> Elasticsearch (Search)
    
    */
}

Spring Data Redis — удобная работа с Redis

Зависимость

<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-data-redis</artifactId>
</dependency>

Конфигурация

spring.redis.host=localhost
spring.redis.port=6379
spring.redis.password=
spring.redis.timeout=2000ms
spring.redis.database=0

RedisTemplate для низкоуровневой работы

@Autowired
private RedisTemplate<String, Object> redisTemplate;

// Strings
redisTemplate.opsForValue().set(key, value);
redisTemplate.opsForValue().get(key);

// Lists
redisTemplate.opsForList().push(key, value);
redisTemplate.opsForList().pop(key);

// Sets
redisTemplate.opsForSet().add(key, member);
redisTemplate.opsForSet().members(key);

// Hashes
redisTemplate.opsForHash().put(key, field, value);
redisTemplate.opsForHash().get(key, field);

// Sorted Sets
redisTemplate.opsForZSet().add(key, member, score);
redisTemplate.opsForZSet().range(key, 0, -1);

StringRedisTemplate для строк

@Autowired
private StringRedisTemplate stringRedisTemplate;

// Проще чем RedisTemplate если работаешь только со строками
stringRedisTemplate.opsForValue().set("key", "value");
String value = stringRedisTemplate.opsForValue().get("key");

Проблемы и решения

1. Cache Invalidation (инвалидация кеша)

public void updateUser(Long userId, User updatedUser) {
    // Обновляем в БД
    userRepository.save(updatedUser);
    
    // Удаляем из кеша
    redisTemplate.delete("user:" + userId);
}

// Или автоматически через Spring
@CachePut(value = "users", key = "#id")
public User updateUser(Long id, User user) {
    return userRepository.save(user);
}

2. Cache Stampede (когда key истекает, все запрашивают БД)

// Решение: использовать refresh time раньше expiration
public User getUser(Long userId) {
    String key = "user:" + userId;
    User cached = (User) redisTemplate.opsForValue().get(key);
    
    if (cached != null) {
        return cached;
    }
    
    User user = userRepository.findById(userId).orElse(null);
    if (user != null) {
        redisTemplate.opsForValue().set(
            key, 
            user, 
            1, 
            TimeUnit.HOURS
        );
    }
    return user;
}

3. Memory Management (управление памятью)

# Redis может вырасти без контроля
# Решение: установить maxmemory policy
maxmemory 2gb
maxmemory-policy allkeys-lru  # Удалять старые ключи когда заканчивается память

Когда использовать Redis

✅ Используй Redis для:

• Кеширования часто запрашиваемых данных
• Сессионного хранилища
• Real-time счётчиков и аналитики
• Очередей и задач
• Распределённых блокировок
• Рейтинговых таблиц (sorted sets)
• Pub/Sub messaging

❌ НЕ используй Redis для:

• Основного хранилища данных (может потерять данные)
• Очень больших объёмов данных (памятью дорогая)
• Данных, которые не кешируются (используй БД)

Заключение

Redis — это мощный инструмент для оптимизации производительности Java-приложений. Он идеален для случаев, где нужна очень быстрая доступность данных, и правильное использование Redis может снизить нагрузку на основную БД в 10+ раз, улучшив response time приложения.