当对Redis进行高频次的命令发送时，由于网络IO的原因，会耗去大量的时间。所以Redis提供了管道技术，就是将命令一次性批量的发送给Redis，从而减少IO。

一、Jedis对redis的管道进行操作

1、获取管道对象

String redisIp = "192.168.110.110";

int reidsPort = 6379;

Jedis jedis = new Jedis(redisIp, reidsPort);

Pipeline pl = jedis.pipelined();

获得到Pipeline 对象之后的操作跟redis类似，由于管道的返回对象Response

所以要对应你的命令创建接收集合

2、声明接收对象(注意类型匹配)

HashMap> map = new  HashMap>(20);

HashMap> map1 = new  HashMap>(20);

map.put("shiqing1", pl.set("shiqing1", "tiancai"));

map1.put("shi", pl.sadd("shi", "frefbrier"));

map.put("shiqing1value", pl.get("shiqing1"));

map1.put("shiqing", pl.lpush("shiqing", "name"));

map1.put("qing", pl.hsetnx("qing", "name", "sq"));

现在把所有要执行的命令都放进管道对象中，下一步就是执行这些命令

3、一次性执行所有命令

pl.sync();

这一步就是将所有命令都一次性执行，将结果保存在之前的map和map1中。

System.out.println(map.get("shiqing1").get());

System.out.println(map1.get("shi").get());

System.out.println(map.get("shiqing1value").get());

System.out.println(map1.get("shiqing").get());

System.out.println(map1.get("qing").get());

结果打印：

OK

0

tiancai

9

0

最后不要忘记关掉管道

try {

pl.close();

} catch (IOException e) {

// TODO Auto-generated catch block

e.printStackTrace();

}

二、Redisson对redis的批量进行操作

1、获取批量对象

Config config = new Config();

config. useSingleServer().setAddress("127.0.0.1:6379");

RedissonClient redisson = Redisson.create(config);

RBatch batch = redisson.createBatch();

获取到RBatch对象之后，跟jedis一样，要先把要执行的命令都放进Rbatch。

batch.getSet("setkey").readAllAsync();

batch.getList("listkey").readAllAsync();

batch.getMap("hashkey").addAndGetAsync("hashfiled", 2);

batch.getAtomicDouble("key1");

batch.getAtomicLong("key2");

batch.getBitSet("key3");

2、声明接收对象

List> res = new ArrayList>();

Redisson的管道返回对象是一个任意类型的list

3、一次性执行所有命令

res = batch.execute();

Redisson的批量操作是异步的。

然后就可以拿到对应的结果。res里面包括全部的命令执行结果。

.NET客户端实现Redis中的管道(PipeLine)与事物(Transactions)

序言 Redis中的管道(PipeLine)特性:简述一下就是,Redis如何从客户端一次发送多个命令,服务端到客户端如何一次性响应多个命令. Redis使用的是客户端-服务器模型和请求/响应协议的T ...

redis-cli 通过管道 --pipe 快速导入数据到redis中

最近有个需求,需要把五千万条数据批量写入redis中,方法倒是有很多种!效率最高的就是通过redis-cl管道的方式写入 一:先看看命令 cat redis.txt | redis-cli -h 12 ...

从redis中取值如果不存在设置值，使用Redisson分布式锁【我】

用到的jar包: redis.clients &lt ...

SpringBoot 中使用redis以及redisTemplate

1.首先在pom.xml中添加依赖 org.springframework.boot

Redis中的管道(PipeLine)与事物(Transactions)

Redis中的管道(PipeLine)与事物(Transactions) 序言 Redis中的管道(PipeLine)特性:简述一下就是,Redis如何从客户端一次发送多个命令,服务端到客户端如何一次 ...

往redis中存储数据是利用pipeline方法

在redis中保存数据时,保存和设置有效时间是分开写的话,如果中间出现的异常,这会导致数据永久有效,因此就可以采用pipeline方法. # 创建redis管道对象,可以一次执行多个语句 pipeli ...

在redis中使用lua脚本

在实际工作过程中,可以使用lua脚本来解决一些需要保证原子性的问题,而且lua脚本可以缓存在redis服务器上,势必会增加性能. 不过lua也会有很多限制,在使用的时候要注意. 在Redis中执行Lu ...

spring中redistemplate不能用通配符keys查出相应Key的问题

有个业务中需要删除某个前缀的所有Redis缓存,于是用RedisTemplate的keys方法先查出所有合适的key,再遍历删除.但是在keys(patten+"*")时每次取出的 ...

24、redis中的sentinel的作用?

redis中的sentinel的作用? Redis-Sentinel是Redis官方推荐的高可用性(HA)解决方案,当用Redis做Master-slave的高可用方案时,假如master宕机了,Re ...

随机推荐

iOS百度地图简单使用

本文介绍三种接口: 1.基础地图2.POI检索3.定位 首先是配置环境,有两种方法,方法在官方教程里都有,不再多说 1.使用CocoaPods自动配置[这个方法特别好,因为当你使用CocoaPods配 ...

idea快捷键(自用)

idea快捷键(自用) 1.比如输入eclipse下面的main,sysout等,在idea里面同样可以实现,如下: sysout(sout 按tab),main(psvm按tab),具体可按照ctr ...

iOS Photos.framework框架

链接: iOS8.0 使用Photos.framework对相册的常用操作 iOS AssetsLibrary和Photos的使用总结: 权限及相册的获取 iOS 开发之照片框架详解 iOS Asse ...

About_php_封装函数

[NYOJ 37] 回文字符串

回文字符串 时间限制:3000 ms  |  内存限制:65535 KB 难度:4   描述 所谓回文字符串,就是一个字符串,从左到右读和从右到左读是完全一样的,比如"aba".当 ...

犯罪团伙 codevs 3554

这是一道经典的水题,提供两种方法:①深搜  ②并查集 NO.1 深度优先搜索: #include#include#include

USDT(omniCore)测试环境搭建

一.测试环境搭建. 注:由于window版本的omni出现同步不了的问题,推荐使用linux系统进行usdt测试链的搭建. 1.下载omnicore: wget https://bintray.com ...

Linux系统中的文件权限

r(read)         4    可读 w(write)   2     可写 x()           1     可执行 644            755 rw-r-r        ...

Chromimu与JS交互的测试

CHROMIMU与JS交互的测试 好东西 谷歌浏览器 学习 研究  http://blog.csdn.net/grassdragon/article/details/51659798 Chromimu ...

Android中EditText焦点问题

https://www.jianshu.com/p/3d31d681f4bc 问题:当EditText失去焦点时做内容校验 场景:用户编辑EditText将内容清空,当点击空白地方时关闭软键盘,同时校 ...