Spring Data Redis Hash 结构操作指南

四、实战案例：用户资料管理

场景：存储和更新用户基本信息

1. 定义实体类（仅用于业务层）

public class User { 
    private String id; 
    private String name; 
    private String email; 
    private Integer age; 
    // getter/setter...
}

2. Hash 操作工具类

@Component
public class UserRedisService {
    @Autowired
    private StringRedisTemplate redisTemplate;
    
    private static final String USER_HASH_PREFIX = "user:";

    // 保存用户（全量覆盖）
    public void saveUser(User user) {
        String key = USER_HASH_PREFIX + user.getId();
        Map<String, String> userMap = new HashMap<>();
        userMap.put("name", user.getName());
        userMap.put("email", user.getEmail());
        userMap.put("age", String.valueOf(user.getAge()));
        redisTemplate.opsForHash().putAll(key, userMap);
        // 设置过期时间（可选）
        redisTemplate.expire(key, 2, TimeUnit.HOURS);
    }

    // 更新单个字段（如修改邮箱）
    public void updateEmail(String userId, String newEmail) {
        redisTemplate.opsForHash().put(USER_HASH_PREFIX + userId, "email", newEmail);
    }

    // 获取用户完整信息
    public User getUser(String userId) {
        String key = USER_HASH_PREFIX + userId;
        Map<Object, Object> entries = redisTemplate.opsForHash().entries(key);
        if (entries.isEmpty()) {
            return null; // 缓存未命中
        }
        User user = new User();
        user.setId(userId);
        user.setName((String) entries.get("name"));
        user.setEmail((String) entries.get("email"));
        user.setAge(Integer.parseInt((String) entries.get("age")));
        return user;
    }

    // 获取单个字段（如只查用户名）
    public String getUserName(String userId) {
        return (String) redisTemplate.opsForHash().get(USER_HASH_PREFIX + userId, "name");
    }

    // 删除用户
    public void deleteUser(String userId) {
        redisTemplate.delete(USER_HASH_PREFIX + userId);
    }
}

✅ 优势体现：更新邮箱时，无需读取整个用户对象；查询用户名时，网络传输量最小；内存占用比多个 String Key 少 30%+（实测）

五、高级技巧：批量操作与管道

1. 批量获取多个用户的某个字段

// 获取多个用户的姓名
List<String> userIds = Arrays.asList("1001", "1002", "1003");
List<String> names = userIds.stream()
    .map(id -> (String) redisTemplate.opsForHash().get("user:" + id, "name"))
    .collect(Collectors.toList());

⚠️ 注意：这是多次网络请求，高并发下可能成为瓶颈。

2. 使用 Pipeline 优化批量操作（需 RedisTemplate）

@Autowired
private RedisTemplate<String, String> redisTemplate; // 注意类型

public List<String> getNamesInPipeline(List<String> userIds) {
    return redisTemplate.executePipelined((RedisCallback<String>) connection -> {
        for (String id : userIds) {
            connection.hGet(("user:" + id).getBytes(), "name".getBytes());
        }
        return null;
    });
}

🔥 性能提升：1000 次操作从 200ms 降至 10ms！

六、避坑指南：常见问题与解决方案

❌ 坑 1：Field 或 Value 出现乱码

原因：使用了默认的 RedisTemplate（JDK 序列化） 解决：始终使用 StringRedisTemplate 操作 Hash

❌ 坑 2：数字字段反序列化失败

// 错误：直接强转 Integer
Integer age = (Integer) redisTemplate.opsForHash().get("user:1001", "age"); // ClassCastException!

正确做法：存为 String，取时手动转换

❌ 坑 3：Hash 过大导致阻塞

风险：单个 Hash 超过 10,000 个字段，HGETALL 会阻塞 Redis 建议：单 Hash 字段数 ≤ 1000；超大对象拆分为多个 Hash（如 user:1001:base, user:1001:profile）

七、Hash 适用场景总结

八、结语

本文总结了 Spring Data Redis Hash 的核心用法与注意事项，希望对你的开发工作有所帮助。