首页 技术 正文
技术 2022年11月12日
0 收藏 650 点赞 5,049 浏览 1750 个字

当对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<T>

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

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

HashMap<String, Response<String>> map = new  HashMap<String,Response<String>>(20);
        HashMap<String, Response<Long>> map1 = new  HashMap<String,Response<Long>>(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里面包括全部的命令执行结果。

相关推荐
python开发_常用的python模块及安装方法
adodb:我们领导推荐的数据库连接组件bsddb3:BerkeleyDB的连接组件Cheetah-1.0:我比较喜欢这个版本的cheeta…
日期:2022-11-24 点赞:878 阅读:9,492
Educational Codeforces Round 11 C. Hard Process 二分
C. Hard Process题目连接:http://www.codeforces.com/contest/660/problem/CDes…
日期:2022-11-24 点赞:807 阅读:5,907
下载Ubuntn 17.04 内核源代码
zengkefu@server1:/usr/src$ uname -aLinux server1 4.10.0-19-generic #21…
日期:2022-11-24 点赞:569 阅读:6,740
可用Active Desktop Calendar V7.86 注册码序列号
可用Active Desktop Calendar V7.86 注册码序列号Name: www.greendown.cn Code: &nb…
日期:2022-11-24 点赞:733 阅读:6,495
Android调用系统相机、自定义相机、处理大图片
Android调用系统相机和自定义相机实例本博文主要是介绍了android上使用相机进行拍照并显示的两种方式,并且由于涉及到要把拍到的照片显…
日期:2022-11-24 点赞:512 阅读:8,132
Struts的使用
一、Struts2的获取  Struts的官方网站为:http://struts.apache.org/  下载完Struts2的jar包,…
日期:2022-11-24 点赞:671 阅读:5,295