[feat] gameStart 및 handlePlayerReady 레디스 분산락 기반 동시성 제어 적용

backend/build.gradle

@@ -29,6 +29,7 @@ dependencies {
 	implementation 'org.springframework.boot:spring-boot-starter-web'
 	implementation 'org.springframework.boot:spring-boot-starter-data-jpa'
 	implementation 'org.springframework.boot:spring-boot-starter-data-redis'
+	implementation 'org.redisson:redisson-spring-boot-starter:3.50.0'
 	implementation 'org.springframework.boot:spring-boot-starter-websocket'
 	implementation 'org.springframework.boot:spring-boot-starter-security'
 	implementation 'org.springframework.boot:spring-boot-starter-oauth2-client'

backend/src/main/java/io/f1/backend/domain/game/app/GameService.java

@@ -31,6 +31,7 @@
 import io.f1.backend.global.exception.CustomException;
 import io.f1.backend.global.exception.errorcode.GameErrorCode;
 import io.f1.backend.global.exception.errorcode.RoomErrorCode;
+import io.f1.backend.global.lock.DistributedLock;
 
 import lombok.RequiredArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
@@ -59,6 +60,7 @@ public class GameService {
     private final RoomRepository roomRepository;
     private final ApplicationEventPublisher eventPublisher;
 
+    @DistributedLock(prefix = "room", key = "#roomId", waitTime = 0)
     public void gameStart(Long roomId, UserPrincipal principal) {
 
         String destination = getDestination(roomId);
@@ -82,6 +84,9 @@ public void gameStart(Long roomId, UserPrincipal principal) {
 
         timerService.startTimer(room, START_DELAY);
 
+        PlayerListResponse playerListResponse = toPlayerListResponse(room);
+        log.info(playerListResponse.toString());
+
         messageSender.sendBroadcast(
                 destination, MessageType.GAME_START, toGameStartResponse(questions));
         messageSender.sendBroadcast(
@@ -190,6 +195,7 @@ public void gameEnd(Room room) {
                 destination, MessageType.ROOM_SETTING, toRoomSettingResponse(room));
     }
 
+    @DistributedLock(prefix = "room", key = "#roomId")
     public void handlePlayerReady(Long roomId, String sessionId) {
 
         Room room = findRoom(roomId);
@@ -218,9 +224,7 @@ public void changeGameSetting(
         broadcastGameSetting(room);
 
         RoomUpdatedEvent roomUpdatedEvent =
-                new RoomUpdatedEvent(
-                        room,
-                        quizService.getQuizWithQuestionsById(room.getGameSetting().getQuizId()));
+                new RoomUpdatedEvent(room, quizService.getQuizWithQuestionsById(room.getQuizId()));
 
         eventPublisher.publishEvent(roomUpdatedEvent);
     }
@@ -242,7 +246,7 @@ private void validateRoomStart(Room room, UserPrincipal principal) {
     // 라운드 수만큼 랜덤 Question 추출
     private List<Question> prepareQuestions(Room room, Quiz quiz) {
         Long quizId = quiz.getId();
-        Integer round = room.getGameSetting().getRound();
+        Integer round = room.getRound();
         return quizService.getRandomQuestionsWithoutAnswer(quizId, round);
     }
 

backend/src/main/java/io/f1/backend/global/config/RedissonConfig.java

@@ -0,0 +1,27 @@
+package io.f1.backend.global.config;
+
+import org.redisson.Redisson;
+import org.redisson.api.RedissonClient;
+import org.redisson.config.Config;
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+
+@Configuration
+public class RedissonConfig {
+
+    @Value("${spring.data.redis.host}")
+    private String redisHost;
+
+    @Value("${spring.data.redis.port}")
+    private int redisPort;
+
+    @Bean
+    public RedissonClient redissonClient() {
+        Config config = new Config();
+        final String address = "redis://%s:%d".formatted(redisHost, redisPort);
+
+        config.useSingleServer().setAddress(address);
+        return Redisson.create(config);
+    }
+}

backend/src/main/java/io/f1/backend/global/exception/errorcode/CommonErrorCode.java

@@ -12,7 +12,8 @@ public enum CommonErrorCode implements ErrorCode {
     INVALID_PAGINATION("E400006", HttpStatus.BAD_REQUEST, "page와 size는 1 이상의 정수여야 합니다."),
     INTERNAL_SERVER_ERROR(
             "E500001", HttpStatus.INTERNAL_SERVER_ERROR, "서버에러가 발생했습니다. 관리자에게 문의해주세요."),
-    INVALID_JSON_FORMAT("E400008", HttpStatus.BAD_REQUEST, "요청 형식이 올바르지 않습니다. JSON 문법을 확인해주세요.");
+    INVALID_JSON_FORMAT("E400008", HttpStatus.BAD_REQUEST, "요청 형식이 올바르지 않습니다. JSON 문법을 확인해주세요."),
+    LOCK_ACQUISITION_FAILED("E409003", HttpStatus.CONFLICT, "다른 요청이 작업 중입니다. 잠시 후 다시 시도해주세요.");
 
     private final String code;
 

backend/src/main/java/io/f1/backend/global/lock/CustomSpringELParser.java

@@ -0,0 +1,24 @@
+package io.f1.backend.global.lock;
+
+import org.springframework.expression.ExpressionParser;
+import org.springframework.expression.spel.standard.SpelExpressionParser;
+import org.springframework.expression.spel.support.StandardEvaluationContext;
+
+public class CustomSpringELParser {
+
+    private CustomSpringELParser() {}
+
+    public static Object getDynamicValue(
+            String[] parameterNames, Object[] args, String keyExpression) {
+
+        ExpressionParser parser = new SpelExpressionParser();
+
+        StandardEvaluationContext context = new StandardEvaluationContext();
+
+        for (int i = 0; i < parameterNames.length; i++) {
+            context.setVariable(parameterNames[i], args[i]);
+        }
+
+        return parser.parseExpression(keyExpression).getValue(context, Object.class);
+    }
+}

backend/src/main/java/io/f1/backend/global/lock/DistributedLock.java

@@ -0,0 +1,27 @@
+package io.f1.backend.global.lock;
+
+import java.lang.annotation.Documented;
+import java.lang.annotation.ElementType;
+import java.lang.annotation.Retention;
+import java.lang.annotation.RetentionPolicy;
+import java.lang.annotation.Target;
+import java.util.concurrent.TimeUnit;
+
+@Target(ElementType.METHOD)
+@Retention(RetentionPolicy.RUNTIME)
+@Documented
+public @interface DistributedLock {
+
+    String prefix();
+
+    String key();
+
+    // 시간단위를 초로 변경
+    TimeUnit timeUnit() default TimeUnit.SECONDS;
+
+    // 락 점유를 위한 대기 시간
+    long waitTime() default 5L;
+
+    // 락 점유 시간
+    long leaseTime() default 3L;
+}

backend/src/main/java/io/f1/backend/global/lock/DistributedLockAspect.java

@@ -0,0 +1,74 @@
+package io.f1.backend.global.lock;
+
+import io.f1.backend.global.exception.CustomException;
+import io.f1.backend.global.exception.errorcode.CommonErrorCode;
+
+import lombok.RequiredArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+
+import org.aspectj.lang.ProceedingJoinPoint;
+import org.aspectj.lang.annotation.Around;
+import org.aspectj.lang.annotation.Aspect;
+import org.aspectj.lang.reflect.MethodSignature;
+import org.redisson.api.RLock;
+import org.redisson.api.RedissonClient;
+import org.springframework.stereotype.Component;
+
+@Slf4j
+@Aspect
+@Component
+@RequiredArgsConstructor
+public class DistributedLockAspect {
+
+    private static final String LOCK_KEY_FORMAT = "lock:%s:{%s}";
+
+    private final RedissonClient redissonClient;
+
+    @Around("@annotation(distributedLock)")
+    public Object lock(ProceedingJoinPoint joinPoint, DistributedLock distributedLock)
+            throws Throwable {
+
+        String key = getLockKey(joinPoint, distributedLock);
+
+        RLock rlock = redissonClient.getLock(key);
+
+        boolean acquired = false;
+        try {
+            acquired =
+                    rlock.tryLock(
+                            distributedLock.waitTime(),
+                            distributedLock.leaseTime(),
+                            distributedLock.timeUnit());
+
+            if (!acquired) {
+                log.warn("[DistributedLock] Lock acquisition failed: {}", key);
+                throw new CustomException(CommonErrorCode.LOCK_ACQUISITION_FAILED);
+            }
+            log.info("[DistributedLock] Lock acquired: {}", key);
+
+            return joinPoint.proceed();
+        } catch (InterruptedException e) {
+            Thread.currentThread().interrupt();
+            throw e;
+        } finally {
+            if (acquired && rlock.isHeldByCurrentThread()) {
+                rlock.unlock();
+                log.info("[DistributedLock] Lock released: {}", key);
+            }
+        }
+    }
+
+    private String getLockKey(ProceedingJoinPoint joinPoint, DistributedLock lockAnnotation) {
+        MethodSignature signature = (MethodSignature) joinPoint.getSignature();
+
+        String keyExpr = lockAnnotation.key();
+        String prefix = lockAnnotation.prefix();
+
+        Object keyValueObj =
+                CustomSpringELParser.getDynamicValue(
+                        signature.getParameterNames(), joinPoint.getArgs(), keyExpr);
+        String keyValue = String.valueOf(keyValueObj);
+
+        return String.format(LOCK_KEY_FORMAT, prefix, keyValue);
+    }
+}

backend/src/test/java/io/f1/backend/domain/game/app/RoomServiceTests.java

@@ -56,9 +56,7 @@ class RoomServiceTests {
     void setUp() {
         MockitoAnnotations.openMocks(this); // @Mock 어노테이션이 붙은 필드들을 초기화합니다.
 
-        roomService =
-                new RoomService(
-                        timerService, quizService, roomRepository, eventPublisher, messageSender);
+        roomService = new RoomService(quizService, roomRepository, eventPublisher, messageSender);
 
         SecurityContextHolder.clearContext();
     }

backend/src/test/java/io/f1/backend/global/config/RedissonTestContainerConfig.java

@@ -0,0 +1,39 @@
+package io.f1.backend.global.config;
+
+import com.redis.testcontainers.RedisContainer;
+
+import org.redisson.Redisson;
+import org.redisson.api.RedissonClient;
+import org.redisson.config.Config;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+import org.testcontainers.junit.jupiter.Container;
+import org.testcontainers.junit.jupiter.Testcontainers;
+
+@Configuration
+@Testcontainers
+public class RedissonTestContainerConfig {
+
+    @Container
+    public static RedisContainer redisContainer =
+            new RedisContainer(
+                    RedisContainer.DEFAULT_IMAGE_NAME.withTag(RedisContainer.DEFAULT_TAG));
+
+    static {
+        redisContainer.start();
+    }
+
+    @Bean
+    public RedissonClient redissonClient() {
+        Config config = new Config();
+        String address =
+                String.format(
+                        "redis://%s:%d",
+                        RedissonTestContainerConfig.redisContainer.getHost(),
+                        RedissonTestContainerConfig.redisContainer.getFirstMappedPort());
+
+        config.useSingleServer().setAddress(address);
+
+        return Redisson.create(config);
+    }
+}