使用Lettuce+Spring Data Redis跨分片查询及替代方案咨询

一、Lettuce跨分片规避CROSSSLOT错误的方案 #

Redis集群默认按键的哈希值分配哈希槽，跨槽执行批量命令（如SET的union）会触发CROSSSLOT错误，Lettuce本身不会自动处理跨槽命令，但可以通过以下两种方式解决：

1. 哈希标签强制键归到同一槽 #

修改键的命名规则，给所有需要参与union操作的键添加相同的哈希标签，格式为{固定标签}键名，比如把set:1、set:2改成{common-slot}:set:1、{common-slot}:set:2。Redis会根据标签内的内容计算哈希槽，这样所有带同一标签的键会被分配到同一个槽，就能正常执行union命令。

注意：如果参与的键数量过大，会导致单个哈希槽压力过高，需根据业务规模权衡使用。

2. 客户端侧手动分组执行再合并 #

通过Lettuce提供的SlotHash工具类，先将所有键按哈希槽分组，对每组内的键执行union操作，最后在客户端合并各组结果：

import io.lettuce.core.cluster.SlotHash;
import java.util.stream.Collectors;

// 假设ids是需要union的SET键集合
Map<Integer, List<String>> slotGroupedKeys = ids.stream()
        .collect(Collectors.groupingBy(key -> SlotHash.getSlot(key)));

Set<String> finalUnionResult = new HashSet<>();
for (List<String> slotKeys : slotGroupedKeys.values()) {
    Set<String> slotUnion = redisTemplate.opsForSet().union(slotKeys);
    finalUnionResult.addAll(slotUnion);
}

这种方式不需要修改键名，但会增加客户端的计算和网络请求次数，适合无法修改键名的场景。

二、CrudRepository的findAllById能否替代union操作？ #

不能，两者语义完全不同：

• redisTemplate.opsForSet().union(ids)是求多个SET类型键的元素并集，返回所有SET中去重后的元素集合。
• CrudRepository.findAllById(ids)是根据实体ID查询对应的Redis实体，前提是你的数据模型是用@RedisHash注解的实体类，查询结果是实体列表，和SET元素的并集逻辑无关。

只有当你的业务需求是获取指定ID的实体时，才适合用findAllById，它无法替代SET的union操作。

内容的提问来源于stack exchange，提问作者Sukh