springboot集成redis（二）各种类型数据的操作

springboot集成redis数据的插入和查询

1. SpringDataRedis操作String类型数据

@Test
public void testString() {
    ValueOperations<String, Object> valueOperations = redisTemplate.opsForValue();
    // 添加一条数据
    valueOperations.set("username", "zhangsan");
    valueOperations.set("age", "18");
    // redis中以层级关系、目录形式存储数据
    valueOperations.set("user:01", "lisi");
    valueOperations.set("user:02", "wangwu");
    // 添加多条数据
    Map<String, String> userMap = new HashMap<>();
    userMap.put("address", "bj");
    userMap.put("sex", "1");
    valueOperations.multiSet(userMap);
    // 获取一条数据
    Object username = valueOperations.get("username");
    System.out.println(username);
    // 获取多条数据
    List<String> keys = new ArrayList<>();
    keys.add("username");
    keys.add("age");
    keys.add("address");
    keys.add("sex");
    List<Object> resultList = valueOperations.multiGet(keys);
    for (Object str : resultList) {
        System.out.println(str);
    }
    // 删除
    redisTemplate.delete("username");
}

插入：
void set(K key, V value);
查询：
V get(Object key);
批量查询：
List multiGet(Collection keys);
删除：（redisTemplate实例）
Boolean delete(K key);

2. SpringDataRedis操作hash数据类型

@Test
public void testHash() {
    HashOperations<String, String, String> hashOperations = redisTemplate.opsForHash();
    /*
    * 
    添加一条数据
    *     
    参数一：redis的key
    *     
    参数二：hash的key
    *     
    参数三：hash的value
    */
    hashOperations.put("userInfo","name","lisi");
    // 添加多条数据
    Map<String, String> map = new HashMap();
    map.put("age", "20");
    map.put("sex", "1");
    hashOperations.putAll("userInfo", map);
    // 获取一条数据
    String name = hashOperations.get("userInfo", "name");
    System.out.println(name);
    // 获取多条数据
    List<String> keys = new ArrayList<>();
    keys.add("age");
    keys.add("sex");
    List<String> resultlist =hashOperations.multiGet("userInfo", keys);
    for (String str : resultlist) {
        System.out.println(str);
    }
    // 获取Hash类型所有的数据
    Map<String, String> userMap = hashOperations.entries("userInfo");
    for (Entry<String, String> userInfo : userMap.entrySet()) {
        System.out.println(userInfo.getKey() + "--" + userInfo.getValue());
    }
    // 删除 用于删除hash类型数据
    hashOperations.delete("userInfo", "name");
}

插入：
void put(H key, HK hashKey, HV value);
void putAll(H key, Map<? extends HK, ? extends HV> m);
查询：
HV get(H key, Object hashKey);
批量查询：
List multiGet(H key, Collection hashKeys);
Map entries(H key);
删除：
Long delete(H key, Object... hashKeys);

3. SpringDataRedis操作List类型数据

@Test
public void testList() {
    ListOperations<String, Object> listOperations = redisTemplate.opsForList();
    // 左添加(上)
    //       listOperations.leftPush("students", "Wang Wu");
    //       listOperations.leftPush("students", "Li Si");
    // 左添加(上) 把value值放到key对应列表中pivot值的左面，如果pivot值存在的话
    //listOperations.leftPush("students", "Wang Wu", "Li Si");
    // 右添加(下)
    //       listOperations.rightPush("students", "Zhao Liu");
    // 获取 start起始下标 end结束下标 包含关系
    List<Object> students = listOperations.range("students", 0,2);
    for (Object stu : students) {
        System.out.println(stu);
    }
    // 根据下标获取
    Object stu = listOperations.index("students", 1);
    System.out.println(stu);
    // 获取总条数
    Long total = listOperations.size("students");
    System.out.println("总条数：" + total);
    // 删除单条 删除列表中存储的列表中几个出现的Li Si。
    listOperations.remove("students", 1, "Li Si");
    // 删除多条
    redisTemplate.delete("students");
}

左添加：
leftPush()
右添加：
rightPush()
根据下标获取：
index(key,index)
获取总条数：
size(key)
删除：
remove(key,count,value)

4. SpringDataRedis操作set类型数据

@Test
public void testSet() {
    SetOperations<String, Object> setOperations = redisTemplate.opsForSet();
    // 添加数据
    String[] letters = new String[]{"aaa", "bbb", "ccc", "ddd", "eee"};
    //setOperations.add("letters", "aaa", "bbb", "ccc", "ddd", "eee");
    setOperations.add("letters", letters);
    // 获取数据
    Set<Object> let = setOperations.members("letters");
    for (Object letter: let) {
        System.out.println(letter);
    }
    // 删除
    setOperations.remove("letters", "aaa", "bbb");
}

添加：
add(key,value)
获取：
members(key)

5. SpringDataRedis操作sorted set类型数据

@Test
public void testSortedSet() {
    ZSetOperations<String, Object> zSetOperations = redisTemplate.opsForZSet();
    ZSetOperations.TypedTuple<Object> objectTypedTuple1 = new DefaultTypedTuple<Object>("zhangsan", 7D);
    ZSetOperations.TypedTuple<Object> objectTypedTuple2 = new DefaultTypedTuple<Object>("lisi", 3D);
    ZSetOperations.TypedTuple<Object> objectTypedTuple3 = new DefaultTypedTuple<Object>("wangwu", 5D);
    ZSetOperations.TypedTuple<Object> objectTypedTuple4 = new DefaultTypedTuple<Object>("zhaoliu", 6D);
    ZSetOperations.TypedTuple<Object> objectTypedTuple5 = new DefaultTypedTuple<Object>("tianqi", 2D);
    Set<ZSetOperations.TypedTuple<Object>> tuples = new HashSet<ZSetOperations.TypedTuple<Object>>();
    tuples.add(objectTypedTuple1);
    tuples.add(objectTypedTuple2);
    tuples.add(objectTypedTuple3);
    tuples.add(objectTypedTuple4);
    tuples.add(objectTypedTuple5);
    // 添加数据
    zSetOperations.add("score", tuples);
    // 获取数据
    Set<Object> scores = zSetOperations.range("score", 0, 4);
    for (Object score: scores) {
        System.out.println(score);
    }
    // 获取总条数
    Long total = zSetOperations.size("score");
    System.out.println("总条数：" + total);
    // 删除
    zSetOperations.remove("score", "zhangsan", "lisi");
}

添加数据：
add(key,score,value)
查询：
range(key,start,end)

6. SpringDataRedis获取所有key和设置key失效时间

1. 获取所有key

@Test
public void testAllKeys() {
    // 当前库key的名称
    Set<String> keys = redisTemplate.keys("*");
    for (String key: keys) {
        System.out.println(key);
    }
}

2. 设置key的失效时间

@Test
public void testEx() {
    ValueOperations<String, Object> valueOperations = redisTemplate.opsForValue();
    // 方法一：插入一条数据并设置失效时间
    valueOperations.set("code", "abcd", 180, TimeUnit.SECONDS);
    // 方法二：给已存在的key设置失效时间
    boolean flag = redisTemplate.expire("code", 180, TimeUnit.SECONDS);
    // 获取指定key的失效时间
    Long l = redisTemplate.getExpire("code");
}