[개발] Node & Steem 9편 - 기초적인 커넥션 풀 적용 - Database Connection Pool

봇 서비스를 만들면서 엄청나게 장편이 되어가고 있네요. 허접하지만 항상 돌아가고 있는 저의 봇 서비스는 깃헙에 공유되고 있어 상세 코드는 제 허접한 깃헙에서 언제든 확인 가능합니다.

■ 커넥션 풀 적용

먼저 커넥션 풀 적용에 대한 이야기입니다. 일단 개발에서 무슨 Pool, 무슨 Pool 이라고 말을 자주 쓰는데

이런거나... 혹시

이런게 아니라는 것쯤은 예상하고 계실겁니다. (이상한 개드립?) 웹 개발을 하고 멀티쓰레드로 동작하는 언어라면 Http request에 대한 처리 쓰레드 풀이나 자주 사용하는 Object에 대한 객체 풀, 그리고 데이터베이스 커넥션 풀이 자주 언급 되는 것 같습니다.

개념적으로는 사용하기 위해 생성(초기화)하는 과정이 오래 걸리고 부하가 심한 것들을 미리 만들어두고 바구니에 담아두고 계속 재 활용하자는게 그 취지면서 고 비용의 초기화 과정을 줄이는 게 그 목적이겠죠.

트... 특히 DB 커넥션 풀 같은 경우는 그 성능 체감에 있어서 엄청난 차이를 보이기에 DB를 쓰는 어플리케이션이라면 필수적으로 들어가야하지 않나 싶습니다. DB에 커넥션 연결하는데 리소스가 많이 들거든요.

그림으로는 이녀석이 가장 이해가 쉽게 표현되어있네요.

출처. docs.oracle.com

누이 좋고 매부 좋다는 이녀석. 적용을 안할 수 없죠. mysql 기준으로 적용해봅니다.

// init mysql!
var db_config = {
   // 운영 모드.
    prod: {
      host: '127.0.0.1',
      port: '3306',
      user: 'steem_nhj',
      password: 'steem_nhj',
      database: 'steem_nhj',
      connectionLimit:20, // 신규
      waitForConnections:false // 신규
    },
..... 생략 ....
function createPool() {
  pool = mysql.createPool(db_config);
}
createPool();

그리고 실제로 쿼리를 connection을 얻어서 쓰고 있었는데 pool 에서 얻어와서 사용하도록 변경해봤습니다. synchroniz가 적용된 쿼리 실행 함수네요. '반환'은 필수!

function query(sql, params){
  //console.log("query.sql : "+sql );
  var conn = await(pool.getConnection( defer() ));
  var rows = await(conn.query(sql, params, defer() ));
  //console.log( rows );
  conn.release(); // 반환.
  return rows;
}

예전에 요즘과 같이 DB 레이어 영역의 프레임워크나 공통 유틸리티를 적용하지 않고 프로그램을 만든적이 있었는데 그때 커넥션을 열고, 닫고를 직접 코딩으로 했었습니다. 어디선가 닫는걸 빼먹으면 디비서버에 자원이 반환되지 않아 나중에 디비 리소스가 풀이 되며 서버가 뻗었었죠. ㅎㅎㅎ 열고 닫고의 중요성을 체감한 소중한 경험이었다고 생각합니다.

머... 암튼 사용할 땐 이렇게 사용하면 되겠습니다. 현재 steem.apps 봇에 적용해서 잘 돌아가고 있는 것 같습니다.

query("쿼리", [ 파라미터들. ] )

허접한 내용 읽어주셔서 감사합니다~ ^^