美文网首页
Redis-pipeline(管道)

Redis-pipeline(管道)

作者: 台风口的猪 | 来源:发表于2019-11-26 17:32 被阅读0次

本质

    客户端通过改变了读写的顺序带来的性能的巨大提升

什么时候使用管道(pipeline)

   Redis客户端执行事务时都会结合pipeline,可以将多次IO操作压缩为单次IO操作

request

1.write操作只需要把消息写到本地操作系统内核的发送缓冲然后就返回了
2.操作系统内核异步将数据发送到目标机器,但是如果发送缓冲满了,就需要
等待缓冲腾出空闲空间来,(这个就是写操作IO真正耗时的地方)

response

1.read操作负责将数据从本地操作系统内核的接收缓冲区取出来,如果缓冲是空的
那么久需要等待数据的到来(这个就是读操作IO真正耗时的地方)

在Spring中使用SessionCallback 和 RedisCallback

redisTemplate.opsForValue().set("key1", "value1");每次都需要开启一个连接
为了在一个redis连接中执行2条以上的命令,我们可以使用 SessionCallback 或者 RedisCallback
SessionCallback优先使用
RedisCallback 可读性比较差
 //TODO  该方法比较底层,可读性较差不推荐使用
        List<Object> redisCallback = redisTemplate.executePipelined(new RedisCallback<Object>() {
            @Override
            public Object doInRedis(RedisConnection redisConnection) throws DataAccessException {
                //打开管道
                redisConnection.openPipeline();
                // 给本次管道内添加要一次性执行的多条命令
                for (int i = 0; i < number; i++) {
                    redisConnection.set(("B" + i).getBytes(), (i + "").getBytes());
                }
                // 关闭管道,不需要close,否则拿不到返回值
//                redisConnection.closePipeline()
                // 这里一定要返回null,最终pipeline的执行结果,才会返回给最外层
                return null;
            }
        });
 public <T> void setObject(String key, T clazz, long timeout) {
       this.setObject(key, clazz, timeout, TimeUnit.SECONDS);
}

public Object pipeline() {
        int number = 1000;
        Long startTime = System.currentTimeMillis();
        for (int i = 0; i < number; i++) {
            setObject(("T" + i), (i + ""));
        }
        Long endTime = System.currentTimeMillis();

        List<Object> sessionCallback = redisTemplate.executePipelined(new SessionCallback<Object>() {
            @Override
            public <K, V> Object execute(RedisOperations<K, V> redisOperations) throws DataAccessException {
                for (int i = 0; i < number; i++) {
                    setObject(("Pipeline" + i), (i + ""));
                }
                return null;
            }
        });

        Long end = System.currentTimeMillis();
        log.info("不使用管道耗时:{}", (endTime - startTime));
        log.info("管道执行耗时: {}", (end - endTime));
        return sessionCallback;
    }

相关文章

  • Redis-pipeline(管道)

    本质 什么时候使用管道(pipeline) request 1.write操作只需要把消息写到本地操作系统内核的发...

  • redis-pipeline

    Redis-pipeline 注意事项 cluster并不支持pipeline操作,不知道有没有什么好的方法 本质...

  • Redis的pipeline

    pipeline:可将命令合并为一次IO,可降低延迟。 本机测试redis-pipeline 测试结果: 在本机测...

  • Spring的RedisTemplate Pipeline的正确

    redis-pipeline 我们都知道大批量有规律的redis写操作,用pipeline模式能够极大提高效率。在...

  • 工业管道工程施工程序

    管道分类与分级 工业管道按压力分级 管道的组成 管道由管道组成件和管道支承件组成 管道组件管道组成件是用于连接或装...

  • Redis-pipeline实现简单的限流

    今天讨论分布式应用中的限流问题,这里通过redis的pipeline实现个简单的限流。这里先简单说一下pipeli...

  • 管道基础

    ##管道基础 #通信分类:只写单工管道、只读单工管道、半双工管道(单向读写)、全双工管道(两个半双工管道拼接) 类...

  • Linux 进程间通信

    进程间通信 一 进程间通信 -- 管道 mkfifo test 创建管道文件 匿名管道和命名管道:匿名管道:匿名管...

  • 隧道安全逃生管道最新成果

    新型高分子隧道安全逃生管道分别有高分子逃生管道、新型隧道逃生管道、轻型逃生管道、悬挂式隧道逃生管道、防腐逃生管道、...

  • Linux-C-day-2-进程通过--管道通信

    管道通信 进程间管道通信方式可以通过man 7 pipe来查看; 匿名管道 单工管道 打开管道:使用popen()...

网友评论

      本文标题:Redis-pipeline(管道)

      本文链接:https://www.haomeiwen.com/subject/jeydwctx.html