[1주차] 영화 서비스 초기 구성 및 상영 중인 영화 조회 API 개발

.gitignore

@@ -0,0 +1,9 @@
+# Spring Boot
+*.log
+*.class
+
+# Gradle
+.gradle/
+
+# IntelliJ IDEA
+.idea/

README.md

@@ -1,3 +1,78 @@
-## [본 과정] 이커머스 핵심 프로세스 구현
-[단기 스킬업 Redis 교육 과정](https://hh-skillup.oopy.io/) 을 통해 상품 조회 및 주문 과정을 구현하며 현업에서 발생하는 문제를 Redis의 핵심 기술을 통해 해결합니다.
-> Indexing, Caching을 통한 성능 개선 / 단계별 락 구현을 통한 동시성 이슈 해결 (낙관적/비관적 락, 분산락 등)
+# [본 과정] 이커머스 핵심 프로세스 구현
+- 분산 캐시를 적용한 영화 조회 API 구현
+- 분산 락을 적용한 영화 자리 예매 API 구현
+- 분산 Rate Limit을 적용한 API 요청 속도 및 횟수 제어 구현
+
+## How to use
+
+```bash
+docker compose up -d
+```
+```bash
+curl -X GET http://localhost:8080/api/v1/movies
+```
+
+## Multi Module
+
+### 1-1. movie-api
+> 영화 도메인 presentation 담당합니다.
+
+### 1-2. booking-api
+> 예약 도메인 presentation 담당합니다.
+
+### 2. application
+> Use Case 생성을 담당합니다.
+
+### 3. infrastructure
+> DB 연결과 Entity 관리를 담당합니다.
+
+### 4. domain
+> 도메인 로직을 포함합니다.
+
+## Architecture
+> 클린 아키텍처를 지향합니다.
+
+![arc](etc/readme/arc3.png)
+
+## Table Design
+![erd_db](etc/readme/erd2.png)
+
+## 성능 테스트
+### 캐싱할 데이터
+
+> API 응답을 캐싱하였습니다.
+
+```json
+// 응답 예시
+[
+  {
+    "id": 0,
+    "title": "나 홀로 집에",
+    "description": "...",
+    "rating": "전체관람가",
+    "genre": "코미디",
+    "thumbnail": "https://...",
+    "runningTime": 103,
+    "releaseDate": "1991-07-06",
+    "theaters": ["강남점", "안양점"],
+    "showtimes": ["08:00 ~ 09:45", "10:00 ~ 11:45"]
+  }
+]
+```
+
+### 분산락
+> Lease Time 길게 잡을수록 한 스레드가 lock을 오래 잡고 있어, 동시성 성능 테스트할때 fail 요청률이 90% 이상 나왔습니다.
+> 
+> Wait Time 경우 좌석 예매 특성상 오래 기다린다고 예약이 되는건 아니라 Lease Time보다 낮게 잡았습니다.
+- Lease Time - 2초 
+- Wait Time - 1초
+
+### 보고서
+- [캐싱 성능 테스트 보고서](https://gusty-football-62b.notion.site/17f81b29f03680718163fe0b7798383e)
+- [분산락 테스트 보고서](https://gusty-football-62b.notion.site/18781b29f03680049de7db34240a6733)
+
+### jacoco 리포트
+
+| movie-api                  | booking-api | application                | infrastructure             | domain                     |
+|----------------------------| ----------- |----------------------------|----------------------------|----------------------------|
+ | ![j_m](etc/readme/j_m.png) | ![j_b](etc/readme/j_b.png) | ![j_a](etc/readme/j_a.png) | ![j_i](etc/readme/j_i.png) | ![j_d](etc/readme/j_d.png) |

application/.gitignore

@@ -0,0 +1,36 @@
+../.gradle
+build/
+!gradle/wrapper/gradle-wrapper.jar
+!**/src/main/**/build/
+!**/src/test/**/build/
+
+### STS ###
+.apt_generated
+.classpath
+.factorypath
+.project
+.settings
+.springBeans
+.sts4-cache
+bin/
+!**/src/main/**/bin/
+!**/src/test/**/bin/
+
+### IntelliJ IDEA ###
+.idea
+*.iws
+*.iml
+*.ipr
+out/
+!**/src/main/**/out/
+!**/src/test/**/out/
+
+### NetBeans ###
+/nbproject/private/
+/nbbuild/
+/dist/
+/nbdist/
+/.nb-gradle/
+
+### VS Code ###
+.vscode/

application/build.gradle

@@ -0,0 +1,22 @@
+dependencies {
+    implementation project(':domain')
+
+    testImplementation project(':infrastructure')
+}
+
+bootJar {
+    enabled = false
+}
+
+test {
+    useJUnitPlatform()
+    finalizedBy jacocoTestReport
+}
+
+jacocoTestReport {
+    dependsOn test
+
+    reports {
+        html.required = true
+    }
+}

application/src/main/java/com/example/app/booking/dto/CreateBookingCommand.java

@@ -0,0 +1,49 @@
+package com.example.app.booking.dto;
+
+import com.example.app.booking.domain.Booking;
+import com.example.app.movie.type.TheaterSeat;
+import lombok.Builder;
+
+import java.time.LocalDate;
+import java.util.Set;
+
+@Builder
+public record CreateBookingCommand(
+        Long userId,
+        Long movieId,
+        Long showtimeId,
+        Long theaterId,
+        LocalDate bookingDate,
+        Set<TheaterSeat> seats
+){
+    public SearchSeatCommand toSearchSeatCommand() {
+        return SearchSeatCommand.builder()
+                .movieId(movieId)
+                .showtimeId(showtimeId)
+                .theaterId(theaterId)
+                .bookingDate(bookingDate)
+                .seats(seats)
+                .build();
+    }
+
+    public SearchBookingCommand toSearchBookingCommand() {
+        return SearchBookingCommand.builder()
+                .userId(userId)
+                .movieId(movieId)
+                .showtimeId(showtimeId)
+                .theaterId(theaterId)
+                .bookingDate(bookingDate)
+                .build();
+    }
+
+    public Booking toBooking() {
+        return Booking.builder()
+                .userId(userId)
+                .movieId(movieId)
+                .showtimeId(showtimeId)
+                .theaterId(theaterId)
+                .bookingDate(bookingDate)
+                .totalSeats(seats.size())
+                .build();
+    }
+}

application/src/main/java/com/example/app/booking/dto/SearchBookingCommand.java

@@ -0,0 +1,15 @@
+package com.example.app.booking.dto;
+
+import lombok.Builder;
+
+import java.time.LocalDate;
+
+@Builder
+public record SearchBookingCommand(
+        Long userId,
+        Long movieId,
+        Long showtimeId,
+        Long theaterId,
+        LocalDate bookingDate
+){
+}

application/src/main/java/com/example/app/booking/dto/SearchSeatCommand.java

@@ -0,0 +1,18 @@
+package com.example.app.booking.dto;
+
+import com.example.app.movie.type.TheaterSeat;
+import lombok.Builder;
+
+import java.time.LocalDate;
+import java.util.Set;
+
+@Builder
+public record SearchSeatCommand(
+        Long bookingId,
+        Long movieId,
+        Long showtimeId,
+        Long theaterId,
+        LocalDate bookingDate,
+        Set<TheaterSeat> seats
+) {
+}

application/src/main/java/com/example/app/booking/port/CreateBookingPort.java

@@ -0,0 +1,8 @@
+package com.example.app.booking.port;
+
+import com.example.app.booking.domain.Booking;
+import com.example.app.booking.dto.CreateBookingCommand;
+
+public interface CreateBookingPort {
+    Booking saveBooking(CreateBookingCommand createBookingCommand);
+}

application/src/main/java/com/example/app/booking/port/LoadBookingPort.java

@@ -0,0 +1,10 @@
+package com.example.app.booking.port;
+
+import com.example.app.booking.domain.Booking;
+import com.example.app.booking.dto.SearchBookingCommand;
+
+import java.util.List;
+
+public interface LoadBookingPort {
+    List<Booking> loadAllBookings(SearchBookingCommand searchBookingCommand);
+}

application/src/main/java/com/example/app/booking/port/LoadSeatPort.java

@@ -0,0 +1,13 @@
+package com.example.app.booking.port;
+
+import com.example.app.booking.domain.Seat;
+import com.example.app.booking.dto.SearchSeatCommand;
+
+import java.util.List;
+
+public interface LoadSeatPort {
+
+    List<Seat> loadAllSeats(SearchSeatCommand searchSeatCommand);
+
+    List<Seat> loadAllSeatsByBookingIds(List<Long> bookingIds);
+}

application/src/main/java/com/example/app/booking/port/UpdateSeatPort.java

@@ -0,0 +1,10 @@
+package com.example.app.booking.port;
+
+import com.example.app.booking.domain.Seat;
+
+import java.util.List;
+
+public interface UpdateSeatPort {
+
+    List<Seat> updateAllSeats(List<Long> seatIds, Long bookingId);
+}

application/src/main/java/com/example/app/booking/service/CreateBookingService.java

@@ -0,0 +1,90 @@
+package com.example.app.booking.service;
+
+import com.example.app.booking.domain.Booking;
+import com.example.app.booking.domain.Seat;
+import com.example.app.booking.dto.CreateBookingCommand;
+import com.example.app.booking.port.CreateBookingPort;
+import com.example.app.booking.port.LoadBookingPort;
+import com.example.app.booking.port.LoadSeatPort;
+import com.example.app.booking.port.UpdateSeatPort;
+import com.example.app.common.exception.APIException;
+import com.example.app.common.function.DistributedLockService;
+import com.example.app.movie.type.TheaterSeat;
+import com.example.app.booking.usecase.CreateBookingUseCase;
+import org.springframework.transaction.annotation.Transactional;
+import lombok.RequiredArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.stereotype.Service;
+
+import static com.example.app.booking.exception.BookingErrorMessage.*;
+
+@Slf4j
+@Service
+@RequiredArgsConstructor
+public class CreateBookingService implements CreateBookingUseCase {
+
+    private final Integer MAX_SEATS = 5;
+
+    private final LoadSeatPort loadSeatPort;
+    private final UpdateSeatPort updateSeatPort;
+    private final LoadBookingPort loadBookingPort;
+    private final CreateBookingPort createBookingPort;
+
+    private final DistributedLockService distributedLockService;
+
+    @Override
+    @Transactional
+    public Booking createBooking(String lockKey, CreateBookingCommand createBookingCommand) {
+        // 유저 확인
+        checkValidUser(createBookingCommand.userId());
+
+        // 연속된 row 체크
+        TheaterSeat.checkSeatsInSequence(createBookingCommand.seats());
+
+        // 기존 예약 조회
+        var existingBookingIds = loadBookingPort.loadAllBookings(createBookingCommand.toSearchBookingCommand())
+                .stream()
+                .map(Booking::id)
+                .toList();
+
+        // 기존 예약의 자리 조회
+        var existingSeats = loadSeatPort.loadAllSeatsByBookingIds(existingBookingIds);
+
+        // 요청한 자리 + 이미 예약한 자리 = 5개 넘는지 체크
+        checkLimitMaxSeats(createBookingCommand.seats().size() + existingSeats.size());
+
+        // booking 생성
+        var booking = createBookingPort.saveBooking(createBookingCommand);
+
+        return distributedLockService.executeWithLockAndReturn(() -> {
+            var requestSeats = loadSeatPort.loadAllSeats(createBookingCommand.toSearchSeatCommand());
+
+            // 요청한 자리 예약 가능 여부 체크
+            Seat.checkSeatsAvailable(requestSeats);
+
+            // 요청한 자리들 업데이트
+            var requestSeatIds = requestSeats.stream().map(Seat::id).toList();
+            updateSeatPort.updateAllSeats(requestSeatIds, booking.id());
+
+            return booking;
+        }, lockKey, 1L, 3L);
+    }
+
+    private void checkLimitMaxSeats(final int totalSeat) {
+        if (totalSeat > MAX_SEATS) {
+            throw new APIException(OVER_MAX_LIMIT_SEATS);
+        }
+    }
+
+    private void checkValidUser(final long userId) {
+        log.info(">>>>>> Checking userId : {}", userId);
+        /* pseudo code
+        * try {
+        *   var user = userApi.getUser(userId);
+        *   if (user == null) { throw new APIException(NOT_VALID_USER); }
+        * } catch (Exception e) {
+        *   throw new APIException(SERVICE_NETWORK_ERROR);
+        * }
+        * */
+    }
+}

application/src/main/java/com/example/app/booking/service/SendMessageService.java

@@ -0,0 +1,16 @@
+package com.example.app.booking.service;
+
+import com.example.app.booking.usecase.SendMessageUseCase;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.stereotype.Service;
+
+@Slf4j
+@Service
+public class SendMessageService implements SendMessageUseCase {
+
+    public void sendMessage(String message) throws InterruptedException {
+        log.info(">>>>> Sending message: {}", message);
+        Thread.sleep(500);
+        log.info(">>>>> Sent");
+    }
+}