10.2.2 고가용 마이크로서비스 만들기

앞에서 배운 cluster 모듈을 우리가 만든 마이크로서비스에 적용하겠습니다. 이때 예제와 다른 점은 자식 프로세스에서 exit 이벤트가 감지되면 새로운 자식 프로세스를 실행하는 부분입니다. 상품 관리 마이크로서비스에 cluster 모듈을 이용해 Failover 기능을 만듭니다.

코드 10-2 상품 관리 마이크로서비스에 cluster 모듈 적용

예제 파일 : microservice_goods.js

'use strict';

const business = require('../chapter5/monolithic_goods.js');
const cluster = require('cluster');  // ➊ cluster 모듈 로드

class goods extends require('./server.js') {
    constructor() {
        super("goods"
            , process.argv[2] ? Number(process.argv[2]) : 9010
            , ["POST/goods", "GET/goods", "DELETE/goods"]);

        this.connectToDistributor("127.0.0.1", 9000, (data) => {
            console.log("Distributor Notification", data);
        });
    }

    onRead(socket, data) {
        console.log("onRead", socket.remoteAddress, socket.remotePort, data);
        business.onRequest(socket, data.method, data.uri, data.params, (s, packet) => {
                           socket.write(JSON.stringify(packet) + '¶');
        });
    }
}

if (cluster.isMaster) {              // ➋ 자식 프로세스 실행
        cluster.fork();

        // ➌ exit 이벤트가 발생하면 새로운 자식 프로세스 실행
        cluster.on('exit', (worker, code, signal) => {
            console.log(`worker ${worker.process.pid} died`);
            cluster.fork();
    });
}else {
    new goods();
}

cluster 모듈을 로드하고(➊) 부모 프로세스에서 자식 프로세스를 하나 실행합니다(➋). 자식 프로세스에서 exit 이벤트가 발생하면 새로운 자식 프로세스를 실행합니다(➌).