Redis pipeline 和 MGET 是否支持跨分片读取？

当使用 **Redis Cluster（分片模式）** 时，`pipeline` 和 `MGET` 在跨多个分片（shards）读取时有不同的行为。 ## **1. `MGET` 不能跨分片** ### **原因** - `MGET key1 key2 key3` **必须所有 key 在同一个分片**，否则会报错： ```shell (error) CROSSSLOT Keys in request don't hash to the same slot ``` - **Redis Cluster** 使用 **哈希槽（hash slots）** 来分片，每个 key 归属于一个槽位（0-16383）。 - **如果 `MGET` 的 keys 分布在不同分片，Redis 不支持跨分片查询**。 ### **解决方案** 如果想在 Redis Cluster 下批量读取多个 key，可以： 1. **使用 `MGET` 但确保所有 key 在同一分片** - 通过 `{}` **哈希标签** 让多个 key 绑定到同一槽： ```shell MSET {user}:1 name "Alice" {user}:2 name "Bob" MGET {user}:1 {user}:2 ``` - **哈希标签 `{}` 让 `user:1` 和 `user:2` 落在同一槽位**。 2. **改用 `pipeline` 代替 `MGET`** - **`pipeline` 允许跨分片执行多个命令**，只不过 Redis Cluster 仍然需要一次性向多个分片发送请求（但不会报 `CROSSSLOT` 错误）。 ## **2. `pipeline` 可以跨分片** ### **行为** - `pipeline` **可以跨多个分片执行**，但**每个 key 仍然会去不同的分片查询**，并 **不能保证原子性**。 - **Redis 只是在客户端批量发送请求，但仍然是多个分片独立处理请求**。 ### **示例** ```python import rediscluster # 连接到 Redis Cluster startup_nodes = [{"host": "127.0.0.1", "port": 6379}] rc = rediscluster.RedisCluster(startup_nodes=startup_nodes, decode_responses=True) # 使用 pipeline 读取多个 key（跨分片） pipe = rc.pipeline() pipe.get("user:1") pipe.get("order:123") # user:1 和 order:123 可能在不同分片 results = pipe.execute() print(results) # ['Alice', 'Order Data'] ``` ### **执行流程** 1. **客户端 pipeline 发送多个 `GET key` 请求** 2. **Redis Cluster 会解析 key 的槽位，并分别发送请求到对应分片** 3. **每个分片独立处理，并返回结果** 4. **客户端收到多个返回值，并按照请求顺序合并** ## **3. `MGET` vs `pipeline` 在 Redis Cluster 下的对比** | **对比项** | **MGET** | **pipeline** | |------------|------------|-----------| | **跨分片支持** | ❌ 不支持，必须在同一分片 | ✅ 支持，多个 key 可在不同分片 | | **网络交互** | 1 次请求，1 次响应 | N 次请求，N 次响应 | | **性能** | 高效（但受限于单分片） | 适合大规模查询 | | **适用场景** | 获取同一分片的多个 key | 获取不同分片的数据 | ## **4. 结论** - **如果 key 在同一个分片** 👉 **`MGET` 更快** - **如果 key 在多个分片** 👉 **只能用 `pipeline`** - **如果 Redis 需要跨分片查询**，**应用层需做分片查询合并**，例如： - 使用 **多个 `MGET`**，针对每个分片分别查询。 - **批量 `pipeline` 处理多个 key**，然后在应用层合并结果。 Redis **天然不支持跨分片的批量操作**，如果需要高效批量查询分片数据，推荐 **客户端自己做分片逻辑**。