[心缘地方]同学录
首页 | 功能说明 | 站长通知 | 最近更新 | 编码查看转换 | 代码下载 | 常见问题及讨论 | 《深入解析ASP核心技术》 | 王小鸭自动发工资条VBA版
登录系统:用户名: 密码: 如果要讨论问题,请先注册。

[备忘]redis批量插入数据,管道操作,spring的redisTemplate

上一篇:[备忘]mongodb绑定多个ip的写法
下一篇:[转帖]redis数据备份与恢复

添加日期:2017/8/23 22:40:38 快速返回   返回列表 阅读11147次
原来是这样,在外面循环调用。
获取一次连接,操作一次,关闭连接,想想都慢。


/**
* 增加元素到list头位置
* @param keyId
* @param bean
* @return
*/
public Long lPush(final String keyId,final Object bean){
Long result = redisTemplate.execute(new RedisCallback<Long>() {  
      public Long doInRedis(RedisConnection connection)  
              throws DataAccessException {  
          RedisSerializer<String> serializer = getRedisSerializer();  
          byte[] key  = serializer.serialize(keyId);  
          byte[] name ;
          if(StringUtil.isStr(bean)){
              name= serializer.serialize(bean.toString());  
          }else{
               name=serializer.serialize(JSONUtil.toJson(bean));  
          }
          connection.openPipeline();
          connection.lPush(key, name);
          connection.lPush(key, name);
          connection.lPush(key, name);
          connection.lPush(key, name);
          connection.lPush(key, name);
          List<Object> xxList = connection.closePipeline();
          return xxList;
          return connection.lPush(key, name);
      }  
  });  
  return result;  



可以改成这样,随便写的,没试~~


/**
* 增加元素到list头位置
* @param keyId
* @param bean
* @return
*/
public List<Object> lPush(final List<String> keyId,final List<Object> bean){
Long result = redisTemplate.execute(new RedisCallback<Long>() {  
      public Long doInRedis(RedisConnection connection)  
              throws DataAccessException {  

          connection.openPipeline();
          for循环{
                    key=...
                    value=..
                    connection.lPush(key, name);
          }
          return connection.closePipeline();

      }  
  });  
  return result;  

 

评论 COMMENTS
guest457767179
2018/2/8 11:24:55
测都不测就敢拿出来,牛逼
guest716690445
2018/2/9 20:15:42
写个思想就行了,还非得给你敲出代码来啊~
guest793067352
2018/3/30 17:33:28
666

添加评论 Add new comment.
昵称 Name:
评论内容 Comment:
验证码(不区分大小写)
Validation Code:
(not case sensitive)
看不清?点这里换一张!(Change it here!)
 
评论由管理员查看后才能显示。the comment will be showed after it is checked by admin.
CopyRight © 心缘地方 2005-2999. All Rights Reserved