[node.js] Subscriber / Publisher

Hyo Kyun Lee·2021년 7월 30일

Subscriber node.js publisher

node.js

목록 보기

31/34

1-1. Subscriber/Publisher Pattern

message queue 경로를 통해 서로 종속적인 관계에 있는 module을 분리하는 과정

Publisher는 data를 전달하는 주체, Subscriber는 data를 전달받는 대상이다.

서로 직접적으로 data를 주고받는 과정을, Publisher가 evenet를 발생하는 등의 특정 시점에서 Subscriber가 data를 받는 과정을 활용하는 방법이다.

위 도식에서 알 수 있듯이, Publusher가 event를 publish하는 시점에서 Event channel를 거쳐 Subscriber에게 data가 전달된다.

subscriber는 해당 channel을 subscribe해야 해당 data를 받을 수 있고, 이 Publisher와 subscriber의 관계를 Sub/Pub Pattern이라 한다.

1-2. 특징

Sub/Pub 관계는 msg를 event 기반, 중개자를 통한 전달을 특징으로 하는 구조이다.

pub/sub는 넓게 보면 module을 분리하여 특정 시점에 data를 보내는 것으로, microservice 환경구조와 흡사하다.
서로 component들의 분리를 되어 각 module의 관리 및 유지보수가 쉬워진다.
Publisher는 data를 보낼때 기본적으로 subscriber가 존재한다는 가정하에 보내며, 이로 인한 불필요한 data 전달 및 자원사용이 이루어질 수 있다.
버그가 많아진다.

1-3. 코드예시(기본구조)

코드예시를 통해 Pub/Sub의 기본구조를 이해해보자.

코드를 살펴보기전에 pub/sub를 이해하기위한 항목을 살펴본다.

pub, sub class가 존재한다.
event 시점을 발생하고(class 호출 시), 이 발생한 event에 따라 어떻게 동작하는지 logic을 정의하는 eventemitter module를 사용한다.
pub가 보낸 msg를 sub가 받아 출력한다.

"use strict";
const events = require("events");
const eventsEmitter = new events.EventEmitter();
let eventName = "greeting";
class Publisher {
  constructor() {}

  publishMessage() {
    let message = "hello";
    eventsEmitter.emit(eventName, message);
  }
}
class Subscriber {
  constructor() {
    eventsEmitter.on(eventName, (greeting) => {
      console.log("Someone sent me a greeting: " + greeting);
    });
  }
}
// Lets create our publisher and subscriber
const publisher = new Publisher();
const subscriber = new Subscriber();
publisher.publishMessage();