refactor: 게임 엔진 서비스의 Busy Waiting 문제 개선 #83
Conversation
- Blocking Pop 연산을 활용해서 데이터가 들어올 때까지 대기 - 기본적으로 1초 동안 대기하고, 없으면 넘어갑니다 - 애플리케이션 로직상 계속해서 Blocking으로 대기하고 있으면, 퀴즈 한문제당 대시시간을 지났는지 아닌지를 판단할 수 없기 때문에, 1초마다 Qeueu를 확인하도록 했습니다. - 대기시간 1초를 지정해줄 때 infrastructure에 매직넘버로 적어주었는데, 서비스 계층에서 값을 전달해줄 수 있게 개선해보면 좋을 것 같습니다.
| @@ -23,7 +23,7 @@ class QueueRepositoryAdapter( | |||
|
|
|||
| override fun poll(roomId: Long, quizId: Long): AnswerResult? { | |||
| val key = "roomId : " + roomId.toString() + ", " + "quizId : " + quizId.toString() | |||
There was a problem hiding this comment.
만약 key가 여러 곳에서 쓰인다면 분리해보는 것도 좋을 것 같습니다.😀😀
There was a problem hiding this comment.
맞아요 레디스에서 다양한 키를 사용할 수 있고, 키 명명 규칙도 존재하기 때문에 별도의 파일에서 관리해주면 좋을 것 같습니다!!
There was a problem hiding this comment.
좋습니다! 이렇게 이슈가 늘어나는 거죠! ㅎㅎ 여기저기 쓰이면서 명명 규칙이 혼재해서 사용될 수 있기 때문에 분리해서 관리하는 게 좋을 것 같습니다.
| @@ -23,7 +23,7 @@ class QueueRepositoryAdapter( | |||
|
|
|||
| override fun poll(roomId: Long, quizId: Long): AnswerResult? { | |||
| val key = "roomId : " + roomId.toString() + ", " + "quizId : " + quizId.toString() | |||
| return redisQueueRepository.poll(key)?.let { | |||
| return redisQueueRepository.poll(key, 1)?.let { | |||
There was a problem hiding this comment.
이 부분이 1초를 대기하고 poll한다는 의미일까요?🤗🤗
There was a problem hiding this comment.
1초동안 블럭킹으로 대기를하고, 없으면 null을 반환하도록 했습니다!
무한으로 blocking 해버리면 대기시간 10초를 카운트해서 다음 문제로 넘어가야하는데 그부분에서 문제가 생길 거같아서 일단 1초로 지정했습니다
이부분 한번 같이 이야기해보면 좋을거같아요!
There was a problem hiding this comment.
네네 이해했습니다. 그리고 직접 게임 해보니까 10초가 참 짧게 느껴졌습니다. 대기시간 10초를 없애는 것도 같이 고려해봐도 좋을 것 같아요😀😀
| @@ -12,8 +13,8 @@ class RedisQueueRepository( | |||
| return redisTemplate.opsForList().rightPush(key, value) | |||
| } | |||
|
|
|||
| fun poll(key: String): String? { | |||
| return redisTemplate.opsForList().leftPop(key) | |||
| fun poll(key: String, timeout: Long = 60, timeUnit: TimeUnit = TimeUnit.SECONDS): String? { | |||
There was a problem hiding this comment.
timeout, timeunit이 어떤 차이가 있을까요? 🤗🤗
There was a problem hiding this comment.
timeout은 몇초동안 blocking을 할지 지정하는 파라미터이고, TimeUnit은 timout에 적어준 값의 기준값을 의미합니다.
예를들어 위의 코드에서 SECONDS로 설정되어있기 때문에, timout값이 10이라면 10초로 설정되는 것입니다!! 😀😀
There was a problem hiding this comment.
친절하게 설명해주셔서 감사해요! 이해가 쏙쏙!! 되었습니다!
| private val redis: GenericContainer<*> = GenericContainer(DockerImageName.parse("redis:latest")) | ||
| .withExposedPorts(6379) | ||
| .withReuse(true) |
There was a problem hiding this comment.
여기서 GenericContainer는 어떤 역할을 하는지 여쭤봐도 될까요?😆😆
There was a problem hiding this comment.
해당 구문은 컨테이너를 활용하기 위해 사용하였는데요, 특정 버전의 redis 이미지를 가져오고 컨테이너화 시킬 때 사용되는 클래스입니다! 😀😀
There was a problem hiding this comment.
컨테이너화... 오 좋은 구문이 많네요! 이렇게 또 배워갑니다!😀😀
| gameAnswerQueueService.add(answerResult) | ||
| } | ||
| } catch (e: Exception) { | ||
| println("Error: ${e.message}") |
There was a problem hiding this comment.
편의를 위해서 print문을 쓰신 걸까요? 그렇다면 남겨두는 것도 좋을 것 같습니다. 😁😁
There was a problem hiding this comment.
넵 편의를 위해서 사용하였는데, 혹시 나중에 성능적으로 문제가 될 것 같으면 로그를 찍는 방식으로 수정해봐도 좋을 것 같아요!!
There was a problem hiding this comment.
네네 알겠습니다. 나중에 print문이 있는 파트를 다 찾아서 로그로 바꿔봐도 좋을 것 같아요!
#️⃣ 관련 이슈
📝 작업한 내용
💬 논의하고 싶은 내용