Lettuce操作AWS ElastiCache JSON MGET时不存在键引发空指针问题求助

当使用Lettuce的jsonMGet批量读取Valkey缓存时，若输入列表中包含不存在的键，Valkey会返回对应位置的nil，而Lettuce在解析该nil值时触发了NullPointerException（底层尝试操作ByteBuffer但bytes为null），导致无法返回其他存在键的结果。

可以通过先批量校验键的存在性，仅对存在的键执行jsonMGet来避免NPE；同时在异常处理中加入逐个读取的降级逻辑，确保即使批量操作失败也能返回可用结果。另外建议升级Lettuce到最新稳定版，可能已修复此兼容性bug。

优化后的代码实现 #

import java.util.ArrayList;
import java.util.Collections;
import java.util.List;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import io.lettuce.core.RedisAsyncCommands;
import io.lettuce.core.json.JsonPath;
import io.lettuce.core.json.JsonValue;

public class CacheService {
    private static final Logger log = LoggerFactory.getLogger(CacheService.class);
    private final RedisCacheClient redisCacheClient; // 假设已注入该客户端

    public List<JsonValue> readMultipleKeys(List<String> keys) {
        if (keys == null || keys.isEmpty()) {
            return Collections.emptyList();
        }

        RedisAsyncCommands<String, String> async = null;
        try {
            async = redisCacheClient.connect().async();
            // 1. 批量检查哪些键存在于缓存中
            List<Long> existsResults = async.exists(keys.toArray(new String[0])).get();
            
            // 2. 过滤出存在的键
            List<String> existingKeys = new ArrayList<>();
            for (int i = 0; i < keys.size(); i++) {
                if (existsResults.get(i) == 1) {
                    existingKeys.add(keys.get(i));
                }
            }

            if (existingKeys.isEmpty()) {
                return Collections.emptyList();
            }

            // 3. 仅对存在的键执行批量JSON读取
            return async.jsonMGet(JsonPath.ROOT_PATH, existingKeys.toArray(new String[0])).get();
        } catch (Exception e) {
            log.error("批量读取缓存失败，降级为逐个读取: ", e);
            List<JsonValue> fallbackResult = new ArrayList<>();
            
            // 初始化连接（若之前连接失败）
            if (async == null) {
                try {
                    async = redisCacheClient.connect().async();
                } catch (Exception connectEx) {
                    log.error("缓存连接初始化失败，无法执行降级读取", connectEx);
                    return fallbackResult;
                }
            }

            // 逐个读取键，忽略读取失败或不存在的键
            for (String key : keys) {
                try {
                    JsonValue value = async.jsonGet(key, JsonPath.ROOT_PATH).get();
                    if (value != null) {
                        fallbackResult.add(value);
                    }
                } catch (Exception keyEx) {
                    log.warn("读取键 {} 失败", key, keyEx);
                }
            }
            return fallbackResult;
        } finally {
            // 关闭连接，避免资源泄漏
            if (async != null && async.getStatefulConnection().isOpen()) {
                async.getStatefulConnection().close();
            }
        }
    }
}

关键优化点 #

• 批量存在性校验：提前过滤不存在的键，避免jsonMGet处理nil值触发NPE
• 资源管理：在finally块中关闭缓存连接，防止连接池资源泄漏
• 降级逻辑：批量操作失败时自动切换为逐个读取，保证服务可用性
• 日志完善：打印完整异常栈轨迹，便于排查问题；对单个键读取失败仅打警告日志，不中断流程

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