Pig-man的gravatar头像
Pig-man 2016-03-15 17:04:02
程序对批量数据写入数据库的优化--引入Redis并通过定时器来触发

没错,还是上篇文章提到的那个SpringMVC+Mybatis的项目,在客户调我方接口,疯狂的给我们insert数据的时候,应该想到一些优化方案,于是Redis就被引用了。

关于Redis的客户端,服务端的一些用法引用了这篇微博http://blog.csdn.net/joyhen/article/details/47358999,这里我就不搬砖了,这个微博写的也算中规中矩,如果你不笨的话完全是可以搞定的。

我详细来讲一下程序里的调用好了。

这是一个Maven项目,于是在pom.xml里增加一下dependency,Spring.xml的配置就不上图了

<dependency>
         <groupId>org.redisson</groupId>
         <artifactId>redisson</artifactId>
         <version>1.0.2</version>
</dependency>

这样,我们的redisson的jar包就有了,然后进行简单的调用,封装一个固定的方法,便于后期的维护。然后调用Redis时候只需 Redisson redisson =RedisConnect.connect();就可以

 public static final String CONF_RESOURCE = "resource";
 public static final String redis_address = Resources.instance(CONF_RESOURCE).getAttributeValue("redis_address");//redis服务IP
 public static final String redis_password = Resources.instance(CONF_RESOURCE).getAttributeValue("redis_password");//redis密码
 
 
 public static final Redisson connect(){
         Config config = new Config();
         config.setConnectionPoolSize(10);
         config.addAddress(redis_address);
         config.setPassword(redis_password);
         Redisson redisson = Redisson.create(config);
         
         return redisson;
     }

 个人的一个肤浅的看法(勿喷,刚接触Redis,还没有高级点儿的理解):Redis就是一个放在内存或者说是缓存上的一个Map,通过<key,Value>来维护。于是就有了下面的写法:当controler传过来一个对象的时候,可以将对象的未来的主键作为Key,然后将对象转换成JSON放到Value中,期间我试过将对象作为Value放到map里,但是在我本地的windows系统下自己搭建的Redis服务器测试是没问题的,但是放到公司的Linux服务器上,如果在定时器处理时,如果没有插入到表里,map会无理由的将这条记录移出去,如果有同仁知道原因希望跟我联系。所以我选择了json格式,这样在服务器上是没有问题的。

     public void redisAdd(Order order) {
         
         Redisson redisson =RedisConnect.connect();
         
         ConcurrentMap<String,Object> newMap = redisson.getMap("newMap");
         order.setPushCount(0);
         String params = FastJsonUtil.toJSONString(order);
         newMap.put(order.getOrderNo(), params);
         // 关闭连接
         redisson.shutdown();
     }

 然后看一下取数据的代码:

   Redisson redisson = RedisConnect.connect();
 
   ConcurrentMap<String,Object> newMap = redisson.getMap("newMap");
   Set<String> mapKey= newMap.keySet();
   for(String orderNo : mapKey){
     params = (String)newMap.get(orderNo);
     order = JSONObject.parseObject(params, Order.class);
     orderService.add(order);
     newMap.remove(orderNo);//保存成功后将该条记录从map中删除
   }
   redisson.shutdown();//关闭redis

这样就可以通过定时器来定时出发这个方法,减少数据库连接池的压力,同时也提高效率。至于定时器,我想如果有空的话我写一个定时器的专栏,然后自己也试试不同的方法来实现


打赏
最近浏览
wkc  LV21 2020年6月28日
hs_shy  LV5 2019年8月2日
lihuiping 2019年6月29日
暂无贡献等级
encorelau  LV3 2018年9月14日
biology000  LV2 2018年9月10日
xiaomazha 2018年6月1日
暂无贡献等级
wgc_jy  LV21 2018年2月2日
weienqing  LV17 2017年11月15日
nsq0006  LV6 2017年11月7日
马小跳  LV12 2017年8月31日
顶部 客服 微信二维码 底部
>扫描二维码关注最代码为好友扫描二维码关注最代码为好友