如何用Jedis批量存储带相同附属信息的Redis字符串键

我来给你梳理下怎么高效实现这个批量存储的需求，不用再挨个遍历key重复存储啦！核心思路是利用Jedis的**Pipeline（管道）**来减少网络往返次数，把多个存储命令打包成一次请求发送给Redis，效率会提升很多，尤其当你的key列表很大的时候。

方案一：批量存储序列化后的对象 #

如果需要把整个Hello对象和每个key绑定，我们可以先把对象序列化成JSON字符串（这里用Jackson做序列化工具，你需要先引入Jackson的依赖），然后通过Pipeline批量设置每个key的值：

import redis.clients.jedis.Jedis;
import redis.clients.jedis.Pipeline;
import com.fasterxml.jackson.databind.ObjectMapper;
import java.util.List;

// 你的Hello类（确保有完整的getter/setter）
class Hello {
    private List<String> keys;
    private String name;
    private String age;
    
    // getter和setter方法
    public List<String> getKeys() { return keys; }
    public void setKeys(List<String> keys) { this.keys = keys; }
    public String getName() { return name; }
    public void setName(String name) { this.name = name; }
    public String getAge() { return age; }
    public void setAge(String age) { this.age = age; }
}

public class JedisBatchStoreExample {
    public static void main(String[] args) {
        // 初始化你的Hello实例（和你示例里的一样）
        List<String> keys = List.of("a", "b");
        Hello hello = new Hello();
        hello.setKeys(keys);
        hello.setName("Hi");
        hello.setAge("23");
        
        // 批量存储逻辑
        try (Jedis jedis = new Jedis("localhost", 6379)) {
            // 如果Redis有密码，需要添加这行：jedis.auth("your_redis_password");
            
            ObjectMapper objectMapper = new ObjectMapper();
            // 先把要存储的公共数据（name和age）封装成一个对象，去掉keys字段避免冗余
            Hello helloData = new Hello();
            helloData.setName(hello.getName());
            helloData.setAge(hello.getAge());
            String helloJson = objectMapper.writeValueAsString(helloData);
            
            // 创建Pipeline执行批量命令
            try (Pipeline pipeline = jedis.pipelined()) {
                for (String key : hello.getKeys()) {
                    pipeline.set(key, helloJson);
                }
                // 同步执行所有命令
                pipeline.sync();
                System.out.println("所有key已批量存储完成！");
            }
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
}

方案二：批量存储Hash结构（更灵活的字段存储） #

如果不需要存整个对象，只想单独存储name和age字段，推荐用Redis的Hash结构，每个key对应一个Hash，里面包含name和age两个field。同样用Pipeline批量操作：

import redis.clients.jedis.Jedis;
import redis.clients.jedis.Pipeline;
import java.util.List;

// 这里省略Hello类的定义，和上面一致

public class JedisBatchHashStoreExample {
    public static void main(String[] args) {
        List<String> keys = List.of("a", "b");
        Hello hello = new Hello();
        hello.setKeys(keys);
        hello.setName("Hi");
        hello.setAge("23");
        
        try (Jedis jedis = new Jedis("localhost", 6379)) {
            // 如果Redis有密码，添加jedis.auth("your_redis_password");
            
            try (Pipeline pipeline = jedis.pipelined()) {
                for (String key : hello.getKeys()) {
                    // 给每个key对应的Hash设置name和age字段
                    pipeline.hset(key, "name", hello.getName());
                    pipeline.hset(key, "age", hello.getAge());
                }
                pipeline.sync();
                System.out.println("批量Hash存储完成！");
            }
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
}

为什么用Pipeline？ #

之前你遍历逐个存储的方式，每个set或hset命令都要和Redis服务器做一次网络交互，当key数量多的时候，网络开销会很大。而Pipeline可以把所有命令打包成一次请求发送，Redis执行完后再一次性返回结果，能大幅提升批量操作的效率。

另外，记得用try-with-resources语法来自动关闭Jedis客户端和Pipeline，避免资源泄漏哦！

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