Vert.x Redis客户端HSET传入Map报错：原因及批量模式解决方案

报错原因 #

Vert.x原生Redis客户端严格遵循Redis的HSET命令规范——HSET的字段值只接受简单类型（字符串、数字、布尔值等）。你传入的JsonObject属于嵌套/复杂结构（报错里的"Graph objects"就是指这类非简单对象），所以客户端直接拦截抛出错误。

而Quarkus的Redis扩展做了上层封装，会自动将Map或复杂对象序列化为Redis支持的JSON字符串，所以看起来能直接用。但Vert.x原生客户端是更底层的实现，不会自动做这个转换，需要手动处理。

解决方法 #

1. 单个HSET批量设置多字段 #

Vert.x的HSET支持批量传入键值对，你需要把contextsMap转换成「Redis键 + 字段名1 + 序列化值1 + 字段名2 + 序列化值2...」的参数列表：

Map<String, Context> contextsMap = new HashMap<>();
// 填充你的contextsMap数据

List<Object> hsetArgs = new ArrayList<>();
hsetArgs.add("mykey"); // 指定Redis键

for (Map.Entry<String, Context> entry : contextsMap.entrySet()) {
    hsetArgs.add(entry.getKey()); // 字段名
    // 将Context对象序列化为JSON字符串
    String contextJson = JsonObject.mapFrom(entry.getValue()).encode();
    hsetArgs.add(contextJson); // 序列化后的字段值
}

Request contextRequest = Request.cmd(Command.HSET).args(hsetArgs);

2. 批量执行多个HSET（Pipeline模式） #

如果要批量提交多个HSET操作（比如给不同Redis键设值），可以用Vert.x的批量请求功能：

Redis redisClient = ...; // 初始化你的Vert.x Redis客户端
List<Request> batchRequests = new ArrayList<>();

for (Map.Entry<String, Context> entry : contextsMap.entrySet()) {
    String contextJson = JsonObject.mapFrom(entry.getValue()).encode();
    Request hsetReq = Request.cmd(Command.HSET)
            .arg("mykey") // 可替换为不同的Redis键
            .arg(entry.getKey())
            .arg(contextJson);
    batchRequests.add(hsetReq);
}

// 批量发送请求
redisClient.sendBatch(batchRequests)
        .onSuccess(results -> {
            // 处理批量执行结果
        })
        .onFailure(err -> {
            // 处理错误
        });

读取时的反序列化 #

后续读取这些值时，需要把JSON字符串反序列回Context对象：

redisClient.send(Request.cmd(Command.HGET).arg("mykey").arg("目标字段名"))
        .onSuccess(response -> {
            String jsonStr = response.toString();
            Context context = new JsonObject(jsonStr).mapTo(Context.class);
            // 使用context对象
        });

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