StandaloneConfiguration XREADGROUP BLOCK 검증 테스트 결과

테스트 일자: 2026-02-10 테스트 대상: Valkey 7.2.6 on Amazon ElastiCache (ap-northeast-2) 테스트 환경: 로컬 VPN 경유 개발 Redis (127.0.0.1:40198) 클라이언트: Lettuce 6.4.2 (Spring Boot 3.4.3 / Spring Data Redis) 커넥션 설정: RedisStandaloneConfiguration + LettucePoolingClientConfiguration + RESP2

1. 진단 테스트 결과

1.1 Stream 명령 호환성 (기본 진단)

1.2 XREADGROUP BLOCK 원인 심층 분석

단일 진단 테스트에서 다양한 방법으로 XREADGROUP BLOCK을 시도하여 근본 원인을 추적하였다.

1.3 근본 원인: Spring Data Redis 커넥션 라우팅

Spring Data Redis LettuceConnection은 내부적으로 두 종류의 커넥션 경로를 사용한다:

// LettuceConnection.getAsyncConnection() — execute()가 사용하는 경로
RedisClusterAsyncCommands getAsyncConnection() {
    if (isQueueing() || isPipelined()) {
        return getAsyncDedicatedConnection();  // 전용 커넥션
    }
    StatefulConnection sharedConnection = this.asyncSharedConnection;
    if (sharedConnection != null) {
        return sharedConnection.async();       // ← 공유 풀 커넥션 (우선 사용)
    }
    return getAsyncDedicatedConnection();
}

• connection.execute("XREADGROUP", ...) → getAsyncConnection() → 공유 풀 커넥션 → 성공
• streamOps.read(BLOCK) → Spring Data Redis blocking 감지 → 전용 커넥션 신규 생성 → 실패
• connection.nativeConnection → getAsyncDedicatedConnection() → 전용 커넥션 → 실패

공유 풀 커넥션은 @BeforeEach에서 XGROUP CREATE 실행 시 이미 생성되어 사용 중인 커넥션이고, 전용 커넥션은 blocking 명령을 위해 새로 생성되는 커넥션이다.

1.4 배제된 가설

결론: ElastiCache Valkey 환경에서 새로 생성된 커넥션의 XREADGROUP BLOCK이 거부된다. 기존에 이미 사용 중인 공유 풀 커넥션에서는 connection.execute()를 통해 XREADGROUP BLOCK이 정상 동작한다.

2. Blocking polling 메시지 수신 (시나리오 2)

pollTimeout(Duration.ofMillis(2000)) → 내부적으로 XREADGROUP BLOCK 2000 실행

XREADGROUP BLOCK이 실패하므로 StreamMessageListenerContainer가 메시지를 수신하지 못한다. Container는 에러를 로깅하며 polling을 반복하지만, 매 시도마다 동일한 에러가 발생한다.

3. 다른 Redis 명령 응답시간 (시나리오 3)

pollTimeout(Duration.ofMillis(2000)) blocking polling 중 SET+GET 응답시간:

참고: BLOCK이 실패하므로 실제 BLOCK 대기가 발생하지 않아 응답시간이 양호하다. 이 수치는 “BLOCK이 정상 동작할 때의 성능”이 아니라 “BLOCK 실패 후 Pool에서 다른 커넥션을 사용한 성능”이다.

4. 다중 Subscription 테스트 결과 (시나리오 4)

Container 1개 + Subscription N개, pollTimeout=2000ms (BLOCK 모드), 메시지 100건 발행

관찰:

• 모든 Subscription 수에서 메시지 수신 0건 (BLOCK 실패)
• SET+GET 응답시간은 Subscription 수와 무관하게 64~70ms로 안정적
• 멀티플렉싱 non-blocking 테스트(1개=107ms → 32개=704ms)와 비교하면 커넥션 풀 효과가 확인됨

멀티플렉싱 non-blocking vs Standalone Pool 응답시간 비교

커넥션 풀을 사용하면 Subscription 수가 증가해도 다른 Redis 명령 응답시간에 영향이 없다. 이는 BLOCK이 정상 동작하더라도 동일하게 적용되는 커넥션 풀의 장점이다.

5. 결론

XREADGROUP BLOCK 실패 원인 확정

XREADGROUP BLOCK 실패의 근본 원인은:

1. Spring Data Redis가 blocking 명령 감지 시 전용(dedicated) 커넥션을 신규 생성
2. ElastiCache Valkey 환경에서 신규 커넥션의 XREADGROUP BLOCK이 거부됨
3. 기존에 사용 중인 공유 풀 커넥션에서는 connection.execute()를 통해 정상 동작

CLIENT SETINFO, 커넥션 구성 방식(StaticMasterReplica vs Standalone), 워밍업 모두 원인이 아니다.

커넥션 풀 효과는 확인됨

• 32개 Subscription에서도 SET+GET 64ms (멀티플렉싱 non-blocking 704ms 대비 11배 개선)
• Subscription 수 증가에 따른 응답시간 저하 없음

테스트 시나리오별 판정

권장 사항

1. non-blocking polling (pollTimeout=Duration.ZERO) + 커넥션 풀: BLOCK을 사용하지 않으므로 문제 회피. 커넥션 풀로 멀티플렉싱 성능 이슈 해소. 단, tight loop으로 인한 CPU/네트워크 부하 존재.
2. 커스텀 poll loop 구현: non-blocking polling + Thread.sleep 간격으로 tight loop 완화. StreamMessageListenerContainer의 pollTimeout은 내부적으로 XREADGROUP BLOCK 또는 XREADGROUP non-block + sleep이므로, 커스텀 구현이 필요할 수 있음.
3. connection.execute() 기반 BLOCK polling: 공유 풀 커넥션 경로(getAsyncConnection())로 XREADGROUP BLOCK이 동작하는 것이 확인됨. StreamMessageListenerContainer를 커스텀하여 이 경로를 사용하면 BLOCK polling 가능. 단, Spring Data Redis 내부 API 의존으로 유지보수 부담.
4. Lettuce / ElastiCache 호환성 패치 대기: Lettuce ↔ ElastiCache Valkey 간 신규 커넥션 XREADGROUP BLOCK 호환성 이슈가 해결될 때까지 non-blocking polling 사용.

6. 테스트 코드 위치

src/test/kotlin/.../campaign/infrastructure/redis/stream/
├── StandaloneConnectionTestConfig.kt   ← @TestConfiguration (Standalone + Pool + noSetInfoClient)
└── StandaloneBlockTest.kt              ← BLOCK 검증 (진단 + 4개 시나리오)

상세 코드는 Standalone 테스트 계획 참고.

7. 재현 방법

# 로컬 VPN으로 개발 Redis 연결 후
./gradlew test --tests "*StandaloneBlockTest" --info

8. 참고 자료

• 멀티플렉싱 단일 커넥션 테스트 결과 — StaticMasterReplicaConfiguration에서의 동일 에러 확인
• Lettuce GitHub Issue #2817 — CLIENT SETINFO 핸드셰이크 이슈 (fire-and-forget 처리됨)
• AWS ElastiCache Supported Commands — XREADGROUP은 공식 지원 명령
• AWS ElastiCache Lettuce Client Configuration — ElastiCache 환경 Lettuce 설정 가이드
• Spring Data Redis LettuceConnection 소스 — getAsyncConnection() vs getAsyncDedicatedConnection() 커넥션 라우팅 로직