-
Spring Webflux에서 R Socket을 다루는 예시 코드입니다.
R Socket을 통해 이벤트를 주고받을 때, 이 애플리케이션은 이벤트를 받아 처리하는 부분에 해당합니다. -
Client로부터 REST API 등의 호출을 받고, 내부적으로 이벤트를 발행하는 코드는 여기에 있습니다.
-
R Socket 패러다임에 맞게, 총 4개의 라우팅 메소드가 포함되어 있습니다.
- 요청-응답 :
items.saveRequestResponse
- 요청-스트림 :
items.getRequestStream
- 실행 후 망각:
items.saveWithoutResponse
- 채널 :
items.monitor
- 요청-응답 :
-
Netty 서버 자체는 9000번 포트에, Spring R Socket 포트는 7000번을 사용합니다.
- 이 프로젝트는 Spring Webflux로 작성되어 있으며, MongoDB를 함께 사용합니다.
따라서 실행되고 있고, 접근할 수 있는 MongoDB가 있어야 합니다.
가장 간단하게, 아래 명령어로 Docker에 Mongo Container를 띄우면 데모용으로는 충분합니다.
docker run -p 27017-27019:27017-27019 mongo