[Redis] 채팅방 목록 조회 API 성능 개선 — 서브쿼리와 GROUP BY에서 Redis 캐싱으로 해결하기

GET /chatRoom/list
  → ChatRoomServiceImpl.getChatRoomList()
    → 1단계: 내가 속한 채팅방 목록 조회 (JPA)
    → 2단계: 각 채팅방의 안읽음 메시지 개수 계산 (GROUP BY 쿼리) ← 여기가 문제

public List<ChatRoomPreviewDto> getChatRoomList(Long userId, String keyword) {
    List<ChatRoomPreviewDto> chatRoomPreviews = 
        userChatRoomService.findChatRoomPreviewsByUserId(userId, keyword);
 
    List<Long> roomIds = chatRoomPreviews.stream()
        .map(ChatRoomPreviewDto::getRoomId)
        .toList();
 
    Map<Long, Long> unreadMessageCount = 
        messageService.getUnreadMessageCount(roomIds, userId);
 
    chatRoomPreviews.forEach(preview ->
        preview.setUnreadCount(unreadMessageCount.getOrDefault(preview.getRoomId(), 0L))
    );
 
    return chatRoomPreviews;
}

@Query("""
    SELECT m.chatRoom.id, COUNT(m)
    FROM Messages m
    JOIN m.chatRoom r
    WHERE r.id IN :roomIds
    AND m.id > (
        SELECT COALESCE(ucr.lastReadMessageId, 0)
        FROM UserChatRoom ucr
        WHERE ucr.chatRoom.id = m.chatRoom.id AND ucr.user.id = :userId
    )
    AND m.sender.id <> :userId
    GROUP BY m.chatRoom.id
""")
List<Object[]> countUnreadMessages(List<Long> roomIds, Long userId);

-- 실행 과정
-- messages 테이블의 모든 행에 대해 아래를 반복 실행
-- (행 1에 대해) SELECT lastReadMessageId FROM user_chat_room WHERE ...
-- (행 2에 대해) SELECT lastReadMessageId FROM user_chat_room WHERE ...
-- (행 3에 대해) SELECT lastReadMessageId FROM user_chat_room WHERE ...
-- ...N번 반복

http_req_duration: avg=39.64ms  p(95)=59.44ms
http_reqs........: 987 req  (38.8 req/s)

http_req_duration: avg=1.63s  p(95)=4.63s
http_reqs........: 390 req  (15.1 req/s)

기존: 목록 조회 요청이 올 때마다 → MySQL GROUP BY로 실시간 계산
개선: 메시지가 오는 순간 → Redis 카운터 +1 보관 / 목록 조회 시 → Redis에서 꺼내기

chat:unread:{roomId}:{userId}
예시) chat:unread:42:7 → 채팅방 42번에서 유저 7번이 읽지 않은 메시지 수

public Map<Long, Long> getUnreadCounts(List<Long> roomIds, Long userId) {
    List<String> keys = roomIds.stream()
        .map(roomId -> generateKey(roomId, userId))
        .collect(Collectors.toList());
 
    List<Object> values = redisTemplate.opsForValue().multiGet(keys);
    // ... 값 매핑 후 반환
}

unreadCountCacheService.incrementUnreadCount(chatRoom.getId(), otherUserId);

unreadCountCacheService.resetUnreadCount(roomId, userId);
 
public Map<Long, Long> getUnreadMessageCount(List<Long> roomIds, Long userId) {
    return unreadCountCacheService.getUnreadCounts(roomIds, userId);
}