개요

Redis를 활용하여 최근 데이터를 관리하는 메모리로써 활용하기 위한 방법을 정리한다.

Redis 프리티어의 제공 용량은 30MB, 최근 30개의 채팅기록을 관리한다 가정하고 계산해본 결과.

채팅방 수=52,429(메세지)/30≈1,748개

최근 5일 내로 활성화되지 않은 채팅방을 제거하는 규칙을 추가하여 관리한다면, 괜찮게 사용할 수 있을 것으로 보인다.

일단 진행해보자.

Redis의 자료구조

• List (사용)

LPUSH 및 LTRIM 그리고 EXPIRE

• lPush - 배열 앞에 추가.
• lTrim - 배열 크기 조정. 지정 길이보다 길 경우, 왼쪽부터 해당 길이까지만 저장함.
• expire - 만료기간 설정. 여러번 설정할 경우. 마지막 설정 기간으로 지정됨.
  • 만료기간 설정에 있어서, Redis 내부에서 별도의 만료일 설정 로직이 동작하기 때문에, 너무 많은 갱신이 이뤄질 경우 생각 이상의 오버헤드가 발생할 수 있다.

const TTL_SECONDS = 5 * 24 * 60 * 60; // 5일
const EXPIRY_TIME_THRESHOLD = 3600 * 1000; // 1시간 (밀리초 단위)
...
...
  let message:any = await Message.create(newMessage);
  message = await message.populate("sender", "nickname pic");

  const cacheData = {
    sender : message.sender,
    content,
    createdAt : message.createdAt
  }

  try {
    const lastMessage = await redisClient.lRange(`room:${chatId}`, 0, 0);
    if (lastMessage.length > 0) {
      const lastM:any = JSON.parse(lastMessage[0]);
      const lastMTime = lastM.createdAt;
      const timeDifference = message.createdAt - lastMTime; //Date 간의 연산은 밀리초 단위로 계산됨.
      if (timeDifference >= EXPIRY_TIME_THRESHOLD) {
          await redisClient.expire(`room:${chatId}`, TTL_SECONDS);
      }
    } else {
      await redisClient.expire(`room:${chatId}`, TTL_SECONDS);
    }

    const result = await redisClient.lPush(`room:${chatId}`, JSON.stringify(cacheData));
    console.log(`Message added to room ${chatId}:`, result);
    await redisClient.lTrim(`room:${chatId}`, 0, 29);
  } catch (err) {
      console.error('Error:', err);
  }

성능 테스트

• 우선 POST Man의 응답속도를 통해 1차적으로 테스트 해 보았다.

  • 전체 채팅내역 불러오기

    

  • 채팅 페이징 처리 이후

    

  • 캐시 측 데이터가 부족할 경우 (오히려 느려짐)