클라이언트 사이드 캐싱 — Tracking과 Invalidation

1. 클라이언트가 CLIENT TRACKING ON 실행
2. 클라이언트가 GET key1 실행 → 서버가 "이 클라이언트가 key1을 읽었다" 기록
3. 클라이언트가 key1의 값을 로컬에 캐시
4. 누군가 key1을 변경 (SET key1 newvalue)
5. 서버가 클라이언트에게 무효화(invalidation) 메시지 전송
6. 클라이언트가 로컬 캐시에서 key1 삭제
7. 다음 조회 시 Redis에서 새 값을 가져옴

# RESP3으로 전환
127.0.0.1:6379> HELLO 3

# 추적 활성화
127.0.0.1:6379> CLIENT TRACKING ON

# 데이터 읽기 → 서버가 이 키를 추적 목록에 추가
127.0.0.1:6379> GET user:1001
"Alice"

# 다른 클라이언트가 key를 변경하면
# 이 연결에 push 메시지가 옴:
# > 1) "invalidate"
# > 2) 1) "user:1001"

# 연결 1: 무효화 메시지를 받을 Pub/Sub 연결
127.0.0.1:6379> SUBSCRIBE __redis__:invalidate
# 이 연결의 CLIENT ID 확인
# (다른 연결에서 CLIENT ID로 확인)

# 연결 2: 데이터 연결
127.0.0.1:6379> CLIENT TRACKING ON REDIRECT 42
# 42는 연결 1의 CLIENT ID

127.0.0.1:6379> GET user:1001
"Alice"

# user:1001이 변경되면 연결 1에서:
# 1) "message"
# 2) "__redis__:invalidate"
# 3) 1) "user:1001"

# user: 프리픽스로 시작하는 모든 키 변경을 추적
127.0.0.1:6379> CLIENT TRACKING ON BCAST PREFIX user: PREFIX session:

# 기본 모드: 서버가 Invalidation Table 유지
# - 클라이언트 수 × 추적 키 수만큼 메모리 사용
# - 기본 최대 추적 키 수: 클라이언트당 200만 개
127.0.0.1:6379> CONFIG SET tracking-table-max-keys 2000000

# 브로드캐스트 모드: 프리픽스만 저장하므로 서버 메모리 부담 적음
# 하지만 클라이언트에 불필요한 무효화 메시지가 많아질 수 있음

# OPTIN 모드 활성화
127.0.0.1:6379> CLIENT TRACKING ON OPTIN

# 일반 GET — 추적 안 됨
127.0.0.1:6379> GET user:1001

# 추적 지정 후 GET — 이 키만 추적
127.0.0.1:6379> CLIENT CACHING YES
127.0.0.1:6379> GET user:1001
# 이제 user:1001이 변경되면 무효화 메시지를 받음

# OPTOUT 모드 활성화
127.0.0.1:6379> CLIENT TRACKING ON OPTOUT

# 모든 GET이 추적됨
127.0.0.1:6379> GET user:1001    # 추적됨
127.0.0.1:6379> GET user:1002    # 추적됨

# 특정 키를 추적에서 제외
127.0.0.1:6379> CLIENT CACHING NO
127.0.0.1:6379> GET temp:data    # 추적 안 됨

// Lettuce 6.x — RESP3 + 클라이언트 사이드 캐싱
RedisClient client = RedisClient.create("redis://localhost:6379");

// 로컬 캐시 맵
ConcurrentHashMap<String, String> localCache = new ConcurrentHashMap<>();

// 트래킹 활성화 및 무효화 리스너 등록
StatefulRedisConnection<String, String> connection = client.connect();
connection.addListener(message -> {
    if (message instanceof PushMessage) {
        PushMessage push = (PushMessage) message;
        if ("invalidate".equals(push.getType())) {
            List<Object> content = push.getContent();
            // 무효화된 키들을 로컬 캐시에서 제거
            List<String> keys = (List<String>) content.get(1);
            keys.forEach(localCache::remove);
        }
    }
});

RedisCommands<String, String> commands = connection.sync();
commands.clientTracking(TrackingArgs.Builder.enabled());

// 조회 시 로컬 캐시 우선
public String get(String key) {
    String cached = localCache.get(key);
    if (cached != null) return cached;

    String value = commands.get(key);
    if (value != null) {
        localCache.put(key, value);
    }
    return value;
}

@Configuration
public class RedisCachingConfig {

    @Bean
    public LettuceClientConfigurationBuilderCustomizer clientCacheCustomizer() {
        return builder -> builder
            .clientOptions(ClientOptions.builder()
                .protocolVersion(ProtocolVersion.RESP3)
                .build());
    }
}

// Caffeine 캐시로 로컬 캐시 구현
Cache<String, String> localCache = Caffeine.newBuilder()
    .maximumSize(100_000)
    .expireAfterWrite(Duration.ofSeconds(60))  // 최대 60초 — 무효화를 놓쳐도 60초 후 만료
    .build();

connection.addListener(message -> {
    if (message instanceof ConnectionEvent.Disconnected) {
        // 연결이 끊기면 로컬 캐시 전체 초기화
        localCache.invalidateAll();
    }
});