Spring中使用RedisTemplate操作Redis（spring-data-redis）-白红宇

Spring中使用RedisTemplate操作Redis（spring-data-redis）

阅读量：5030 次

发布时间：2019-06-12

本文共 54233 字，大约阅读时间需要 180 分钟。

Redis 数据结构简介

Redis可以存储键与5种不同数据结构类型之间的映射，这5种数据结构类型分别为String（字符串）、List（列表）、Set（集合）、Hash（散列）和 Zset（有序集合）。 下面来对这5种数据结构类型作简单的介绍：

结构类型	结构存储的值	结构的读写能力
String	可以是字符串、整数或者浮点数	对整个字符串或者字符串的其中一部分执行操作；对象和浮点数执行自增(increment)或者自减(decrement)
List	一个链表，链表上的每个节点都包含了一个字符串	从链表的两端推入或者弹出元素；根据偏移量对链表进行修剪(trim)；读取单个或者多个元素；根据值来查找或者移除元素
Set	包含字符串的无序收集器(unorderedcollection)，并且被包含的每个字符串都是独一无二的、各不相同	添加、获取、移除单个元素；检查一个元素是否存在于某个集合中；计算交集、并集、差集；从集合里卖弄随机获取元素
Hash	包含键值对的无序散列表	添加、获取、移除单个键值对；获取所有键值对
Zset	字符串成员(member)与浮点数分值(score)之间的有序映射，元素的排列顺序由分值的大小决定	添加、获取、删除单个元素；根据分值范围(range)或者成员来获取元素

Redis 5种数据结构的概念大致介绍到这边，下面将结合Spring封装的RedisTemplate来对这5种数据结构的运用进行演示

RedisTemplate介绍

Spring封装了RedisTemplate对象来进行对Redis的各种操作，它支持所有的Redis原生的api。RedisTemplate位于spring-data-redis包下。

RedisTemplate在Spring代码中的结构如下：

org.springframework.data.redis.coreClass RedisTemplate
     
      java.lang.Object    org.springframework.data.redis.core.RedisAccessor        org.springframework.data.redis.core.RedisTemplate

Type Parameters:

模板中的Redis key的类型（通常为String）如：RedisTemplate<String, Object>

注意：如果没特殊情况，切勿定义成RedisTemplate<Object, Object>，否则根据里氏替换原则，使用的时候会造成类型错误。

模板中的Redis value的类型

RedisTemplate中定义了对5种数据结构操作

redisTemplate.opsForValue();//操作字符串redisTemplate.opsForHash();//操作hashredisTemplate.opsForList();//操作listredisTemplate.opsForSet();//操作setredisTemplate.opsForZSet();//操作有序set

StringRedisTemplate与RedisTemplate

两者的关系是StringRedisTemplate继承RedisTemplate。

两者的数据是不共通的；也就是说StringRedisTemplate只能管理StringRedisTemplate里面的数据，RedisTemplate只能管理RedisTemplate中的数据。

SDR默认采用的序列化策略有两种，一种是String的序列化策略，一种是JDK的序列化策略。

StringRedisTemplate默认采用的是String的序列化策略，保存的key和value都是采用此策略序列化保存的。

RedisTemplate默认采用的是JDK的序列化策略，保存的key和value都是采用此策略序列化保存的。

RedisConf配置如下：

package com.guige.core.conf;import com.guige.core.ext.common.redis.MyCacheErrorHandler;import com.guige.core.ext.common.redis.MyKeyGenerator;import com.guige.core.ext.common.redis.MyRedisCacheManager;import com.guige.core.ext.common.redis.MyRedisTemplate;import org.springframework.beans.factory.annotation.Value;import org.springframework.cache.interceptor.CacheErrorHandler;import org.springframework.cache.interceptor.KeyGenerator;import org.springframework.context.annotation.Bean;import org.springframework.context.annotation.Configuration;import org.springframework.data.redis.cache.RedisCacheManager;import org.springframework.data.redis.connection.jedis.JedisConnectionFactory;import org.springframework.data.redis.core.RedisTemplate;import org.springframework.stereotype.Component;import redis.clients.jedis.JedisPoolConfig;/** * TODO * * @author songaw * @date 2018/7/17 11:29 */@Component@Configurationpublic class RedisConf {    @Value("${spring.redis.database}")    private Integer database;    @Value("${spring.redis.host}")    private String host;    @Value("${spring.redis.password}")    private String password;    @Value("${spring.redis.port}")    private Integer port;    @Value("${spring.redis.timeout}")    private Integer timeout;    @Value(value = "${spring.redis.expire:300}")    private Integer expiration;    @Value("${spring.redis.pool.maxactive}")    private int maxActive;    @Value("${spring.redis.pool.minidle}")    private int minIdle;    @Value("${spring.redis.pool.maxidle}")    private int maxIdle;    @Bean    public JedisPoolConfig jedisPoolConfig(){        JedisPoolConfig poolConfig = new JedisPoolConfig();        poolConfig.setMaxIdle(this.maxIdle);        poolConfig.setMinIdle(this.minIdle);        poolConfig.setTestOnCreate(true);        poolConfig.setTestOnBorrow(true);        poolConfig.setTestOnReturn(true);        poolConfig.setTestWhileIdle(true);        return poolConfig;    }    @Bean    public JedisConnectionFactory jedisConnectionFactory(){        JedisPoolConfig config = jedisPoolConfig();        JedisConnectionFactory jedisConnectionFactory = new JedisConnectionFactory(config);        jedisConnectionFactory.setDatabase(this.database);        jedisConnectionFactory.setHostName(this.host);        jedisConnectionFactory.setPassword(this.password);        jedisConnectionFactory.setPort(this.port);        jedisConnectionFactory.setTimeout(this.timeout);        return jedisConnectionFactory;    }    @Bean   public  RedisTemplate redisTemplate(){        MyRedisTemplate myRedisTemplate = new MyRedisTemplate();        myRedisTemplate.setConnectionFactory(jedisConnectionFactory());        return myRedisTemplate;    }    public RedisCacheManager redisCacheManager(){        MyRedisCacheManager myRedisCacheManager = new MyRedisCacheManager(redisTemplate());        return myRedisCacheManager;    }    @Bean    public CacheErrorHandler cacheErrorHandler(){        MyCacheErrorHandler myCacheErrorHandler = new MyCacheErrorHandler();        return myCacheErrorHandler;    }    @Bean    KeyGenerator keyGenerator(){        MyKeyGenerator myKeyGenerator = new MyKeyGenerator();        return myKeyGenerator;    }}

MyRedisTemplate

package com.guige.core.ext.common.redis;import com.fasterxml.jackson.annotation.JsonAutoDetect;import com.fasterxml.jackson.annotation.PropertyAccessor;import com.fasterxml.jackson.databind.ObjectMapper;import org.springframework.data.redis.connection.RedisConnectionFactory;import org.springframework.data.redis.core.RedisTemplate;import org.springframework.data.redis.serializer.Jackson2JsonRedisSerializer;/** * 自己的redisTemplate * * @author Song.aw * @create 2017-12-07 9:37 **/public class MyRedisTemplate  extends RedisTemplate {    public MyRedisTemplate(){        Jackson2JsonRedisSerializer

MyRedisCacheManager

package com.guige.core.ext.common.redis;import org.springframework.cache.Cache;import org.springframework.data.redis.cache.RedisCache;import org.springframework.data.redis.cache.RedisCacheManager;import org.springframework.data.redis.core.RedisOperations;import com.guige.core.ext.util.SysLog;/** * redis 缓存管理 * * @author Song.aw * @create 2017-12-05 15:31 **/public class MyRedisCacheManager extends RedisCacheManager {        public MyRedisCacheManager(RedisOperations redisOperations) {        super(redisOperations);    }    @Override    protected RedisCache createCache(String cacheName) {        try {            cacheName = CacheConstant.proccessCacheName(cacheName);            if (cacheName != null) {                long expiration = this.computeExpiration(cacheName);                MyRedisCache redisCache= new MyRedisCache(cacheName, super.isUsePrefix()?super.getCachePrefix().prefix(cacheName):null, super.getRedisOperations(), expiration);               // MyRedisCache redisCache = super.createCache(cacheName);                SysLog.info("创建缓存" + cacheName);                return redisCache;            } else {                return null;            }        }catch (Exception e){            SysLog.error("创建缓存出错:",e);            return null;        }    }    @Override    public Cache getCache(String cacheName) {        try {            cacheName = CacheConstant.proccessCacheName(cacheName);            if (cacheName != null) {                Cache cache = super.getCache(cacheName);                SysLog.info("获取缓存" + cacheName);                return cache;            } else {                return null;            }        }catch (Exception e){            SysLog.error("获取缓存错误:",e);            return null;        }    }}

MyRedisCache

package com.guige.core.ext.common.redis;import org.springframework.data.redis.cache.RedisCache;import org.springframework.data.redis.core.RedisOperations;/** * 自己的redisCache * * @author Song.aw * @create 2017-12-06 14:12 **/public class MyRedisCache extends RedisCache {        public MyRedisCache(String name, byte[] prefix, RedisOperations
      redisOperations, long expiration) {        super(name, prefix, redisOperations, expiration);    }  /*  @Override    public ValueWrapper get(Object key) {        try {            ValueWrapper valueWrapper = super.get(key);            return valueWrapper;        }catch (Exception e){            log.error("获取缓存出错"+e);            e.printStackTrace();            return null;        }    }   */}

RedisTemplate配置如下：

@Beanpublic RedisTemplate
     
       redisTemplate(RedisConnectionFactory redisConnectionFactory){        Jackson2JsonRedisSerializer

Redis的String数据结构（推荐使用StringRedisTemplate）

注意：如果使用RedisTemplate需要更改序列化方式

RedisSerializer
     
       stringSerializer = new StringRedisSerializer();        template.setKeySerializer(stringSerializer );        template.setValueSerializer(stringSerializer );        template.setHashKeySerializer(stringSerializer );        template.setHashValueSerializer(stringSerializer );

public interface ValueOperations
     
      ValueOperations可以对String数据结构进行操作：---------------------------------------------------------------------------------------------------------------set void set(K key, V value); 使用：redisTemplate.opsForValue().set("name","tom");结果：redisTemplate.opsForValue().get("name")  输出结果为tom---------------------------------------------------------------------------------------------------------------set void set(K key, V value, long timeout, TimeUnit unit);使用：redisTemplate.opsForValue().set("name","tom",10, TimeUnit.SECONDS);结果：redisTemplate.opsForValue().get("name")由于设置的是10秒失效，十秒之内查询有结果，十秒之后返回为null---------------------------------------------------------------------------------------------------------------set void set(K key, V value, long offset); 该方法是用 value 参数覆写(overwrite)给定 key 所储存的字符串值，从偏移量 offset 开始使用：template.opsForValue().set("key","hello world");      template.opsForValue().set("key","redis", 6);      System.out.println("***************"+template.opsForValue().get("key"));结果：***************hello redis---------------------------------------------------------------------------------------------------------------setIfAbsent Boolean setIfAbsent(K key, V value); 使用：System.out.println(template.opsForValue().setIfAbsent("multi1","multi1"));//false  multi1之前已经存在        System.out.println(template.opsForValue().setIfAbsent("multi111","multi111"));//true  multi111之前不存在结果：falsetrue--------------------------------------------------------------------------------------------------------------- multiSet void multiSet(Map
       m); 为多个键分别设置它们的值 multiSet void multiSet(Map
       m); 使用：        Map
      
        maps = new HashMap
       
        ();        maps.put("multi1","multi1");        maps.put("multi2","multi2");        maps.put("multi3","multi3");        template.opsForValue().multiSet(maps);        List
        
          keys = new ArrayList
         
          ();        keys.add("multi1");        keys.add("multi2");        keys.add("multi3");        System.out.println(template.opsForValue().multiGet(keys));结果：        [multi1, multi2, multi3]---------------------------------------------------------------------------------------------------------------get V get(Object key);使用：template.opsForValue().set("key","hello world");      System.out.println("***************"+template.opsForValue().get("key"));结果：***************hello world--------------------------------------------------------------------------------------------------------------- getAndSet V getAndSet(K key, V value); 设置键的字符串值并返回其旧值使用：template.opsForValue().set("getSetTest","test");      System.out.println(template.opsForValue().getAndSet("getSetTest","test2"));结果：test---------------------------------------------------------------------------------------------------------------multiGet List
          
            multiGet(Collection
           
             keys); 为多个键分别取出它们的值使用：Map
            
              maps = new HashMap
             
              (); maps.put("multi1","multi1"); maps.put("multi2","multi2"); maps.put("multi3","multi3"); template.opsForValue().multiSet(maps); List
              
                keys = new ArrayList
               
                (); keys.add("multi1"); keys.add("multi2"); keys.add("multi3"); System.out.println(template.opsForValue().multiGet(keys));结果：[multi1, multi2, multi3]--------------------------------------------------------------------------------------------------------------- increment Long increment(K key, long delta); 支持整数使用：template.opsForValue().increment("increlong",1); System.out.println("***************"+template.opsForValue().get("increlong"));结果：***************1--------------------------------------------------------------------------------------------------------------- increment Double increment(K key, double delta); 也支持浮点数使用：template.opsForValue().increment("increlong",1.2); System.out.println("***************"+template.opsForValue().get("increlong"));结果：***************2.2--------------------------------------------------------------------------------------------------------------- append Integer append(K key, String value);如果key已经存在并且是一个字符串，则该命令将该值追加到字符串的末尾。如果键不存在，则它被创建并设置为空字符串，因此APPEND在这种特殊情况下将类似于SET。使用：template.opsForValue().append("appendTest","Hello"); System.out.println(template.opsForValue().get("appendTest")); template.opsForValue().append("appendTest","world"); System.out.println(template.opsForValue().get("appendTest"));结果：Hello Helloworld--------------------------------------------------------------------------------------------------------------- get String get(K key, long start, long end); 截取key所对应的value字符串使用：appendTest对应的value为HelloworldSystem.out.println("*********"+template.opsForValue().get("appendTest",0,5));结果：*********Hellow使用：System.out.println("*********"+template.opsForValue().get("appendTest",0,-1));结果：*********Helloworld使用：System.out.println("*********"+template.opsForValue().get("appendTest",-3,-1));结果：*********rld--------------------------------------------------------------------------------------------------------------- size Long size(K key); 返回key所对应的value值得长度使用：template.opsForValue().set("key","hello world"); System.out.println("***************"+template.opsForValue().size("key"));结果：***************11---------------------------------------------------------------------------------------------------------------setBit Boolean setBit(K key, long offset, boolean value); 对 key 所储存的字符串值，设置或清除指定偏移量上的位(bit)key键对应的值value对应的ascii码,在offset的位置(从左向右数)变为value使用：template.opsForValue().set("bitTest","a"); // 'a' 的ASCII码是 97。转换为二进制是：01100001 // 'b' 的ASCII码是 98 转换为二进制是：01100010 // 'c' 的ASCII码是 99 转换为二进制是：01100011 //因为二进制只有0和1，在setbit中true为1，false为0，因此我要变为'b'的话第六位设置为1，第七位设置为0 template.opsForValue().setBit("bitTest",6, true); template.opsForValue().setBit("bitTest",7, false); System.out.println(template.opsForValue().get("bitTest"));结果：b--------------------------------------------------------------------------------------------------------------- getBit Boolean getBit(K key, long offset); 获取键对应值的ascii码的在offset处位值使用：System.out.println(template.opsForValue().getBit("bitTest",7));结果：false

Redis的List数据结构

这边我们把RedisTemplate序列化方式改回之前的

Jackson2JsonRedisSerializer

public interface ListOperations
     
      Redis列表是简单的字符串列表，按照插入顺序排序。你可以添加一个元素导列表的头部（左边）或者尾部（右边）ListOperations专门操作list列表：---------------------------------------------------------------------------------------------------------------List
      
        range(K key, long start, long end);返回存储在键中的列表的指定元素。偏移开始和停止是基于零的索引，其中0是列表的第一个元素（列表的头部），1是下一个元素使用：System.out.println(template.opsForList().range("list",0,-1));结果:[c#, c++, python, java, c#, c#]---------------------------------------------------------------------------------------------------------------void trim(K key, long start, long end);修剪现有列表，使其只包含指定的指定范围的元素，起始和停止都是基于0的索引使用：System.out.println(template.opsForList().range("list",0,-1));template.opsForList().trim("list",1,-1);//裁剪第一个元素System.out.println(template.opsForList().range("list",0,-1));结果:[c#, c++, python, java, c#, c#][c++, python, java, c#, c#]---------------------------------------------------------------------------------------------------------------Long size(K key);返回存储在键中的列表的长度。如果键不存在，则将其解释为空列表，并返回0。当key存储的值不是列表时返回错误。使用：System.out.println(template.opsForList().size("list"));结果:6---------------------------------------------------------------------------------------------------------------Long leftPush(K key, V value);将所有指定的值插入存储在键的列表的头部。如果键不存在，则在执行推送操作之前将其创建为空列表。（从左边插入）使用：template.opsForList().leftPush("list","java");      template.opsForList().leftPush("list","python");      template.opsForList().leftPush("list","c++");结果:返回的结果为推送操作后的列表的长度123---------------------------------------------------------------------------------------------------------------Long leftPushAll(K key, V... values);批量把一个数组插入到列表中使用：String[] stringarrays = new String[]{"1","2","3"};      template.opsForList().leftPushAll("listarray",stringarrays);      System.out.println(template.opsForList().range("listarray",0,-1));结果:[3, 2, 1]---------------------------------------------------------------------------------------------------------------Long leftPushAll(K key, Collection
       
         values);批量把一个集合插入到列表中使用：List

Redis的Hash数据机构

Redis的散列可以让用户将多个键值对存储到一个Redis键里面。

public interface HashOperations
     
      HashOperations提供一系列方法操作hash：---------------------------------------------------------------------------------------------------------------初始数据:template.opsForHash().put("redisHash","name","tom");template.opsForHash().put("redisHash","age",26);template.opsForHash().put("redisHash","class","6");Map
      
        testMap = new HashMap();testMap.put("name","jack");testMap.put("age",27);testMap.put("class","1");template.opsForHash().putAll("redisHash1",testMap);---------------------------------------------------------------------------------------------------------------Long delete(H key, Object... hashKeys); 删除给定的哈希hashKeys使用：System.out.println(template.opsForHash().delete("redisHash","name"));      System.out.println(template.opsForHash().entries("redisHash"));结果：1{class=6, age=28.1}---------------------------------------------------------------------------------------------------------------Boolean hasKey(H key, Object hashKey); 确定哈希hashKey是否存在使用：System.out.println(template.opsForHash().hasKey("redisHash","age"));      System.out.println(template.opsForHash().hasKey("redisHash","ttt"));结果：truefalse---------------------------------------------------------------------------------------------------------------HV get(H key, Object hashKey); 从键中的哈希获取给定hashKey的值使用：System.out.println(template.opsForHash().get("redisHash","age"));结果：26---------------------------------------------------------------------------------------------------------------List
       
         multiGet(H key, Collection
        
          hashKeys); 从哈希中获取给定hashKey的值使用：List

Redis的Set数据结构

Redis的Set是string类型的无序集合。集合成员是唯一的，这就意味着集合中不能出现重复的数据。

Redis 中集合是通过哈希表实现的，所以添加，删除，查找的复杂度都是O(1)。

public interface SetOperations
     
      SetOperations提供了对无序集合的一系列操作：

--------------------------------------------------------------------------------------------------------------- Long add(K key, V... values); 无序集合中添加元素，返回添加个数 也可以直接在add里面添加多个值 如：template.opsForSet().add("setTest","aaa","bbb")

使用：String[] strarrays = new String[]{"strarr1","sgtarr2"};      System.out.println(template.opsForSet().add("setTest", strarrays));结果：2

--------------------------------------------------------------------------------------------------------------- Long remove(K key, Object... values); 移除集合中一个或多个成员

使用：String[] strarrays = new String[]{"strarr1","sgtarr2"};System.out.println(template.opsForSet().remove("setTest",strarrays));结果：2

--------------------------------------------------------------------------------------------------------------- V pop(K key); 移除并返回集合中的一个随机元素

使用：System.out.println(template.opsForSet().pop("setTest"));System.out.println(template.opsForSet().members("setTest"));结果：bbb[aaa, ccc]

---------------------------------------------------------------------------------------------------------------

Boolean move(K key, V value, K destKey); 将 member 元素从 source 集合移动到 destination 集合

使用：template.opsForSet().move("setTest","aaa","setTest2");      System.out.println(template.opsForSet().members("setTest"));      System.out.println(template.opsForSet().members("setTest2"));结果：[ccc][aaa]

--------------------------------------------------------------------------------------------------------------- Long size(K key); 无序集合的大小长度

使用：System.out.println(template.opsForSet().size("setTest"));结果：1

--------------------------------------------------------------------------------------------------------------- Boolean isMember(K key, Object o); 判断 member 元素是否是集合 key 的成员

使用：System.out.println(template.opsForSet().isMember("setTest","ccc"));      System.out.println(template.opsForSet().isMember("setTest","asd"));结果：truefalse --------------------------------------------------------------------------------------------------------------- Set
     
       intersect(K key, K otherKey);

key对应的无序集合与otherKey对应的无序集合求交集

使用：System.out.println(template.opsForSet().members("setTest"));      System.out.println(template.opsForSet().members("setTest2"));      System.out.println(template.opsForSet().intersect("setTest","setTest2"));结果：[aaa, ccc][aaa][aaa]

---------------------------------------------------------------------------------------------------------------

Set
     
       intersect(K key, Collection
      
        otherKeys); key对应的无序集合与多个otherKey对应的无序集合求交集

使用：System.out.println(template.opsForSet().members("setTest"));        System.out.println(template.opsForSet().members("setTest2"));        System.out.println(template.opsForSet().members("setTest3"));        List
     
       strlist = new ArrayList
      
       ();        strlist.add("setTest2");        strlist.add("setTest3");        System.out.println(template.opsForSet().intersect("setTest",strlist));结果：[aaa, ccc][aaa][ccc, aaa][aaa]

--------------------------------------------------------------------------------------------------------------- Long intersectAndStore(K key, K otherKey, K destKey); key无序集合与otherkey无序集合的交集存储到destKey无序集合中

使用：System.out.println("setTest:" + template.opsForSet().members("setTest"));System.out.println("setTest2:" + template.opsForSet().members("setTest2"));System.out.println(template.opsForSet().intersectAndStore("setTest","setTest2","destKey1"));System.out.println(template.opsForSet().members("destKey1"));结果：setTest:[ddd, bbb, aaa, ccc]setTest2:[ccc, aaa]2[aaa, ccc] --------------------------------------------------------------------------------------------------------------- Long intersectAndStore(K key, Collection
     
       otherKeys, K destKey); key对应的无序集合与多个otherKey对应的无序集合求交集存储到destKey无序集合中

使用：System.out.println("setTest:" + template.opsForSet().members("setTest"));      System.out.println("setTest2:" + template.opsForSet().members("setTest2"));      System.out.println("setTest3:" + template.opsForSet().members("setTest3"));      List
     
       strlist = new ArrayList
      
       ();      strlist.add("setTest2");      strlist.add("setTest3");      System.out.println(template.opsForSet().intersectAndStore("setTest",strlist,"destKey2"));      System.out.println(template.opsForSet().members("destKey2"));结果：setTest:[ddd, bbb, aaa, ccc]setTest2:[ccc, aaa]setTest3:[ccc, aaa]2[aaa, ccc]

--------------------------------------------------------------------------------------------------------------- Long unionAndStore(K key, K otherKey, K destKey); key无序集合与otherkey无序集合的并集存储到destKey无序集合中

使用：System.out.println("setTest:" + template.opsForSet().members("setTest"));      System.out.println("setTest2:" + template.opsForSet().members("setTest2"));      System.out.println(template.opsForSet().unionAndStore("setTest","setTest2","unionAndStoreTest1"));      System.out.println("unionAndStoreTest1:" + template.opsForSet().members("unionAndStoreTest1"));结果：setTest:[ddd, bbb, aaa, ccc]setTest2:[ccc, aaa]4unionAndStoreTest1:[ccc, aaa, ddd, bbb]

--------------------------------------------------------------------------------------------------------------- Long unionAndStore(K key, Collection
     
       otherKeys, K destKey); key无序集合与多个otherkey无序集合的并集存储到destKey无序集合中

使用：System.out.println("setTest:" + template.opsForSet().members("setTest"));      System.out.println("setTest2:" + template.opsForSet().members("setTest2"));      System.out.println("setTest3:" + template.opsForSet().members("setTest3"));      List
     
       strlist = new ArrayList
      
       ();      strlist.add("setTest2");      strlist.add("setTest3");      System.out.println(template.opsForSet().unionAndStore("setTest",strlist,"unionAndStoreTest2"));      System.out.println("unionAndStoreTest2:" + template.opsForSet().members("unionAndStoreTest2"));结果：setTest:[ddd, bbb, aaa, ccc]setTest2:[ccc, aaa]setTest3:[xxx, ccc, aaa]5unionAndStoreTest2:[ddd, xxx, bbb, aaa, ccc]

--------------------------------------------------------------------------------------------------------------- Set
     
       difference(K key, K otherKey); key无序集合与otherKey无序集合的差集

使用：System.out.println("setTest:" + template.opsForSet().members("setTest"));      System.out.println("setTest2:" + template.opsForSet().members("setTest2"));      System.out.println(template.opsForSet().difference("setTest","setTest2"));结果：setTest:[ddd, bbb, aaa, ccc]setTest2:[ccc, aaa][bbb, ddd]

--------------------------------------------------------------------------------------------------------------- Set
     
       difference(K key, Collection
      
        otherKeys); key无序集合与多个otherKey无序集合的差集

使用：System.out.println("setTest:" + template.opsForSet().members("setTest"));      System.out.println("setTest2:" + template.opsForSet().members("setTest2"));      System.out.println("setTest3:" + template.opsForSet().members("setTest3"));      List
     
       strlist = new ArrayList
      
       ();      strlist.add("setTest2");      strlist.add("setTest3");      System.out.println(template.opsForSet().difference("setTest",strlist));结果：setTest:[ddd, bbb, aaa, ccc]setTest2:[ccc, aaa]setTest3:[xxx, ccc, aaa][bbb, ddd]

--------------------------------------------------------------------------------------------------------------- Long differenceAndStore(K key, K otherKey, K destKey); key无序集合与otherkey无序集合的差集存储到destKey无序集合中

使用：System.out.println("setTest:" + template.opsForSet().members("setTest"));      System.out.println("setTest2:" + template.opsForSet().members("setTest2"));      System.out.println(template.opsForSet().differenceAndStore("setTest","setTest2","differenceAndStore1"));      System.out.println("differenceAndStore1:" + template.opsForSet().members("differenceAndStore1"));结果：setTest:[ddd, bbb, aaa, ccc]setTest2:[ccc, aaa]2differenceAndStore1:[bbb, ddd]

--------------------------------------------------------------------------------------------------------------- Long differenceAndStore(K key, Collection
     
       otherKeys, K destKey); key无序集合与多个otherkey无序集合的差集存储到destKey无序集合中

使用：System.out.println("setTest:" + template.opsForSet().members("setTest"));      System.out.println("setTest2:" + template.opsForSet().members("setTest2"));      System.out.println("setTest3:" + template.opsForSet().members("setTest3"));      List
     
       strlist = new ArrayList
      
       ();      strlist.add("setTest2");      strlist.add("setTest3");      System.out.println(template.opsForSet().differenceAndStore("setTest",strlist,"differenceAndStore2"));      System.out.println("differenceAndStore2:" + template.opsForSet().members("differenceAndStore2"));结果：setTest:[ddd, bbb, aaa, ccc]setTest2:[ccc, aaa]setTest3:[xxx, ccc, aaa]2differenceAndStore2:[bbb, ddd]

--------------------------------------------------------------------------------------------------------------- Set
     
       members(K key);

返回集合中的所有成员

使用：System.out.println(template.opsForSet().members("setTest"));结果：[ddd, bbb, aaa, ccc]

--------------------------------------------------------------------------------------------------------------- V randomMember(K key); 随机获取key无序集合中的一个元素

使用：System.out.println("setTest:" + template.opsForSet().members("setTest"));      System.out.println("setTestrandomMember:" + template.opsForSet().randomMember("setTest"));      System.out.println("setTestrandomMember:" + template.opsForSet().randomMember("setTest"));      System.out.println("setTestrandomMember:" + template.opsForSet().randomMember("setTest"));      System.out.println("setTestrandomMember:" + template.opsForSet().randomMember("setTest"));结果：setTest:[ddd, bbb, aaa, ccc]setTestrandomMember:aaasetTestrandomMember:bbbsetTestrandomMember:aaasetTestrandomMember:ddd

--------------------------------------------------------------------------------------------------------------- Set
     
       distinctRandomMembers(K key, long count);

获取多个key无序集合中的元素（去重），count表示个数

使用：System.out.println("randomMembers:" + template.opsForSet().distinctRandomMembers("setTest",5)); 结果：randomMembers:[aaa, bbb, ddd, ccc]

---------------------------------------------------------------------------------------------------------------

List
     
       randomMembers(K key, long count); 获取多个key无序集合中的元素，count表示个数

使用：System.out.println("randomMembers:" + template.opsForSet().randomMembers("setTest",5));结果：randomMembers:[ccc, ddd, ddd, ddd, aaa]

---------------------------------------------------------------------------------------------------------------

Cursor
     
       scan(K key, ScanOptions options); 遍历set

使用：    Cursor

Redis的ZSet数据结构

Redis有序集合和无序集合一样也是string类型元素的集合,且不允许重复的成员。 不同的是每个元素都会关联一个double类型的分数。redis正是通过分数来为集合中的成员进行从小到大的排序。 有序集合的成员是唯一的,但分数(score)却可以重复。

public interface ZSetOperations<K,V>

ZSetOperations提供了一系列方法对有序集合进行操作：

Boolean add(K key, V value, double score);
新增一个有序集合，存在的话为false，不存在的话为true
```
使用：System.out.println(template.opsForZSet().add("zset1","zset-1",1.0));结果：true
```

Long add(K key, Set<TypedTuple<V>> tuples);

新增一个有序集合

使用：ZSetOperations.TypedTuple

Long remove(K key, Object... values);

从有序集合中移除一个或者多个元素

使用：System.out.println(template.opsForZSet().range("zset1",0,-1));      System.out.println(template.opsForZSet().remove("zset1","zset-6"));      System.out.println(template.opsForZSet().range("zset1",0,-1));结果：[zset-1, zset-2, zset-3, zset-4, zset-5, zset-6]1[zset-1, zset-2, zset-3, zset-4, zset-5]

Double incrementScore(K key, V value, double delta);

增加元素的score值，并返回增加后的值

使用：System.out.println(template.opsForZSet().incrementScore("zset1","zset-1",1.1));  //原为1.1结果：2.2

Long rank(K key, Object o);

返回有序集中指定成员的排名，其中有序集成员按分数值递增(从小到大)顺序排列

使用：System.out.println(template.opsForZSet().range("zset1",0,-1));      System.out.println(template.opsForZSet().rank("zset1","zset-2"));结果：[zset-2, zset-1, zset-3, zset-4, zset-5]0   //表明排名第一

Long reverseRank(K key, Object o);

返回有序集中指定成员的排名，其中有序集成员按分数值递减(从大到小)顺序排列

使用：System.out.println(template.opsForZSet().range("zset1",0,-1));      System.out.println(template.opsForZSet().reverseRank("zset1","zset-2"));结果：[zset-2, zset-1, zset-3, zset-4, zset-5]4 //递减之后排到第五位去了

Set<V> range(K key, long start, long end);
通过索引区间返回有序集合成指定区间内的成员，其中有序集成员按分数值递增(从小到大)顺序排列
```
使用：System.out.println(template.opsForZSet().range("zset1",0,-1));结果：[zset-2, zset-1, zset-3, zset-4, zset-5]
```

Set<TypedTuple<V>> rangeWithScores(K key, long start, long end);

通过索引区间返回有序集合成指定区间内的成员对象，其中有序集成员按分数值递增(从小到大)顺序排列

使用：Set

Set<V> rangeByScore(K key, double min, double max);
通过分数返回有序集合指定区间内的成员，其中有序集成员按分数值递增(从小到大)顺序排列
```
使用：System.out.println(template.opsForZSet().rangeByScore("zset1",0,5));结果：[zset-2, zset-1, zset-3]
```

Set<TypedTuple<V>> rangeByScoreWithScores(K key, double min, double max);

通过分数返回有序集合指定区间内的成员对象，其中有序集成员按分数值递增(从小到大)顺序排列

使用：Set

Set<V> rangeByScore(K key, double min, double max, long offset, long count);
通过分数返回有序集合指定区间内的成员，并在索引范围内，其中有序集成员按分数值递增(从小到大)顺序排列
```
使用：    System.out.println(template.opsForZSet().rangeByScore("zset1",0,5));  System.out.println(template.opsForZSet().rangeByScore("zset1",0,5,1,2));结果：[zset-2, zset-1, zset-3][zset-1, zset-3]
```

Set<TypedTuple<V>> rangeByScoreWithScores(K key, double min, double max, long offset, long count);

通过分数返回有序集合指定区间内的成员对象，并在索引范围内，其中有序集成员按分数值递增(从小到大)顺序排列

使用：Set

Set<V> reverseRange(K key, long start, long end);
通过索引区间返回有序集合成指定区间内的成员，其中有序集成员按分数值递减(从大到小)顺序排列
```
使用：System.out.println(template.opsForZSet().reverseRange("zset1",0,-1));结果：[zset-5, zset-4, zset-3, zset-1, zset-2]
```

Set<TypedTuple<V>> reverseRangeWithScores(K key, long start, long end);

通过索引区间返回有序集合成指定区间内的成员对象，其中有序集成员按分数值递减(从大到小)顺序排列

使用：Set

Set<V> reverseRangeByScore(K key, double min, double max);

使用：与rangeByScore调用方法一样，其中有序集成员按分数值递减(从大到小)顺序排列

Set<TypedTuple<V>> reverseRangeByScoreWithScores(K key, double min, double max);

使用：与rangeByScoreWithScores调用方法一样，其中有序集成员按分数值递减(从大到小)顺序排列

Set<V> reverseRangeByScore(K key, double min, double max, long offset, long count);

使用：与rangeByScore调用方法一样，其中有序集成员按分数值递减(从大到小)顺序排列

Set<TypedTuple<V>> reverseRangeByScoreWithScores(K key, double min, double max, long offset, long count);

使用：与rangeByScoreWithScores调用方法一样，其中有序集成员按分数值递减(从大到小)顺序排列

Long count(K key, double min, double max);

通过分数返回有序集合指定区间内的成员个数

使用：System.out.println(template.opsForZSet().rangeByScore("zset1",0,5));      System.out.println(template.opsForZSet().count("zset1",0,5));结果：[zset-2, zset-1, zset-3]3

Long size(K key);
获取有序集合的成员数，内部调用的就是zCard方法
```
使用：System.out.println(template.opsForZSet().size("zset1"));结果：6
```

Long zCard(K key);

获取有序集合的成员数

使用：System.out.println(template.opsForZSet().zCard("zset1"));结果：6

Double score(K key, Object o);

获取指定成员的score值

使用：System.out.println(template.opsForZSet().score("zset1","zset-1"));结果：2.2

Long removeRange(K key, long start, long end);

移除指定索引位置的成员，其中有序集成员按分数值递增(从小到大)顺序排列

使用：System.out.println(template.opsForZSet().range("zset2",0,-1));      System.out.println(template.opsForZSet().removeRange("zset2",1,2));      System.out.println(template.opsForZSet().range("zset2",0,-1));结果：[zset-1, zset-2, zset-3, zset-4]2[zset-1, zset-4]

Long removeRangeByScore(K key, double min, double max);

根据指定的score值得范围来移除成员

使用：//System.out.println(template.opsForZSet().add("zset2","zset-1",1.1));      //System.out.println(template.opsForZSet().add("zset2","zset-2",1.2));      //System.out.println(template.opsForZSet().add("zset2","zset-3",2.3));      //System.out.println(template.opsForZSet().add("zset2","zset-4",6.6));System.out.println(template.opsForZSet().range("zset2",0,-1));System.out.println(template.opsForZSet().removeRangeByScore("zset2",2,3));  System.out.println(template.opsForZSet().range("zset2",0,-1));结果：[zset-1, zset-2, zset-3,zset-4]1[zset-1, zset-2, zset-4]

Long unionAndStore(K key, K otherKey, K destKey);

计算给定的一个有序集的并集，并存储在新的 destKey中，key相同的话会把score值相加

使用：System.out.println(template.opsForZSet().add("zzset1","zset-1",1.0));      System.out.println(template.opsForZSet().add("zzset1","zset-2",2.0));      System.out.println(template.opsForZSet().add("zzset1","zset-3",3.0));      System.out.println(template.opsForZSet().add("zzset1","zset-4",6.0));      System.out.println(template.opsForZSet().add("zzset2","zset-1",1.0));      System.out.println(template.opsForZSet().add("zzset2","zset-2",2.0));      System.out.println(template.opsForZSet().add("zzset2","zset-3",3.0));      System.out.println(template.opsForZSet().add("zzset2","zset-4",6.0));      System.out.println(template.opsForZSet().add("zzset2","zset-5",7.0));      System.out.println(template.opsForZSet().unionAndStore("zzset1","zzset2","destZset11"));      Set

Long unionAndStore(K key, Collection<K> otherKeys, K destKey);

计算给定的多个有序集的并集，并存储在新的 destKey中

使用：//System.out.println(template.opsForZSet().add("zzset1","zset-1",1.0));      //System.out.println(template.opsForZSet().add("zzset1","zset-2",2.0));      //System.out.println(template.opsForZSet().add("zzset1","zset-3",3.0));      //System.out.println(template.opsForZSet().add("zzset1","zset-4",6.0));      //      //System.out.println(template.opsForZSet().add("zzset2","zset-1",1.0));      //System.out.println(template.opsForZSet().add("zzset2","zset-2",2.0));      //System.out.println(template.opsForZSet().add("zzset2","zset-3",3.0));      //System.out.println(template.opsForZSet().add("zzset2","zset-4",6.0));      //System.out.println(template.opsForZSet().add("zzset2","zset-5",7.0));      System.out.println(template.opsForZSet().add("zzset3","zset-1",1.0));      System.out.println(template.opsForZSet().add("zzset3","zset-2",2.0));      System.out.println(template.opsForZSet().add("zzset3","zset-3",3.0));      System.out.println(template.opsForZSet().add("zzset3","zset-4",6.0));      System.out.println(template.opsForZSet().add("zzset3","zset-5",7.0));      List
       
         stringList = new ArrayList
        
         ();      stringList.add("zzset2");      stringList.add("zzset3");      System.out.println(template.opsForZSet().unionAndStore("zzset1",stringList,"destZset22"));      Set

Long intersectAndStore(K key, K otherKey, K destKey);

计算给定的一个或多个有序集的交集并将结果集存储在新的有序集合 key 中

使用：System.out.println(template.opsForZSet().intersectAndStore("zzset1","zzset2","destZset33"));      Set

Long intersectAndStore(K key, Collection<K> otherKeys, K destKey);

计算给定的一个或多个有序集的交集并将结果集存储在新的有序集合 key 中

使用：List
       
         stringList = new ArrayList
        
         ();      stringList.add("zzset2");      stringList.add("zzset3");      System.out.println(template.opsForZSet().intersectAndStore("zzset1",stringList,"destZset44"));      Set

Cursor<TypedTuple<V>> scan(K key, ScanOptions options);

遍历zset

使用：    Cursor

注：TimeUnit是java.util.concurrent包下面的一个类，表示给定单元粒度的时间段

常用的颗粒度

TimeUnit.DAYS //天TimeUnit.HOURS //小时TimeUnit.MINUTES //分钟TimeUnit.SECONDS //秒TimeUnit.MILLISECONDS //毫秒

转载于:https://www.cnblogs.com/matd/p/11049581.html

你可能感兴趣的文章

iOS计算富文本(NSMutableAttributedString)高度

gulp-rev-append md5版本号

CF717A Festival Organization（第一类斯特林数，斐波那契数列）

查看>>

oracle直接读写ms sqlserver数据库（二）配置透明网关

查看>>

控件发布：div2dropdownlist(div模拟dropdownlist控件)

查看>>

Oracle composite index column ordering

查看>>

ActiveReports 报表控件官方中文入门教程 (3)-如何选择页面报表和区域报表

南海区行政审批管理系统接口规范v0.3（规划）4.2.【queryExpireList】当天到期业务查询...

查看>>

Redis 数据结构简介

RedisTemplate介绍

RedisTemplate在Spring代码中的结构如下：

RedisTemplate中定义了对5种数据结构操作

StringRedisTemplate与RedisTemplate

RedisConf配置如下：

RedisTemplate配置如下：

Redis的String数据结构 （推荐使用StringRedisTemplate）

Redis的List数据结构

Redis的Hash数据机构

Redis的Set数据结构

Redis的ZSet数据结构

Redis的String数据结构（推荐使用StringRedisTemplate）