Redis cache 설정 (Node.js)

출처: https://inpa.tistory.com/entry/REDIS-📚-Redis를-클라우드로-사용하자-Redislabs [Inpa Dev 👨‍💻:티스토리]

[REDIS] 📚 Node.js 에서 redis 모듈 사용법 (캐싱 & 세션 스토어)

 

이 분의 글을 토대로 작성했다. 이분의 글에는 redis 설정 뿐만 아니라 캐싱 전략이나 redis로 세션관리를 하여 복수 서버 환경(클러스터링)에서도  세션을 공유할 수 있는 방법이 나와있어 도움이 많이 된다!

1. Redis Labs 로 클라우드 서버 개설

MySQL을 사용하기 위해서 워크벤치를 설치했던 것 처럼, 레디스를 사용하려면 레디스 데이터베이스를 설치해야 한다. 

Redislabs에서는 1개의 db에서 30mb 를 무료 제공해준다. (ram 영역에서 테스트를 위해서는 충분하다.) 

 

 

https://redis.com/

Redis | The Real-time Data Platform

1. 접속하여 회원가입
2. 클라우드 업체 선택 (지장 없으니 아무 것이나 체크 )
3. DB 생성 완료 

Mysql 을 연결할 때와 같이, 레디스도 생성된 클라우드 db서버에 접속하기 위해선 Host, Port, Password 3가지 정보가 필요하다.

 

2. Redis Cloud 접속 

얻은 정보로 redis에  접속해보자. 

Mac 기준 

$brew install redis # apt-get install redis-tools , redis 설치

$redis-cli-v #버전확인

$redis-cli -h [endpoint] -p [port] -a [password] #redis cloud 접속

 

- redis 서버 명령어

 

$redis-server #서버 시작
$redis-cli ping # 서버 확인, 실행중이라면 PONG
$redis-cli shutdown #서버 정지

$redis-cli # redis 명령창으로 접속 
$redis-cli shutdown 

#cli에서 정지
> shutdown save #지금까지 내용 저장 
> shutdown nosave #지금까지 내용 저장 X

3. Node에 연결

npm i redis #node 에 Redis 패키지 설치

 

redis 클라우드에 연결하기

redis db의 계정 정보들 저장 파일 생성(.env)

redisenv.env

# redisEnv.env 파일
REDIS_HOST=[endpoint]
REDIS_PORT=[port]
REDIS_USERNAME=[user]
REDIS_PASSWORD=[password]

 

redis.js

#with cloud redis server

const redis = require("redis");
const redisEnv= require('redisEnv')
redisEnv.config()  //환경변수 파일 가져오기
// redis[s]://[[username][:password]@][host][:port][/db-number]
const redisClient = redis.createClient({
   url: `redis://${process.env.REDIS_USERNAME}:${process.env.REDIS_PASSWORD}@${process.env.REDIS_HOST}:${process.env.REDIS_PORT}/0`,
   legacyMode: true, // 반드시 설정 !!
});

 

redis 로컬에 연결하기 + 캐시 등록, 제거, 조회

const redis = require("redis");

const bluebird = require("bluebird");
bluebird.promisifyAll(redis);

//redis 연결, 로컬에서
const redisClient = redis.createClient({
  host: `127.0.0.1`,
  port: 6379,
  legacyMode: true, //레거시 모드 반드시 설정
});

redisClient.on(`connect`, () => {
  console.info(`Redis connected!`);
});
redisClient.on(`error`, (err) => {
  console.error(`Redis Client Error`, err);
});
redisClient.connect().then();//redis v4 연결 비동기
const redisCli = redisClient.v4; // 기본 redisClient 객체는 콜백기반인데 v4버젼은 프로미스 기반이라 사용

const setCache = async (key, value) => {
  await redisCli.set(key,  JSON.stringify(value)); // key, value 형태로 redis에 저장
  await redisCli.expire(key, 3600); //
};

const deleteCache = async (key) => {
  await redisCli.delAsync(key); //데이터 제거
  res.status(200).json({
    isSuccess: "all cache deleted",
  });
};

// 책 리스트 결과 캐시에 저장하기 
const getBooksCache = async (req, res, next) => {
  let key = "book-list/";
  try {
    const data = JSON.parse(await redisCli.get(key));

    if (data) {
      if (redisCli.ttl(key) < 1000) { // ttl 타임아웃까지 남은 시간을 초단위로 반환
        // 소멸 시간 연장하기
        console.log("redis work1");
        await redisCli.setex(key, 3600, data); //소멸시간 지정해서 저장하기 , 3600초
        console.log("redis work2");
      }

      res.status(200).json(
        //결과 전송
        data
      );
    } else {
      next(); //다음 함수 실행  (컨트롤러의 getBookList 함수 실행, 캐시 없이 가져오는 경우(키 값 존재X) )
    } 
  } catch (err) {
    res.status(400).json({
      ok: false,
      message: err,
    });
  }
};

module.exports = {
  setCache,
  getBooksCache,
  deleteCache,
};