# 普通模式：每条命令一次网络往返
for i in range(1000):
    r.set(f"key:{i}", i)

客户端 → 发送命令 → 服务端处理 → 返回结果 → 客户端

# Pipeline 模式：打包发送
pipe = r.pipeline()
for i in range(1000):
    pipe.set(f"key:{i}", i)
pipe.execute()  # 一次网络往返

普通模式：
客户端: [SET a 1]───→[SET b 2]───→[GET c]────→
服务端:      ←[OK]──    ←[OK]──    ←[3]──

Pipeline 模式：
客户端: [SET a 1][SET b 2][GET c]──────────────────────→
服务端:                              ←[OK][OK][3]───

import redis

r = redis.Redis(host='localhost', port=6379)

# 批量写入
pipe = r.pipeline()
pipe.set('name', 'Alice')
pipe.set('age', '30')
pipe.set('city', 'Beijing')
results = pipe.execute()
# results = [True, True, True]

# 批量读取
pipe = r.pipeline()
pipe.get('name')
pipe.get('age')
pipe.get('city')
results = pipe.execute()
# results = [b'Alice', b'30', b'Beijing']

Jedis jedis = new Jedis("localhost");
Pipeline pipeline = jedis.pipelined();

// 批量设置
for (int i = 0; i < 1000; i++) {
    pipeline.set("key:" + i, String.valueOf(i));
}
List<Object> results = pipeline.syncAndReturnAll();

# 使用 --pipe 模式
echo -e '*3\r\n$3\r\nSET\r\n$5\r\nkey1\r\n$5\r\nvalue\r\n' | redis-cli --pipe

# ❌ 错误：后续命令依赖前面命令的结果
pipe = r.pipeline()
pipe.set('counter', 0)
pipe.incr('counter')     # 没问题，INCER 不依赖 GET 结果

# ❌ 更典型的问题：无法实现"读-改-写"
pipe.get('balance')      # 需要这个结果来做判断
pipe.decrby('balance', amount)  # 但这里不确定余额是否足够
pipe.execute()

# Pipeline 中的命令执行是顺序的
# 但如果中间某条命令失败，其他命令仍然会执行
# Pipeline 不保证事务隔离

# 分批 Pipeline
for i in range(0, 100000, 1000):
    pipe = r.pipeline()
    for j in range(i, i + 1000):
        pipe.set(f"key:{j}", j)
    pipe.execute()

import time

# 普通模式
start = time.time()
for i in range(10000):
    r.set(f"seq:{i}", i)
print(f"普通模式: {time.time() - start:.2f}s")

# Pipeline 模式
start = time.time()
pipe = r.pipeline()
for i in range(10000):
    pipe.set(f"pipe:{i}", i)
pipe.execute()
print(f"Pipeline: {time.time() - start:.2f}s")

普通模式: 2.85s
Pipeline: 0.08s