Spring Data Redis：Redis管道始终返回null

Question

我想只使用指定的字段检索多个hashmap值。所以我选择了Redis管道。

在测试下面的代码时，我redisResponse1总是看到null，它redisResponse2具有价值。

    getRedisTemplate().executePipelined(new RedisCallback<Object>() { 
        @Override
        public Object doInRedis(RedisConnection connection) throws DataAccessException {
                List<byte[]> redisResponse1 = connection.hMGet(key.getBytes(), params);
                List<byte[]> redisResponse2 = getRedisTemplate().getConnectionFactory().getConnection().hMGet(key.getBytes(), specificParams);
                return null;
        }
    });

当我查看代码并发现下面的内容时，

a）redisResponse2不使用管道选项执行

b）redisResponse1用管道执行（isPipelined（）== true），但始终返回null。

public List<byte[]> hMGet(byte[] key, byte[]... fields) {
    try {
        if (isPipelined()) {
            pipeline(new JedisResult(pipeline.hmget(key, fields)));
            return null;
        }
        if (isQueueing()) {
            transaction(new JedisResult(transaction.hmget(key, fields)));
            return null;
        }
        return jedis.hmget(key, fields);
    } catch (Exception ex) {
        throw convertJedisAccessException(ex);
    }
}

所以问题是

1）如何通过管道选项实现用例？

2）getRedisTemplate().getConnectionFactory().getConnection()在此RedisCallback中访问有什么影响？

3）整个管道概念如何运作？就像动态的Lua吗？该Java代码在哪里转换为Lua脚本并作为脚本发送到Redis，在Redis中执行然后返回？在此回调中感到惊讶；代码也正在访问/更新外部类变量，那么所有这些变量将如何处理？所有这些外部类变量也会在lua中发送给redis吗？

4）我看到许多关于doInRedisAPI返回的示例null；为什么这样？如何从中返回/获取有效的对象？

Answer 1

Spring Data Redis 参考文档中提供了大多数问题。

在深入研究流水线之前，来自一个哈希的单个多重获取不需要流水线，因为它只是一个命令。管道传输不会提高Redis交互的性能/稳定性/…。

流水线被安排为回调，旨在发出多个命令而无需立即等待结果–将其视为一批，您可以在以后获得所有结果。因为流水线在最后就同步了响应，所以当流水线会话同步并executePipelined(…)终止时，您不会在回调内收到结果值，而是在最后。

您的代码应如下所示：

List<Object> results = getRedisTemplate().executePipelined(new RedisCallback<Object>() {

    @Override
    public Object doInRedis(RedisConnection connection) {

            connection.hMGet(key.getBytes(), params);

            return null;
    }
});

List<Object> hmget = (List<Object>) results.get(0);

您只需要使用收到的作为回调参数的连接，因为该连接已进入流水线模式。从回调外部获取连接（如template.getConnectionFactory().getConnection()）将打开一个新连接，并在等待响应的情况下执行Redis命令-
没有流水线应用于任何外部获得的连接。

您也可以使用的方法来RedisTemplate代替普通连接。executePipelined(…)将回调中使用的连接绑定到当前线程，并在调用模板API方法时重用该绑定的连接。

关于您的Lua问题：代码/方法调用不会移调到Lua。