您的位置:首页 > 数据库 > Redis

使用Redisson、Jedis对redis进行管道操作(JAVA)

2017-12-25 15:52 561 查看
JAVA使用Redisson操作redis管道
第一次写博客分享,主要是公司业务用到,但是在网上搜索不到太多相关文章。摸索后准备分享出来。
Redis是一个key-value的数据库,它是一个性能超强的缓存数据库,他支持支持五种数据类型:string(字符串),hash(哈希),list(列   表),set(集合)及zset(sorted set:有序集合)。
一、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的管道返回对象是一个任意类型的list3、一次性执行所有命令res = batch.execute();
Redisson的批量操作是异步的。
      然后就可以拿到对应的结果。res里面包括全部的命令执行结果。

三、个人感想
本人第一次写这种博客,写的可能很差,但是还是希望能对您有所帮助
内容来自用户分享和网络整理,不保证内容的准确性,如有侵权内容,可联系管理员处理 点击这里给我发消息