zoukankan      html  css  js  c++  java
  • java通过redisTemplate使用pipeline调用redis数据

    一、为什么要使用Pipeline?

        Redis是采用基于C/S模式的请求/响应协议的TCP服务器。
                   性能问题一:redis客户端发送多条请求,后面的请求需要等待前面的请求处理完后,才能进行处理,而且每个请求都存在往返时间RRT(Round Trip Time),即使redis性能极高,当数据量足够大,也会极大影响性能,还可能会引起其他意外情况。
                   性能问题二:性能问题一,我们可以通过scan命令来解决,如何来设置count又是一个问题,设置不好,同样会有大量请求存在,即使设置到1w(推荐最大值),如果扫描的数据量太大,这个问题同样不能避免。每个请求都会经历三次握手、四次挥手,在处理大量连接时,处理完后,挥手会产生大量time-wait,如果该服务器提供其他服务,可能对其他服务造成影响。

    使用Pipeline可以解决以上问题。
    二、如何在使用Pipeline?

        本文使用的是RedisTemplate使用Pipeline需要调用executePipelined结果,相当简单。

    代码实例如:

    wins = redisTemplate.executePipelined(new SessionCallback<Object>() {
    @Override
    public <K, V> Object execute(RedisOperations<K, V> redisOperations) throws DataAccessException {
    for (Order order : orderList) {
    String orderManagerKey = RedisCacheUtil.buildKey(DspConstants.OM_TABLE_NAME, order.getId(), DateUtils.getCurrentDate("yyyyMMdd"));
    stringRedisTemplate.opsForHash().get(orderManagerKey, DspConstants.LOG_TYPE_WIN);
    }
    return null;
    }
    });
  • 相关阅读:
    设计模式开篇——7大设计原则
    MySQL MVCC专题
    Spring常考的面试题
    HashMap常考面试题
    Equals和==的比较
    高并发编程
    一文读懂JVM
    scala实现定时任务的方法
    PLAY2.6-SCALA(十二) 表单的处理
    PLAY2.6-SCALA(十一) 模板常用场景
  • 原文地址:https://www.cnblogs.com/xiaohan666/p/10901173.html
Copyright © 2011-2022 走看看