Command와 coroutine

호출 경로를 섞지 않는다

commands는 호출 thread를 block하는 sync API, asyncCommands는 RedisFuture, coroutinesCommands는 Lettuce의 experimental coroutine API를 반환합니다. servlet blocking 경계에서는 sync가 단순할 수 있지만, coroutine service에서는 async 또는 coroutine 경로를 끝까지 유지합니다.

val async = LettuceClients.asyncCommands(client)
val value = async.get("account:1").awaitSuspending()

val values = listOf(async.get("a"), async.get("b")).awaitAll()

awaitAll()은 입력 순서대로 결과를 돌려주고, 빈 입력은 빈 list입니다. 하나가 실패하면 부분 결과를 만들지 않고 원래 예외를 전파합니다.

cancellation은 fallback이 아니다

awaitSuspending()은 kotlinx.coroutines.future.await의 취소 전파 규칙을 따릅니다. loaded map의 suspend 구현도 CancellationException을 다시 던집니다. timeout이나 요청 취소를 Redis miss로 바꿔 DB loader를 호출하면 이미 취소된 작업이 뒤에서 계속됩니다.

command 지원 여부

RedisCommandSupports는 client와 command별로 COMMAND INFO 결과를 cache합니다. 확인용 임시 connection은 즉시 닫습니다. 실패는 지원하지 않는 것으로 반환하므로, 권한 부족과 실제 미지원이 같은 false로 보일 수 있음을 운영 log에서 구분합니다.

Source와 tests

다음은 Codec과 직렬화입니다.