🥳 typeorm을 이용한 FCM 알림 서비스

발단

• 주춤주춤 서비스는 초보자를 위한 서비스이다.

  • 알림을 처음 설정하고 나서 유저는 신경을 쓰지 않아도 설정한 가격, 거래량에 도달하면 알림을 받을 수 있게 주식 서비스를 구성하고자 했다.

• 알림 서비스를 구현할 때 고려한 부분은 크게 두가지이다.

  • 서버의 부하 가능성
    • 채팅서버, 주식 데이터 서버 등등 이미 부하가 있는 상황에서 알림까지 부하를 가하기에는 부담이 있었다.
    • 현재 서버 구조는 각 구조가 분리되어 있지 않은 환경이라 더더욱 부하 가능성에 문제가 있을 수 있었다.
  • 오프라인 환경에서도 제대로 작동되어야 함.
    • 초보자에게 주식을 지속해서 확인하는 상황보다는 비교적 자유롭게 확인이 가능해야 한다.

알림 서비스 구현 방법

SSE (Server-Sent Events)

서버 부하 가능성

• 클라이언트와 서버 간 지속적인 연결을 유지해야 하므로, 연결 수가 많아질수록 서버 자원이 소모된다.
• 많은 사용자를 동시에 지원하려면 서버 확장이 필요할 수 있으며, 특히 실시간 데이터 스트리밍 서비스에서 부하 관리가 어려울 수 있다.
  • 특히 한 서버 환경에서 지원하는 SSE는 HTTP 2.0 기준으로 100개에 불과하다.

오프라인 환경 작동

• 클라이언트가 브라우저 탭을 닫거나 네트워크 연결이 끊기면 알림을 받을 수 없다.
• 연결이 유지되는 동안에는 실시간으로 데이터를 받을 수 있지만, 오프라인 환경에서는 알림이 중단된다.

Web Push

서버 부하 가능성

• 서버는 필요할 때만 푸시 메시지를 전송하므로 지속적인 연결이 필요하지 않다. 따라서 서버 부하가 상대적으로 적다.
• 푸시 메시지는 푸시 서버를 통해 전달되므로, 서버 부하의 대부분은 클라이언트와 직접 연결된 푸시 서버가 처리한다.

오프라인 환경 작동

• 사용자가 브라우저를 닫거나 오프라인 상태여도, 푸시 메시지가 전송되면 사용자는 알림을 받을 수 있다.

• 네트워크가 복구되면 푸시 서버가 메시지를 전달하므로, 사용자가 다시 온라인이 되었을 때 알림을 놓치지 않는다.

• 이런 점에서 Web Push를 이용한 구현으로 접근했다.

이벤트 흐름도

• typeorm의 afterInsert를 이용해 이벤트가 발생할 때마다 subscriber가 작동될 수 있게 이벤트를 설계했다.

graph
    A[OpenapiMinuteData] -->|insert| B[StockMinutely Table]
    B -.->|TypeORM event| C[AlarmSubscriber]
    C --> D[AlarmService.sendPushNotification]

    subgraph OpenapiScraperModule
        A
        B
    end

    subgraph AlarmModule
        C
        D
    end

Loading

발생했던 문제점

외부서비스 API 요청 제한 문제

• 주춤주춤 서비스는 외부 서비스인 한국투자증권의 api를 사용해 분단위 데이터를 가져 온다.
• 문제는 현재 api를 이용해 데이터를 가져오는 다른 서비스가 많고, api의 최대 요청 횟수는 초당 20회, 사용 가능한 api가 4개여서 최대 80개를 처리할 수 있었다.
• 1000명이 알림을 3개 등록한 상황에서 공통된 알림의 경우 제외한다고 해도 발생하지 않았다.

문제 접근 법

• 비즈니스 로직적 측면

  • 현재(2024년 12월 3일) 기준 한국의 코스피, 코스닥에 상장되어 있는 주식(ETN, ETF 등 포함)은 대략 4200개 정도이다.
  • 분단위 데이터를 일분에 한번 받고, 1초에 80건의 요청이 처리가능하면 4800건의 요청을 1분에 모두 처리할 수 있다.
  • 다만, 다른 api 요청이 있고, 이 요청들이 가져올 수 있는 부하를 아직 테스트하지 못해 일단 알림을 등록한 건 중 많은 주식 관련 알림 상위 200건에 대해서만 요청이 가능하게 처리를 진행했다.

• 서버 부하적인 측면

참고 자료

SSE MDN Web Docs

Push API MDN Web Docs

npm web-push library

firebase transfer to v1

Sanha Ko - PWA 환경에서 푸시 알림 구현하기