spring-scalable-example

Application Level에서 대규모 트래픽 감당 예제

사용기술

• Spring Cloud Gateway
• Ribbon (Client Side LoadBalance)
• Spring WebFlux, Reactor
• RabbitMQ
• Redis
• Docker

실행 방법

$ git clone https://github.com/viviennes7/spring-scalable-example.git
$ cd spring-scalable-example
$ mvn clean install
$ docker-compose up

요구사항

• 대규모 트래픽 가정
• 제한된 수의 상품을 팜
• 실패했던 성공했던 구매에 시도한 사람의 기록을 남겨야함

주의 사항

• Race condition (제한된 개수만큼만 판매)
• 대용량 트래픽에 대응하고, 정보를 남겨야함

ex) 맥북프로 최상위 옵션을 100만원에 100대만 판매. 들어올 트래픽은 10만으로 짐작됨.

HTTP API

• Event 상품 구매

POST http://localhost:10000/service/events

• Event 상품 구매 내역 조회

GET http://localhost:10000/service/orders

핵심로직

public Mono<Boolean> apply(Long userId) {
    return this.reactiveValueOperations.get(EVENT_APPLY_KEY)
            .doOnNext(size -> this.rabbitTemplate.convertAndSend(MicroserviceApplication.EVENT_TOPIC, "foo.bar.baz", userId))
            .filter(this::isPurchase)
            .flatMap(s -> this.reactiveValueOperations.increment(EVENT_APPLY_KEY))
            .flatMap(s -> this.reactiveListOperations.leftPush(EVENT_APPLY_LIST, userId.toString()))
            .map(add -> true)
            .defaultIfEmpty(false);
}