zoukankan      html  css  js  c++  java
  • Redis中Pipeline的使用

    通过Java访问Redis,我们一般使用Jedis,示例代码如下:

    Jedis jedis = new Jedis("172.23.88.107", 6379);
    jedis.set("addr", "chonginq");
    jedis.del("addr");

    这段代码我们设置了addr的值,同时又删除了键addr。如果Redis和我们的Java程序在同一台服务器,那么可能不明显,如果我们的Java程序和Redis属于跨机房,那么这个命令就会通过网络发送两次。如果很多这种短小的命令通过网络传输势必就会造成网络延迟。于是就提出了pipeline的概念。
    pipeline就是把一组命令进行打包,然后一次性通过网络发送到Redis。同时将执行的结果批量的返回回来。示例代码如下:

    public void testPipeline(){
        Jedis jedis = new Jedis("172.23.88.107", 6379);
        try {
            Pipeline pipelined = jedis.pipelined();
            pipelined.set("addr", "chongqing");
            pipelined.del("addr");
            //pipelined.sync();//没有返回值
            List<Object> list= pipelined.syncAndReturnAll();
            for (Object object : list) {
                System.out.println(object);
            }
        } finally {
            redis.dispose(jedis);
        }
    }

    1.pipelined.sync()表示我一次性的异步发送到redis,不关注执行结果。
    2.pipelined.syncAndReturnAll()程序会阻塞,等到所有命令执行完之后返回一个List集合。
    3.pipeline也不适合组装特别多的命令,因此如果是成千上万的这种命令,我们还是要进行命令的拆分。

  • 相关阅读:
    1
    最大子串
    线段树
    mybatis分页插件
    springmvc下载文件
    获“领跑衫”感言
    finnal 评论 II
    用户使用报告
    事后诸葛亮会议 (尸体解剖)
    final阶段成员贡献分
  • 原文地址:https://www.cnblogs.com/duanjt/p/10245620.html
Copyright © 2011-2022 走看看