-
Notifications
You must be signed in to change notification settings - Fork 1
SSE vs Socket.io
JIN edited this page Dec 3, 2024
·
1 revision
클라이언트의 별도 요청 없이 서버에서 업데이트를 스트리밍
HTTP 통신으로, 구현이 쉬움
네트워크 연결이 끊겼을 때 자동으로 재연결 시도
실시간으로 클라이언트에게 데이터 전송 가능
단방향 통신
한번 보내면 취소가 불가능
클라이언트가 페이지를 닫아도 서버에서 감지하기 어려움
HTTP2를 사용하지 않을 경우에 탭 제한을 걸고 있음
- 6개 이상 열리면 안될 수도 있고, 크롬 등에서 고치지 않을 것이라 함
- HTTP2로 하면 100개 이상 허용
현재 작성한 코드는 양방향 통신이 필요 없는 상황
보낸 내용을 취소할 이유가 없음
@ApiTags('주식현재가 체결 조회 API')
@Controller('/api/stocks/trade-history')
export class StockTradeHistoryController {
constructor(
private readonly stockTradeHistoryService: StockTradeHistoryService,
private readonly stockTradeHistorySocketService: StockTradeHistorySocketService,
) {}
// API 코드
@Sse(':stockCode/today-sse')
@ApiOperation({ summary: '단일 주식 종목에 대한 실시간 체결 데이터 스트림' })
@ApiParam({
name: 'stockCode',
required: true,
description:
'종목 코드\n\n' +
'(ex) 005930 삼성전자 / 005380 현대차 / 001500 현대차증권',
})
@ApiResponse({
status: 200,
description:
'단일 주식 종목에 대한 주식현재가 체결값 실시간 데이터 조회 성공',
type: TodayStockTradeHistoryDataDto,
})
streamTradeHistory(@Param('stockCode') stockCode: string) {
this.stockTradeHistorySocketService.subscribeByCode(stockCode);
return new Observable<SseEvent>((subscriber) => {
const subscription = this.stockTradeHistorySocketService
.getTradeDataStream()
.subscribe(subscriber);
return () => {
this.stockTradeHistorySocketService.unsubscribeByCode(stockCode);
subscription.unsubscribe();
};
});
}
}
- SSE의 제약사항
- HTTP/1.1 크롬 브라우저 기준으로는 최대 연결 수가 6개
- HTTP/2 크롬 브라우저 기준으로는 기본 100개 사용 가능 - 100개 이상으로 사용하고 싶다면 추가 설정 필요
- Nginx에 SSE와 관련된 추가 설정 필요
- Websocket의 이벤트 이름과 같이 필터링할 수단이 없어 직접 필터링을 해야 함
- WebSocket
- SSE와 같이 별도의 연결 제한이 없음
- 이벤트 이름으로 필터링이 가능해 추가적인 필터링이 필요없음
위와 같은 이유와 기존 코드들이 socket.io로 작성되었던 점을 고려해 다시 socket.io를 사용하기로 함
- [FE] 프론트엔드 기술스택
- [FE] 라이브러리 없이 차트 구현 이유
- [FE] Canvas API 사용방법
- [FE] 네비게이션 바 애니메이션 구현
- [FE] Socket.io 사용방법
- [FE] Tanstack Router에 대하여...
- [FE] Intl(Internationalization) API
- [FE] React Suspense 적용
- [FE] 한글 입력 방식의 유연성을 높인 검색 시스템 구현하기
- [BE] 백엔드 기술 스택
- [BE] SSE vs Socket.io
- [BE] Redis를 도입하게 된 계기
- [BE] ACG Rule을 활용한 Secure CI CD 파이프라인 구현
- [BE] Nginx 로드밸런싱을 통해 한국 투자 API 소켓 제한 극복
- [BE] 주가 지수 기능 개발 과정
- [BE] 매수 및 매도 기능 개발 과정
- [BE] 실시간 자산 조회 기능 개발 과정
- [BE] 단위 테스트
- [BE] redis를 이용한 한국투자 Open API 세션 관리
- [BE] 데이터베이스 인덱싱
- [FE] React에서의 DOM 요소 접근 (useRef vs getElementById)
- [FE] Outlet을 활용한 공통 레이아웃 관리
- [FE] react hooks가 특정 조건에서 실행되면 안되는 이유 & useQuery에 query function 매개변수가 undefined일 수도 있을 때 어떻게 해결할까
- [FE] cross‐domain 로컬 환경에서 cookie로 인증 처리하기 with vite proxy
- [FE] 크롬&사파리 Composition 차이
- [FE] useEffect 의존성 배열
- [BE] Naver Cloud Platform HTTPS 무응답 현상
- [BE] 한국투자 Open API에서 access token을 발급받지 못하는 문제
- [BE] 한국투자 Open API와 웹소켓 연결이 되지 않던 문제
- [BE] 한국투자 Open API 웹소켓 연결이 중단되는 문제
- [BE] 같은 주식 주문이 동시에 여러 번 체결되는 문제
- [BE] 한국투자 Open API Websocket 세션을 두 개에서 한 개로 변경하기
- [BE] Nginx 로드 밸런싱 중 Socket bad Request 발생하는 현상
- [BE] 매수/매도 체결 로직에 의해 redis pub/sub이 정상적으로 동작하지 않는 문제