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。
欢迎分享,转载请注明来源:内存溢出
评论列表(0条)