Spring RedisTemplate 批量获取值的2种方式

1、利用mGet

List<String> keys = new ArrayList<>();
//初始keys
List<YourObject> list = this.redisTemplate.opsForValue().multiGet(keys);

2、利用PipeLine

List<YourObject> list = this.redisTemplate.executePipelined(new RedisCallback<YourObject>() {
@Override
public YourObject doInRedis(RedisConnection connection) throws DataAccessException {
StringRedisConnection conn = (StringRedisConnection)connection;
for (String key : keys) {
conn.get(key);
}
return null;
}
});

其实2者底层都是用到execute方法，multiGet在使用连接是没用到pipeline，一条命令直接传给Redis，Redis返回结果。而executePipelined实际上一条或多条命令，但是共用一个连接。

/**
* Executes the given action object within a connection that can be exposed or not. Additionally, the connection can
* be pipelined. Note the results of the pipeline are discarded (making it suitable for write-only scenarios).
*
* @param <T> return type
* @param action callback object to execute
* @param exposeConnection whether to enforce exposure of the native Redis Connection to callback code
* @param pipeline whether to pipeline or not the connection for the execution
* @return object returned by the action
*/
public <T> T execute(RedisCallback<T> action, boolean exposeConnection, boolean pipeline) {
Assert.isTrue(initialized, "template not initialized; call afterPropertiesSet() before using it");
Assert.notNull(action, "Callback object must not be null");
RedisConnectionFactory factory = getConnectionFactory();
RedisConnection conn = null;
try {
if (enableTransactionSupport) {
// only bind resources in case of potential transaction synchronization
conn = RedisConnectionUtils.bindConnection(factory, enableTransactionSupport);
} else {
conn = RedisConnectionUtils.getConnection(factory);
}
boolean existingConnection = TransactionSynchronizationManager.hasResource(factory);
RedisConnection connToUse = preProcessConnection(conn, existingConnection);
boolean pipelineStatus = connToUse.isPipelined();
if (pipeline && !pipelineStatus) { //开启管道
connToUse.openPipeline();
}
RedisConnection connToExpose = (exposeConnection ? connToUse : createRedisConnectionProxy(connToUse));
T result = action.doInRedis(connToExpose);
if (pipeline && !pipelineStatus) {// 关闭管道
connToUse.closePipeline();
}
// TODO: any other connection processing?
return postProcessResult(result, connToUse, existingConnection);
} finally {
if (!enableTransactionSupport) {
RedisConnectionUtils.releaseConnection(conn, factory);
}
}
}

还有一点，就是查询返回的结果，和键的顺序是一一对应的，如果没查到，会返回null值。

Spring RedisTemplate 批量获取值的2种方式相关推荐

Spring Boot当中获取request的三种方式
本篇博客主要记录request相关知识,也是开发当中经常遇到的,感兴趣的跟小编一起学习吧! 目录一.请求过程二.获取request的三种方式 2.1.可以封装为静态方法 2.2.controlle ...
Spring读取配置文件，获取bean的几种方式
Spring读取配置文件,获取bean的几种方式方法一:在初始化时保存ApplicationContext对象代码: ApplicationContext ac = new FileSystemX ...
Spring Boot 获取 Bean 的 3 种方式！还有谁不会？
作者 | chilx 来源 | https://blog.csdn.net/showchi/article/details/97005720 注意:调用者要被spring管理方式一注解@PostC ...
python执行系统命令后获取返回值的几种方式集合
第一种情况 os.system('ps aux') 执行系统命令,没有返回值第二种情况 result = os.popen('ps aux') res = result.read() for lin ...
【Spring杂烩】探讨Spring向容器注册Bean的三种方式
探讨Spring向容器注册Bean的三种方式重点了解@Import实现的三种子方式前提概要 Spring向容器注册Bean的三种方式通过@ComponentScan.@Componet 通过@B ...
Spring加载properties文件的两种方式
2019独角兽企业重金招聘Python工程师标准>>> 在项目中如果有些参数经常需要修改,或者后期可能需要修改,那我们最好把这些参数放到properties文件中,源代码中读取pro ...
用spring管理和实例化对象的四种方式
用spring管理和实例化对象的四种方式方式一:无参构造函数(最常用) 对象是spring创建,创建的对象还要交给spring容器管理 bean:豆子 id:在spring容器中Hello对象的名, ...
ASP.NET页面之间传递值的几种方式
页面传值是学习asp.net初期都会面临的一个问题,总的来说有页面传值.存储对象传值.ajax.类.model.表单等.但是一般来说,常用的较简单有QueryString,Session,Cookie ...
SpringBoot静态获取 bean的三种方式，你学会了吗？
欢迎关注方志朋的博客,回复"666"获面试宝典来源:blog.csdn.net/showchi/article/details/97005720 注意:调用者要被spring管理 ...

Spring RedisTemplate 批量获取值的2种方式

Spring RedisTemplate 批量获取值的2种方式相关推荐

最新文章

热门文章