상품 관리와 동일하게 Distributor와 비즈니스 로직을 호출하기 위해 다음 코드를 추가합니다.

코드 7- 6 회원 관리 마이크로서비스 Distributor, onRead 구현

예제 파일 : microservice_members.js

......
        super("members", process.argv[2] ? Number(process.argv[2]) : 902
            , ["POST/members", "GET/members"
                , "DELETE/members"]);
        
        this.connectToDistributor("127.0.0.1", 9000, (data) => { // ➊ Distributor 접속
            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) + '¶');
        });
    }
}

new members();

Distributor에 접속하려고 connectToDistributor 함수를 호출하고(➊), onRead 함수를 호출해 들어오는 API 요청에 맞는 비즈니스 로직을 호출합니다(➋).