Redis 통신 프로토콜 — RESP와 클라이언트-서버 통신

+OK\r\n

-ERR unknown command 'foobar'\r\n
-WRONGTYPE Operation against a key holding the wrong kind of value\r\n

:1000\r\n
:0\r\n

$6\r\nfoobar\r\n    // 6바이트 문자열 "foobar"
$0\r\n\r\n          // 빈 문자열
$-1\r\n             // NULL (키가 존재하지 않을 때)

*3\r\n               // 3개 원소의 배열
$3\r\nSET\r\n        // "SET"
$3\r\nkey\r\n        // "key"
$5\r\nvalue\r\n      // "value"

*3\r\n          // 3개 원소 배열
$3\r\n          // 첫 번째 원소: 3바이트
SET\r\n         // 명령어 이름
$5\r\n          // 두 번째 원소: 5바이트
mykey\r\n       // 키
$11\r\n         // 세 번째 원소: 11바이트
Hello World\r\n // 값

+OK\r\n         // Simple String으로 성공 응답

PING\r\n
SET key value\r\n
GET key\r\n

# telnet으로 직접 Redis에 명령 전송
$ telnet localhost 6379
PING
+PONG
SET greeting "hello"
+OK
GET greeting
$5
hello

*4\r\n
$4\r\nname\r\n
$5\r\nAlice\r\n
$3\r\nage\r\n
$2\r\n30\r\n

%2\r\n
$4\r\nname\r\n
$5\r\nAlice\r\n
$3\r\nage\r\n
$2\r\n30\r\n

# 연결 후 RESP3으로 전환
HELLO 3

# 응답 (RESP3 Map 형식)
%7
$6 server
$5 redis
$7 version
$5 7.2.4
...

[클라이언트 → 서버] 연속 전송:
*3\r\n$3\r\nSET\r\n$1\r\na\r\n$1\r\n1\r\n
*3\r\n$3\r\nSET\r\n$1\r\nb\r\n$1\r\n2\r\n
*2\r\n$3\r\nGET\r\n$1\r\na\r\n

[서버 → 클라이언트] 순서대로 응답:
+OK\r\n
+OK\r\n
$1\r\n1\r\n

# 주의: 너무 많은 명령어를 한 번에 파이프라이닝하면
# 서버의 출력 버퍼가 커질 수 있습니다
pipe = r.pipeline()
for i in range(1000000):  # 100만 개는 너무 많음
    pipe.set(f'key:{i}', i)
pipe.execute()

# 권장: 적절한 크기로 나누어 실행
BATCH_SIZE = 1000
pipe = r.pipeline()
for i in range(1000000):
    pipe.set(f'key:{i}', i)
    if (i + 1) % BATCH_SIZE == 0:
        pipe.execute()
        pipe = r.pipeline()

# 클라이언트당 최대 1GB (기본값, 변경 불가)
# CLIENT LIST에서 qbuf로 확인 가능
CLIENT LIST

# 출력 예시
id=5 addr=127.0.0.1:52345 ... qbuf=26 qbuf-free=32742 ...

# 설정 형식: client-output-buffer-limit <class> <hard> <soft> <seconds>
# 일반 클라이언트: 무제한 (기본)
client-output-buffer-limit normal 0 0 0

# Pub/Sub 클라이언트: 32MB 하드 리밋, 8MB가 60초 이상 지속되면 종료
client-output-buffer-limit pubsub 32mb 8mb 60

# 복제(replica) 클라이언트: 256MB 하드 리밋
client-output-buffer-limit replica 256mb 64mb 60

퍼블리셔 → Redis → [출력 버퍼 증가] → 느린 구독자
                    ↓
              버퍼 제한 초과
                    ↓
              연결 강제 종료

// Java Jedis 연결 풀 설정
JedisPoolConfig config = new JedisPoolConfig();
config.setMaxTotal(128);     // 최대 연결 수
config.setMaxIdle(64);       // 최대 유휴 연결
config.setMinIdle(16);       // 최소 유휴 연결
config.setTestOnBorrow(true); // 사용 전 연결 유효성 검사

JedisPool pool = new JedisPool(config, "localhost", 6379);

try (Jedis jedis = pool.getResource()) {
    jedis.set("key", "value");
}

# Python redis-py 연결 풀
import redis

pool = redis.ConnectionPool(
    host='localhost',
    port=6379,
    max_connections=50,
    decode_responses=True
)
r = redis.Redis(connection_pool=pool)

# 연결된 모든 클라이언트 조회
CLIENT LIST

# 특정 조건으로 필터링
CLIENT LIST TYPE normal  # 일반 클라이언트만
CLIENT LIST ID 5 10 15   # 특정 ID만

# 현재 연결 정보
CLIENT INFO

# 연결 이름 설정 (디버깅용)
CLIENT SETNAME "order-service-1"

# 느린 클라이언트 강제 종료
CLIENT KILL ID 123