Redis中RedisTemplate和Redisson管道的使用

當對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里面包括全部的命令執行結果。