Previous
Next
Node.js 성능 최적화 | 클러스터링, 캐싱, 프로파일링

Node.js 성능 최적화 | 클러스터링, 캐싱, 프로파일링

· 24분 읽기 · 수정 고급 튜토리얼
Node.js 성능 최적화 | 클러스터링, 캐싱, 프로파일링

이 글의 핵심

Node.js 성능 최적화: 클러스터링, 캐싱, 프로파일링. 클러스터링 (Clustering)·캐싱 (Caching).

들어가며

성능 최적화의 중요성

Node는 한 프로세스 안에서 이벤트 루프로 I/O를 잘 감당하지만, CPU를 오래 쓰는 작업은 전체를 막을 수 있습니다. 그래서 클러스터·워커 스레드·캐시처럼 “누가 어떤 일을 나눠 갖는지”를 조정합니다. 최적화는 측정 없이 추측하지 말고, 프로파일러로 병목을 본 뒤 한 가지씩 바꾸는 것이 안전합니다. 성능이 중요한 이유:

  • ✅ 사용자 경험: 빠른 응답 시간
  • ✅ 비용 절감: 서버 리소스 효율화
  • ✅ 확장성: 더 많은 사용자 처리
  • ✅ SEO: 페이지 속도가 검색 순위에 영향 최적화 원칙:
  1. 측정 먼저: 추측하지 말고 측정
  2. 병목 지점 찾기: 가장 느린 부분 개선
  3. 점진적 개선: 한 번에 하나씩
  4. 트레이드오프 고려: 성능 vs 가독성

실전 경험에서 배운 교훈

이 기술을 실무 프로젝트에 처음 도입했을 때, 공식 문서만으로는 알 수 없었던 많은 함정들이 있었습니다. 특히 프로덕션 환경에서 발생하는 엣지 케이스들은 로컬 개발 환경에서는 재현조차 되지 않았죠.

가장 어려웠던 점은 성능 최적화였습니다. 처음엔 “동작만 하면 되겠지”라고 생각했지만, 실제 사용자 트래픽이 몰리면서 병목 지점들이 하나씩 드러났습니다. 특히 데이터베이스 쿼리 최적화, 캐싱 전략, 에러 핸들링 구조 등은 여러 번의 장애를 겪으면서 개선해 나갔습니다.

이 글에서는 그런 시행착오를 통해 얻은 실전 노하우와, “이렇게 하면 안 된다”는 교훈들을 함께 정리했습니다. 특히 트러블슈팅 섹션은 실제 장애 대응 경험을 바탕으로 작성했으니, 비슷한 문제를 마주했을 때 참고하시면 도움이 될 것입니다.

1. 클러스터링 (Clustering)

Cluster 모듈

// cluster.js
const cluster = require('cluster');
const http = require('http');
const os = require('os');
const numCPUs = os.cpus().length;
if (cluster.isMaster) {
    console.log(`마스터 프로세스 ${process.pid} 실행 중`);
    
    // 워커 프로세스 생성
    for (let i = 0; i < numCPUs; i++) {
        cluster.fork();
    }
    
    // 워커 종료 시 재시작
    cluster.on('exit', (worker, code, signal) => {
        console.log(`워커 ${worker.process.pid} 종료됨`);
        console.log('새 워커 시작 중...');
        cluster.fork();
    });
    
} else {
    // 워커 프로세스에서 서버 실행
    const server = http.createServer((req, res) => {
        res.writeHead(200);
        res.end(`워커 ${process.pid}가 처리함\n`);
    });
    
    server.listen(3000, () => {
        console.log(`워커 ${process.pid} 시작됨`);
    });
}

실행:

node cluster.js
# 마스터 프로세스 12345 실행 중
# 워커 12346 시작됨
# 워커 12347 시작됨
# 워커 12348 시작됨
# 워커 12349 시작됨

PM2 클러스터 모드

# CPU 코어 수만큼 프로세스 생성
pm2 start app.js -i max
# 특정 개수
pm2 start app.js -i 4
# 무중단 재시작
pm2 reload app

2. 캐싱 (Caching)

인메모리 캐싱

// 간단한 캐시
const cache = new Map();
function getCachedData(key, fetchFn, ttl = 60000) {
    const cached = cache.get(key);
    
    if (cached && Date.now() < cached.expiresAt) {
        console.log('캐시 히트');
        return cached.data;
    }
    
    console.log('캐시 미스');
    const data = fetchFn();
    
    cache.set(key, {
        data,
        expiresAt: Date.now() + ttl
    });
    
    return data;
}
// 사용
app.get('/api/users', async (req, res) => {
    const users = getCachedData('users', async () => {
        return await User.find();
    }, 60000);  // 1분 캐시
    
    res.json({ users });
});

Redis 캐싱

npm install redis
// cache.js
const redis = require('redis');
const client = redis.createClient({
    host: 'localhost',
    port: 6379
});
client.on('error', (err) => {
    console.error('Redis 에러:', err);
});
client.connect();
// 캐시 설정
async function setCache(key, value, ttl = 3600) {
    await client.setEx(key, ttl, JSON.stringify(value));
}
// 캐시 조회
async function getCache(key) {
    const value = await client.get(key);
    return value ? JSON.parse(value) : null;
}
// 캐시 삭제
async function deleteCache(key) {
    await client.del(key);
}
module.exports = { setCache, getCache, deleteCache };
// 사용
// 변수 선언 및 초기화
const { getCache, setCache } = require('./cache');
app.get('/api/users/:id', async (req, res) => {
    const { id } = req.params;
    const cacheKey = `user:${id}`;
    
    // 캐시 확인
    let user = await getCache(cacheKey);
    
    if (user) {
        console.log('캐시 히트');
        return res.json({ user, cached: true });
    }
    
    // 데이터베이스 조회
    user = await User.findById(id);
    
    if (!user) {
        return res.status(404).json({ error: '사용자 없음' });
    }
    
    // 캐시 저장 (1시간)
    await setCache(cacheKey, user, 3600);
    
    res.json({ user, cached: false });
});

캐시 무효화

app.put('/api/users/:id', async (req, res) => {
    const { id } = req.params;
    
    const user = await User.findByIdAndUpdate(id, req.body, { new: true });
    
    // 캐시 무효화
    await deleteCache(`user:${id}`);
    
    res.json({ user });
});

3. 데이터베이스 최적화

인덱스

// MongoDB
userSchema.index({ email: 1 });  // 단일 인덱스
userSchema.index({ name: 1, age: -1 });  // 복합 인덱스
userSchema.index({ email: 1 }, { unique: true });
// 인덱스 확인
const indexes = await User.collection.getIndexes();
console.log(indexes);

쿼리 최적화

// ❌ 느린 쿼리
const posts = await Post.find();
for (const post of posts) {
    const author = await User.findById(post.author);  // N+1 문제
}
// ✅ Populate 사용
const posts = await Post.find().populate('author');
// ✅ 필요한 필드만 선택
const posts = await Post.find()
    .select('title content author')
    .populate('author', 'name email');
// ✅ Lean (Mongoose 객체 → Plain Object)
const posts = await Post.find().lean();  // 더 빠름

커넥션 풀

// MongoDB
mongoose.connect('mongodb://localhost:27017/mydb', {
    maxPoolSize: 10,  // 최대 연결 수
    minPoolSize: 2
});
// PostgreSQL
const pool = new Pool({
    max: 20,
    min: 5,
    idleTimeoutMillis: 30000
});

4. 비동기 최적화

병렬 처리

// ❌ 순차 실행 (느림)
async function sequential() {
    const users = await User.find();
    const posts = await Post.find();
    const comments = await Comment.find();
    
    return { users, posts, comments };
}
// 총 시간: T1 + T2 + T3
// ✅ 병렬 실행 (빠름)
async function parallel() {
    const [users, posts, comments] = await Promise.all([
        User.find(),
        Post.find(),
        Comment.find()
    ]);
    
    return { users, posts, comments };
}
// 총 시간: max(T1, T2, T3)

동시 실행 제한

// p-limit 사용
const pLimit = require('p-limit');
async function processFiles(files) {
    const limit = pLimit(5);  // 최대 5개 동시 실행
    
    const results = await Promise.all(
        files.map(file => limit(() => processFile(file)))
    );
    
    return results;
}

5. 메모리 관리

메모리 사용량 확인

function logMemoryUsage() {
    const used = process.memoryUsage();
    
    console.log({
        rss: `${Math.round(used.rss / 1024 / 1024)} MB`,  // 총 메모리
        heapTotal: `${Math.round(used.heapTotal / 1024 / 1024)} MB`,  // 할당된 힙
        heapUsed: `${Math.round(used.heapUsed / 1024 / 1024)} MB`,  // 사용 중인 힙
        external: `${Math.round(used.external / 1024 / 1024)} MB`  // C++ 객체
    });
}
setInterval(logMemoryUsage, 60000);  // 1분마다

메모리 누수 방지

// ❌ 메모리 누수
const cache = new Map();
app.get('/api/data/:id', async (req, res) => {
    const data = await fetchData(req.params.id);
    cache.set(req.params.id, data);  // 계속 쌓임!
    res.json(data);
});
// ✅ LRU 캐시 사용
const LRU = require('lru-cache');
const cache = new LRU({
    max: 500,  // 최대 500개
    maxAge: 1000 * 60 * 60  // 1시간
});
app.get('/api/data/:id', async (req, res) => {
    let data = cache.get(req.params.id);
    
    if (!data) {
        data = await fetchData(req.params.id);
        cache.set(req.params.id, data);
    }
    
    res.json(data);
});

스트림 사용

// ❌ 전체 파일을 메모리에 로드
// 실행 예제
app.get('/download', async (req, res) => {
    const data = await fs.promises.readFile('large-file.pdf');
    res.send(data);
});
// ✅ 스트림 사용
app.get('/download', (req, res) => {
    const stream = fs.createReadStream('large-file.pdf');
    stream.pipe(res);
});

일상 비유로 이해하기: 메모리를 아파트 건물로 생각해보세요. 스택은 엘리베이터 같아서 빠르지만 공간이 제한적입니다. 힙은 창고처럼 넓지만 물건을 찾는 데 시간이 걸립니다. 포인터는 “3층 302호”처럼 주소를 가리키는 메모지라고 보면 됩니다.

6. 프로파일링

Node.js 내장 프로파일러

# CPU 프로파일
node --prof app.js
# 프로파일 분석
node --prof-process isolate-0x*.log > processed.txt

Chrome DevTools

# 디버그 모드로 실행
node --inspect app.js
# 또는 중단점과 함께
node --inspect-brk app.js

브라우저에서 chrome://inspect 접속 후 프로파일링.

clinic.js

npm install -g clinic
# CPU 프로파일
clinic doctor -- node app.js
# 이벤트 루프 지연
clinic bubbleprof -- node app.js
# 메모리 누수
clinic heapprofiler -- node app.js

7. 벤치마킹

Apache Bench

# 설치
sudo apt install apache2-utils
# 테스트
ab -n 1000 -c 10 http://localhost:3000/
# -n: 총 요청 수
# -c: 동시 연결 수

autocannon

npm install -g autocannon
# 테스트
autocannon -c 10 -d 10 http://localhost:3000/
# -c: 동시 연결 수
# -d: 지속 시간 (초)

벤치마크 코드

// benchmark.js
const autocannon = require('autocannon');
async function runBenchmark() {
    const result = await autocannon({
        url: 'http://localhost:3000',
        connections: 10,
        duration: 10,
        pipelining: 1
    });
    
    console.log('요청/초:', result.requests.mean);
    console.log('지연시간:', result.latency.mean, 'ms');
    console.log('처리량:', result.throughput.mean, 'bytes/sec');
}
runBenchmark();

8. 실전 최적화 예제

예제 1: API 응답 캐싱

const express = require('express');
const redis = require('redis');
const app = express();
const client = redis.createClient();
await client.connect();
// 캐시 미들웨어
function cacheMiddleware(ttl = 3600) {
    return async (req, res, next) => {
        const key = `cache:${req.originalUrl}`;
        
        try {
            const cached = await client.get(key);
            
            if (cached) {
                console.log('캐시 히트');
                return res.json(JSON.parse(cached));
            }
            
            // 원래 res.json을 래핑
            const originalJson = res.json.bind(res);
            res.json = (data) => {
                client.setEx(key, ttl, JSON.stringify(data));
                return originalJson(data);
            };
            
            next();
        } catch (err) {
            next();
        }
    };
}
// 사용
app.get('/api/users', cacheMiddleware(60), async (req, res) => {
    const users = await User.find();
    res.json({ users });
});

예제 2: 데이터베이스 쿼리 최적화

// ❌ 비효율적
async function getPostsWithAuthors() {
    const posts = await Post.find();
    
    for (const post of posts) {
        post.author = await User.findById(post.author);  // N+1
    }
    
    return posts;
}
// ✅ 최적화
async function getPostsWithAuthorsOptimized() {
    return await Post.find()
        .populate('author', 'name email')
        .select('title content author createdAt')
        .lean()  // Plain Object로 변환 (빠름)
        .limit(20);
}

예제 3: 이미지 최적화

npm install sharp
const sharp = require('sharp');
const fs = require('fs');
async function optimizeImage(inputPath, outputPath) {
    await sharp(inputPath)
        .resize(800, 600, {
            fit: 'inside',
            withoutEnlargement: true
        })
        .jpeg({ quality: 80 })
        .toFile(outputPath);
    
    const inputSize = fs.statSync(inputPath).size;
    const outputSize = fs.statSync(outputPath).size;
    
    console.log(`압축률: ${((1 - outputSize / inputSize) * 100).toFixed(2)}%`);
}
// Express에서 사용
const multer = require('multer');
const upload = multer({ dest: 'uploads/' });
app.post('/upload', upload.single('image'), async (req, res) => {
    const inputPath = req.file.path;
    const outputPath = `optimized/${req.file.filename}.jpg`;
    
    await optimizeImage(inputPath, outputPath);
    
    res.json({ path: outputPath });
});

9. 압축

gzip 압축

npm install compression
const compression = require('compression');
// 모든 응답 압축
app.use(compression());
// 조건부 압축
app.use(compression({
    filter: (req, res) => {
        if (req.headers['x-no-compression']) {
            return false;
        }
        
        return compression.filter(req, res);
    },
    level: 6  // 압축 레벨 (0-9)
}));

효과:

  • HTML: 70-90% 감소
  • JSON: 60-80% 감소
  • CSS/JS: 50-70% 감소

10. 자주 발생하는 문제

문제 1: 이벤트 루프 블로킹

// ❌ CPU 집약적 작업 (블로킹)
app.get('/heavy', (req, res) => {
    let sum = 0;
    for (let i = 0; i < 1e9; i++) {
        sum += i;
    }
    res.json({ sum });
});
// ✅ Worker Threads 사용
const { Worker } = require('worker_threads');
app.get('/heavy', (req, res) => {
    const worker = new Worker('./heavy-task.js');
    
    worker.on('message', (result) => {
        res.json({ sum: result });
    });
    
    worker.on('error', (err) => {
        res.status(500).json({ error: err.message });
    });
});
// heavy-task.js
const { parentPort } = require('worker_threads');
let sum = 0;
for (let i = 0; i < 1e9; i++) {
    sum += i;
}
parentPort.postMessage(sum);

문제 2: 메모리 누수

원인: 전역 변수, 이벤트 리스너 미제거, 캐시 무한 증가

// ❌ 메모리 누수
const EventEmitter = require('events');
const emitter = new EventEmitter();
app.get('/api/data', (req, res) => {
    emitter.on('data', (data) => {  // 리스너가 계속 쌓임!
        res.json(data);
    });
});
// ✅ 리스너 제거
app.get('/api/data', (req, res) => {
    const handler = (data) => {
        res.json(data);
        emitter.off('data', handler);  // 제거
    };
    
    emitter.on('data', handler);
});

11. 실전 팁

성능 모니터링

// 응답 시간 측정
app.use((req, res, next) => {
    const start = Date.now();
    
    res.on('finish', () => {
        const duration = Date.now() - start;
        
        if (duration > 1000) {
            console.warn(`느린 요청: ${req.method} ${req.url} - ${duration}ms`);
        }
    });
    
    next();
});

에러 처리 최적화

// ❌ 동기 에러 처리 (try-catch 오버헤드)
app.get('/api/users', async (req, res) => {
    try {
        const users = await User.find();
        res.json({ users });
    } catch (err) {
        res.status(500).json({ error: err.message });
    }
});
// ✅ 에러 핸들러로 위임
function asyncHandler(fn) {
    return (req, res, next) => {
        Promise.resolve(fn(req, res, next)).catch(next);
    };
}
app.get('/api/users', asyncHandler(async (req, res) => {
    const users = await User.find();
    res.json({ users });
}));
// 전역 에러 핸들러
app.use((err, req, res, next) => {
    logger.error(err.message, { stack: err.stack });
    res.status(500).json({ error: 'Internal Server Error' });
});

Keep-Alive

const http = require('http');
const server = http.createServer((req, res) => {
    res.end('Hello');
});
// Keep-Alive 설정
server.keepAliveTimeout = 65000;  // 65초
server.headersTimeout = 66000;  // 66초
server.listen(3000);

정리

핵심 요약

  1. 클러스터링: 멀티 코어 활용, PM2 클러스터 모드
  2. 캐싱: Redis, 인메모리 캐시, TTL 설정
  3. 데이터베이스: 인덱스, 쿼리 최적화, 커넥션 풀
  4. 비동기: 병렬 처리, 동시 실행 제한
  5. 메모리: 스트림 사용, LRU 캐시, 메모리 모니터링
  6. 압축: gzip, 이미지 최적화

성능 최적화 우선순위

  1. 데이터베이스 쿼리: 가장 큰 병목
  2. 캐싱: 빠른 효과
  3. 비동기 최적화: 병렬 처리
  4. 압축: 네트워크 비용 절감
  5. 클러스터링: 멀티 코어 활용

측정 도구

도구용도
--profCPU 프로파일링
Chrome DevTools메모리, CPU 분석
clinic.js종합 진단
autocannonHTTP 벤치마크
PM2프로세스 모니터링

다음 단계

  • Node.js 보안 심화
  • Node.js 마이크로서비스

추천 학습 자료

도구:

관련 글

심화 부록: 구현·운영 관점

이 부록은 앞선 본문에서 다룬 주제(「Node.js 성능 최적화 | 클러스터링, 캐싱, 프로파일링」)를 구현·런타임·운영 관점에서 다시 압축합니다. 도메인별 세부 구현은 글마다 다르지만, 입력 검증 → 핵심 연산 → 부작용(I/O·네트워크·동시성) → 관측의 흐름으로 장애를 나누면 원인 추적이 빨라집니다.

내부 동작과 핵심 메커니즘

flowchart TD
  A[입력·요청·이벤트] --> B[파싱·검증·디코딩]
  B --> C[핵심 연산·상태 전이]
  C --> D[부작용: I/O·네트워크·동시성]
  D --> E[결과·관측·저장]
sequenceDiagram
  participant C as 클라이언트/호출자
  participant B as 경계(런타임·게이트웨이·프로세스)
  participant D as 의존성(API·DB·큐·파일)
  C->>B: 요청/이벤트
  B->>D: 조회·쓰기·RPC
  D-->>B: 지연·부분 실패·재시도 가능
  B-->>C: 응답 또는 오류(코드·상관 ID)
  • 불변 조건(Invariant): 버퍼 경계, 프로토콜 상태, 트랜잭션 격리, FD 상한 등 단계별로 문장으로 적어 두면 디버깅 비용이 줄어듭니다.
  • 결정성: 순수 층과 시간·네트워크·스케줄에 의존하는 층을 분리해야 테스트와 장애 분석이 쉬워집니다.
  • 경계 비용: 직렬화, 인코딩, syscall 횟수, 락 경합, 할당·GC, 캐시 미스를 의심 목록에 둡니다.
  • 백프레셔: 생산자가 소비자보다 빠를 때 버퍼·큐·스트림에서 속도를 줄이는 신호를 어디에 둘지 정의합니다.

프로덕션 운영 패턴

영역운영 관점 질문
관측성요청 단위 상관 ID, 에러율·지연 p95/p99, 의존성 타임아웃·재시도가 대시보드에 보이는가
안전성입력 검증·권한·비밀·감사 로그가 코드 경로마다 일관적인가
신뢰성재시도는 멱등 연산에만 적용되는가, 서킷 브레이커·백오프·DLQ가 있는가
성능캐시·배치 크기·커넥션 풀·인덱스·백프레셔가 데이터 규모에 맞는가
배포롤백 룬북, 카나리/블루그린, 마이그레이션·피처 플래그가 문서화되어 있는가
용량피크 트래픽·디스크·FD·스레드 풀 상한을 주기적으로 검증하는가

스테이징은 데이터 양·네트워크 RTT·동시성을 프로덕션에 가깝게 맞출수록 재현율이 올라갑니다.

확장 예시: 엔드투엔드 미니 시나리오

앞선 본문 주제(「Node.js 성능 최적화 | 클러스터링, 캐싱, 프로파일링」)를 배포·운영 흐름에 맞춰 옮긴 체크리스트입니다. 도메인에 맞게 단계 이름만 바꿔 적용할 수 있습니다.

  1. 입력 계약 고정: 스키마·버전·최대 페이로드·타임아웃·에러 코드를 경계에 둔다.
  2. 핵심 경로 계측: 요청 ID, 단계별 지연, 외부 호출 결과 코드를 로그·메트릭·트레이스에서 한 흐름으로 본다.
  3. 실패 주입: 의존성 타임아웃·5xx·부분 데이터·락 대기를 스테이징에서 재현한다.
  4. 호환·롤백: 설정/마이그레이션/클라이언트 버전을 되돌릴 수 있는지 확인한다.
  5. 부하 후 검증: 피크 대비 p95/p99, 에러율, 리소스 상한, 알림 임계값을 점검한다.
handle(request):
  ctx = newCorrelationId()
  validated = validateSchema(request)
  authorize(validated, ctx)
  result = domainCore(validated)
  persistOrEmit(result, idempotentKey)
  recordMetrics(ctx, latency, outcome)
  return result

문제 해결(Troubleshooting)

증상가능 원인조치
간헐적 실패레이스, 타임아웃, 외부 의존성, DNS최소 재현 스크립트, 분산 트레이스·로그 상관관계, 재시도·서킷 설정 점검
성능 저하N+1, 동기 I/O, 락 경합, 과도한 직렬화, 캐시 미스프로파일러·APM으로 핫스팟 확인 후 한 가지씩 제거
메모리 증가캐시 무제한, 구독/리스너 누수, 대용량 버퍼, 커넥션 미반납상한·TTL·힙/FD 스냅샷 비교
빌드·배포만 실패환경 변수, 권한, 플랫폼 차이, lockfileCI 로그와 로컬 diff, 런타임·이미지 버전 핀
설정 불일치프로필·시크릿·기본값, 리전스키마 검증된 설정 단일 소스와 배포 매트릭스 표준화
데이터 불일치비멱등 재시도, 부분 쓰기, 캐시 무효화 누락멱등 키·아웃박스·트랜잭션 경계 재검토

권장 순서: (1) 최소 재현 (2) 최근 변경 범위 축소 (3) 환경·의존성 차이 (4) 관측으로 가설 검증 (5) 수정 후 회귀·부하 테스트.

배포 전에는 git add → git commit → git push 후 npm run deploy 순서를 권장합니다.

자주 묻는 질문 (FAQ)

Q. 이 내용을 실무에서 언제 쓰나요?

A. Node.js 성능 최적화: 클러스터링, 캐싱, 프로파일링. 클러스터링 (Clustering)·캐싱 (Caching)로 흐름을 잡고 원리·코드·실무 적용을 한글로 정리합니다. Node.js·성능최적화·클러스터 중심으… 실무에서는 위 본문의 예제와 선택 가이드를 참고해 적용하면 됩니다.

Q. 선행으로 읽으면 좋은 글은?

A. 각 글 하단의 이전 글 또는 관련 글 링크를 따라가면 순서대로 배울 수 있습니다. C++ 시리즈 목차에서 전체 흐름을 확인할 수 있습니다.

Q. 더 깊이 공부하려면?

A. cppreference와 해당 라이브러리 공식 문서를 참고하세요. 글 말미의 참고 자료 링크도 활용하면 좋습니다.

같이 보면 좋은 글 (내부 링크)

이 주제와 연결되는 다른 글입니다.

이 글에서 다루는 키워드 (관련 검색어)

Node.js, 성능최적화, 클러스터, 캐싱, 프로파일링, 벤치마크 등으로 검색하시면 이 글이 도움이 됩니다.