미션 첫 인상 및 설계 방향 💡

미션을 이해하는 것조차 버겁게 느껴졌다… 감히 지금까지의 미션 중 가장 첫인상도 어렵고, 마지막까지 어렵다고 느껴진다…

미션 해결 중 문제점

• 짝 프로그래밍을 하며 코드를 작성하는 습관이나 방법이 전부 다른 캠퍼와 하면서, 그 자체에 대한 이해가 어려웠던 문제점이 있었다… 내가 보탬이 되고 있지 않다는 생각이 들어 그 점도 힘들었고, 서로 다른 의견을 맞춰가는 과정도 힘들었다. 하지만, 그만큼 어떻게 의견을 조율해야 하는지, 어떻게 다른 프로그래머의 코드를 잘 이해할 수 있는지에 대한 부분을 생각하며 많이 성장한 것 같다.

오늘 공부한 이론 🔍

• Publisher-Scriber 패턴

  • 비동기 메시징 패러다임
  • 발행자와 구독자가 있고, 그 사이에 브로커(message queue)가 있는 형태

  

  1. 발행자 메시지의 수신자가 정해져 있지 않다.

  2. 메시지는 정해진 범주에 따라서 구독을 신청한 수신자에게 전달이 된다.

  3. 수신자는 발행자에 대한 정보 없이, 원하는 메시지를 수신할 수 있다.

  4. 메시지 큐 패러다임과 마치 형제같은 관계로, 대형 메시지 지향 미들웨어 솔루션의 일부라고 한다.

• 발행자와 구독자

  1. pub이 sub의 선언 위치나 존재를 알 필요가 없다.
  • 메시지 큐와 같은 브로커 역할을 하는 중간 지점에 메시지를 던져 두기만 하면, 브로커가 알아서 처리한다.
  2. sub 역시 pub의 선언 위치나 존재를 알 필요가 없다.
  • 브로커에 할당된 작업만을 모니터링하고, 원하는 작업이 발생하면 할당받아 작업을 수행하면 된다.

  그러므로 pub, sub은 서로 알 필요가 없으며, 브로커와의 통신만을 수행할 수 있다면 역할을 잘 수행하는 것이다.

• 브로커

  • 발행자와 구독자 사이에 위치
  • 주로 메시지 큐가 브로커 역할 수행, 두 객체 사이에서 구독과 발행 이후의 메시지 처리해줌
  • 브로커가 들어오는 모든 메시지를 필터링하고, 타겟(구독자)에게 메시지를 처리해줌.

• 메시지큐

  • 대용량 데이터 처리를 위한 배치 작업이나 채팅 서비스, 비동기 데이터 처리등에 이용
  • 프로세스나 프로그램 인스턴스가 데이터 상호 교환 시 사용하는 통신 방법
  • 장점
    • 비동기(Asynchronous) : 큐에 넣어서 나중에 처리 가능
    • 비동조(Decoupling) : 앱과 분리 가능
    • 탄력성(Resilience) : 일부 실패가 전체에 영향x
    • 과잉(Redunadancy) : 실패할 경우 재실행 가능
    • 보증(Guarantees) : 작업 처리 확인 가능
    • 확장성(Scalable) : 다수 프로세스들이 큐에 메시지 보내기 가능
  • 단점
    • '큐'이기 때문에 사용자가 많아지거나, 데이터가 많아지면 요청에 대한 응답이 늦어지게 된다.
    • 즉 과도한 트래픽이 몰리게 되면, 대기 시간 지연으로 인해 서비스가 망가질 위험이 있다.

• 싱글톤

  • 싱글톤 패턴은 특정 클래스의 인스턴스를 1개만 생성되는 것을 보장하는 디자인 패턴
  • 생성자를 통해서 여러 번 호출이 되더라도 인스턴스를 새로 생성하지 않고 최초 호출 시에 만들어두었던 인스턴스를 재활용
  • 싱글톤 패턴을 사용함으로써 얻을 수 있는 이점 중 하나는 메모리 낭비를 방지
  • 의존성이 높아짐
  • 테스트하기 어려움

• Worker Thread

  // worker 클래스는 독립적인 자바스크립트 실행 스레드를 의미하고, parentPort는 메시지 포트의 인스턴스
  const { worker, parentPort } = require('worker_threads')
  
  // 워커를 시작하는 두가지 메인 방법(파일 명을 넘기거나, 실행하고자 하는 코드를 작성하거나)
  new Worker(filename)
  new Worker(code,{eval:true})
  
  // 다른 스레드 간 메시지를 주고받을 때 사용
  worker.on('message'),worker.postMessage(data)
  
  // parentPort.postMessage(data) 를 통해 보내진 메세지는 worker.on('message') 를 사용한 부모 스레드에서 사용 
  // worker.postMessage(data) 를 사용한 부모 스레드로부터 보내진 메세지는 parentPort.on('message') 를 사용한 스레드에서 사용 가능
  parentPort.on('message'),parentPort.postMessage(data)
  

• EventEmitter
  • EventEmitter 클래스를 상속한 객체를 만들고, on() 메서드를 사용하여 이벤트 리스너를 등록하면, 이벤트가 발생할 때마다 등록된 콜백 함수가 실행됨
  • 이벤트는 문자열 형태의 이름과 함께 발생하며, 이벤트에 대한 데이터를 선택적으로 전달할 수 있음.
  • Promise VS EventEmitter
    • Promise
      • 비동기 작업이 완료될 때마다 실행할 콜백 함수를 등록하는 방식보다 더 깔끔하고 직관적인 방식으로 비동기 작업 처리할 수있도록 하는 객체
      • 비동기 작업의 성공 또는 실패 상태를 쉽게 확인하고 처리 가능
    • EventEmitter
      • 이벤트 기반 프로그래밍에서 사용되는 객체
      • 이벤트를 발생시키고, 이벤트가 발생했을 때 처리할 콜백 함수를 등록
      • 이벤트는 이름과 함께 발생하며, 발생한 이벤트를 처리할 수 있는 모든 리스너에게 알림
      • 여러 개의 콜백 함수를 동시에 처리 가능