SpringBoot使用RedisTemplate操作Redis的5种数据类型

待我称王封你为后i 2022-12-11 10:29 521阅读 0赞

Spring 封装了 RedisTemplate 来操作 Redis，它支持所有的 Redis 原生的 API。在 RedisTemplate 中定义了对5种数据结构的操作方法。

*  opsForValue()：操作字符串。
 *  opsForList()：操作列表。
 *  opsForHash()：操作哈希。
 *  opsForSet()：操作集合。
 *  opsForZSet()：操作有序集合。

下面通过实例来理解和应用这些方法。这里需要特别注意的是，运行上述方法后要对数据进行清空操作，否则多次运行会导致数据重复操作。

**（1）使用Maven添加依赖文件**

在pom.xml配置信息文件中，添加Redis依赖：

我的SpringBoot版本：

<parent>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-parent</artifactId>
        <version>2.3.4.RELEASE</version>
        <relativePath/> 
    </parent>

添加Redis依赖：

<dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-data-redis</artifactId>
        <version>2.3.3.RELEASE</version>
    </dependency>

**（2）Redis的配置**

在 application.yml 配置文件中配置Redis信息：

#Spring配置
    spring:
      #缓存管理器
      cache:
        type: redis
      #Redis配置
      redis:
        database: 0 #Redis数据库索引（默认为0）
        host: 127.0.0.1 #Redis服务器地址
        port: 6379 #Redis服务器连接端口
        password:  #Redis服务器连接密码（默认为空）
        jedis:
          pool:
            max-active: 8 #连接池最大连接数（使用负值表示没有限制）
            max-wait: -1s #连接池最大阻塞等待时间（使用负值表示没有限制）
            max-idle: 8  #连接池中的最大空闲连接
            min-idle: 0 #连接池中的最小空闲连接
        lettuce:
          shutdown-timeout: 100ms #关闭超时时间，默认值100ms

**（3）Redis配置类（config层）**

创建com.pjb.config包中，并创建RedisConfig类（Redis配置类），并继承CachingConfigurerSupport类。

package com.pjb.config;
    
    import com.fasterxml.jackson.annotation.JsonAutoDetect;
    import com.fasterxml.jackson.annotation.PropertyAccessor;
    import com.fasterxml.jackson.databind.ObjectMapper;
    import org.springframework.cache.CacheManager;
    import org.springframework.cache.annotation.CachingConfigurerSupport;
    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.RedisConnectionFactory;
    import org.springframework.data.redis.core.RedisTemplate;
    import org.springframework.data.redis.core.StringRedisTemplate;
    import org.springframework.data.redis.serializer.Jackson2JsonRedisSerializer;
    
    import java.lang.reflect.Method;
    
    /**
     * Redis配置类
     * @author pan_junbiao
     **/
    @Configuration
    public class RedisConfig extends CachingConfigurerSupport
    {
        /**
         * 缓存对象集合中，缓存是以key-value形式保存的,
         * 当不指定缓存的key时，SpringBoot会使用keyGenerator生成Key。
         */
        @Bean
        public KeyGenerator keyGenerator()
        {
            return new KeyGenerator()
            {
                @Override
                public Object generate(Object target, Method method, Object... params) {
                    StringBuilder sb = new StringBuilder();
                    //类名+方法名
                    sb.append(target.getClass().getName());
                    sb.append(method.getName());
                    for (Object obj : params) {
                        sb.append(obj.toString());
                    }
                    return sb.toString();
                }
            };
        }
    
        /**
         * 缓存管理器
         */
        @SuppressWarnings("rawtypes")
        @Bean
        public CacheManager cacheManager(RedisConnectionFactory connectionFactory)
        {
            RedisCacheManager cacheManager = RedisCacheManager.create(connectionFactory);
            //设置缓存过期时间
    
            return cacheManager;
        }
    
        /**
         * 实例化RedisTemplate对象
         */
        @Bean
        public RedisTemplate<String, String> redisTemplate(RedisConnectionFactory factory)
        {
            StringRedisTemplate template = new StringRedisTemplate(factory);
            Jackson2JsonRedisSerializer jackson2JsonRedisSerializer = new Jackson2JsonRedisSerializer(Object.class);
            ObjectMapper om = new ObjectMapper();
            om.setVisibility(PropertyAccessor.ALL, JsonAutoDetect.Visibility.ANY);
            om.enableDefaultTyping(ObjectMapper.DefaultTyping.NON_FINAL);
            jackson2JsonRedisSerializer.setObjectMapper(om);
            template.setValueSerializer(jackson2JsonRedisSerializer);
            template.afterPropertiesSet();
            return template;
        }
    }

# 1、字符串（String） #

字符串（String）是 Redis 最基本的数据类型。String 的一个“Key”对应一个“Value”，即 Key-Value 键值对。String 是二进制安全的，可以存储任何数据（比如图片或序列化的对象）。值最大能存储512MB的数据。一般用于一些复杂的计数功能的缓存。RedisTemplate 提供以下操作 String 的方法。

## 1.1 void set(K key, V value)；V get(Object key) ##

具体用法见以下代码：

/**
     * Redis操作字符串（String）
     * @author pan_junbiao
     **/
    @SpringBootTest
    public class StringTest
    {
        @Autowired
        private RedisTemplate redisTemplate;
        
        @Test
        public void string1()
        {
            redisTemplate.opsForValue().set("userName","pan_junbiao的博客");
            redisTemplate.opsForValue().set("blogUrl","https://blog.csdn.net/pan_junbiao");
            redisTemplate.opsForValue().set("blogRemark","您好，欢迎访问 pan_junbiao的博客");
            System.out.println("用户名称：" + redisTemplate.opsForValue().get("userName"));
            System.out.println("博客地址：" + redisTemplate.opsForValue().get("blogUrl"));
            System.out.println("博客信息：" + redisTemplate.opsForValue().get("blogRemark"));
        }
    }

**执行结果：**

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3Bhbl9qdW5iaWFv_size_16_color_FFFFFF_t_70][]

## 1.2 void set(K key, V value, long timeout, TimeUnit unit) ##

以下代码设置3s失效。3s之内查询有结果，3s之后查询返回为null。具体用法见以下代码：

@Autowired
    private RedisTemplate redisTemplate;
    
    @Test
    public void string2()
    {
        //设置的是3s失效，3s之内查询有结果，3s之后返回null
        redisTemplate.opsForValue().set("blogRemark","您好，欢迎访问 pan_junbiao的博客",3, TimeUnit.SECONDS);
        try
        {
            Object s1 = redisTemplate.opsForValue().get("blogRemark");
            System.out.println("博客信息：" + s1);
            Thread.currentThread().sleep(2000);
    
            Object s2 = redisTemplate.opsForValue().get("blogRemark");
            System.out.println("博客信息：" + s2);
            Thread.currentThread().sleep(5000);
    
            Object s3 = redisTemplate.opsForValue().get("blogRemark");
            System.out.println("博客信息：" + s3);
        }
        catch (InterruptedException ie)
        {
            ie.printStackTrace();
        }
    }

**执行结果：**

![20200930114151959.jpg][]

## 1.3 V getAndSet(K key, V value) ##

设置键的字符串，并返回其旧值。具体用法见以下代码：

@Autowired
    private RedisTemplate redisTemplate;
    
    @Test
    public void string3()
    {
        //设置键的字符串并返回其旧值
        redisTemplate.opsForValue().set("blogRemark","pan_junbiao的博客");
        Object oldVaule = redisTemplate.opsForValue().getAndSet("blogRemark","您好，欢迎访问 pan_junbiao的博客");
        Object newVaule = redisTemplate.opsForValue().get("blogRemark");
        System.out.println("旧值：" + oldVaule);
        System.out.println("新值：" + newVaule);
    }

**执行结果：**

![20200930120416951.jpg][]

## 1.4 Integer append(K key, V value) ##

如果key已经存在，并且是一个字符串，则该命令将该值追加到字符串的末尾。如果key不存在，则它将被创建并设置为空字符串，因此 append 在这种特殊情况下类似于 set。具体用法见以下代码：

@Autowired
    private RedisTemplate redisTemplate;
    
    @Test
    public void string4()
    {
        //设置value的序列化规则，否则会报错
        redisTemplate.setValueSerializer(new StringRedisSerializer());
    
        redisTemplate.opsForValue().append("blogRemark","您好，欢迎访问 ");
        System.out.println(redisTemplate.opsForValue().get("blogRemark"));
        redisTemplate.opsForValue().append("blogRemark","pan_junbiao的博客");
        System.out.println(redisTemplate.opsForValue().get("blogRemark"));
    }

**执行结果：**

![20200930162722711.jpg][]

> **注意：**这里一定要注意反序列化配置，否则会报错。

## 1.5 Long size(K key) ##

返回key所对应的value值的长度，见以下代码：

@Autowired
    private RedisTemplate redisTemplate;
    
    @Test
    public void string5()
    {
        redisTemplate.opsForValue().set("userName","pan_junbiao的博客");
        System.out.println("Value值：" + redisTemplate.opsForValue().get("userName"));
        System.out.println("Value值的长度：" + redisTemplate.opsForValue().size("userName"));
    }

**执行结果：**

![20200930164130803.jpg][]

# 2、列表（List） #

Redis列表是简单的字符串列表，按照插入顺序排序。可以添加一个元素到列表的头部（左边）或尾部（右边）。

使用list数据结果，可以做简单的消息队列的功能。还可以利用 Irange 命令，做基于Reids的分页功能，性能极佳。

## 2.1 Long leftPushAll(K key, V... values)；Long rightPushAll(K key, V... values) ##

leftPushAll方法：表示把一个数组插入列表中。

rightPushAll方法：表示向列表的最右边批量添加元素。具体用法见以下代码：

/**
     * Redis操作列表（List）
     * @author pan_junbiao
     **/
    @SpringBootTest
    public class ListTest
    {
        @Autowired
        private RedisTemplate redisTemplate;
    
        @Test
        public void list1()
        {
            String[] user1 = new String[]{"1","pan_junbiao的博客","您好，欢迎访问 pan_junbiao的博客"};
            String[] user2 = new String[]{"2","pan_junbiao的博客","https://blog.csdn.net/pan_junbiao"};
            String[] user3 = new String[]{"3","pan_junbiao的博客","您好，欢迎访问 pan_junbiao的博客"};
    
            redisTemplate.opsForList().rightPushAll("user1",user1);
            redisTemplate.opsForList().rightPushAll("user2",user2);
            redisTemplate.opsForList().rightPushAll("user3",user3);
    
            System.out.println(redisTemplate.opsForList().range("user1",0,-1));
            System.out.println(redisTemplate.opsForList().range("user2",0,-1));
            System.out.println(redisTemplate.opsForList().range("user3",0,-1));
        }
    }

**执行结果：**

![2020093017271483.jpg][]

## 2.2 Long leftPush(K key, V value)；Long rightPush(K key, V value) ##

leftPush方法：将所有指定的值插入在键的列表的头部。如果键不存在，则在执行推送操作之前将其创建为空列表（从左边插入）。

rightPush方法：将所有指定的值插入在键的列表的尾部。如果键不存在，则在执行推送操作之前将其创建为空列表（从右边插入）。具体用法见以下代码：

@Autowired
    private RedisTemplate redisTemplate;
    
    @Test
    public void list2()
    {
        redisTemplate.opsForList().rightPush("userInfo",1);
        redisTemplate.opsForList().rightPush("userInfo","pan_junbiao的博客");
        redisTemplate.opsForList().rightPush("userInfo","https://blog.csdn.net/pan_junbiao");
        redisTemplate.opsForList().rightPush("userInfo","您好，欢迎访问 pan_junbiao的博客");
    
        System.out.println("用户编号：" + redisTemplate.opsForList().index("userInfo",0));
        System.out.println("用户名称：" + redisTemplate.opsForList().index("userInfo",1));
        System.out.println("博客地址：" + redisTemplate.opsForList().index("userInfo",2));
        System.out.println("博客信息：" + redisTemplate.opsForList().index("userInfo",3));
    }

**执行结果：**

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3Bhbl9qdW5iaWFv_size_16_color_FFFFFF_t_70 1][]

## 2.3 Long size(K key) ##

返回存储在键中的列表的长度。如果键不存在，则将其解释为空列表，并返回0。如果key存在的值不是列表，则返回错误。具体用法见以下代码：

@Autowired
    private RedisTemplate redisTemplate;
    
    @Test
    public void list3()
    {
        String[] user = new String[]{"1","pan_junbiao的博客","您好，欢迎访问 pan_junbiao的博客"};
        redisTemplate.opsForList().leftPushAll("user",user);
        System.out.println("列表的长度：" + redisTemplate.opsForList().size("user"));
    }

**执行结果：**

![20200930175036276.jpg][]

## 2.4 void set(K key, long index, V value) ##

在列表中 index 的位置设置 value。具体用法见以下代码：

@Autowired
    private RedisTemplate redisTemplate;
    
    @Test
    public void list4()
    {
        String[] user = new String[]{"1","pan_junbiao的博客","https://blog.csdn.net/pan_junbiao"};
        redisTemplate.opsForList().rightPushAll("user",user);
        System.out.println(redisTemplate.opsForList().range("user",0,-1));
    
        redisTemplate.opsForList().set("user",2,"您好，欢迎访问 pan_junbiao的博客");
        System.out.println(redisTemplate.opsForList().range("user",0,-1));
    }

**执行结果：**

![20200930181502752.jpg][]

## 2.5 V index(K key, long index) ##

根据下标获取列表中的值（下标从0开始）。具体用法见以下代码：

**执行结果：**

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3Bhbl9qdW5iaWFv_size_16_color_FFFFFF_t_70 2][]

## 2.6 Long remove(K key, long count, Object value) ##

从存储在键中的列表，删除给定“count”值的元素的第1个计数事件。其中，参数count的含义如下：

*  count=0：删除等于value的所有元素。
 *  count>0：删除等于从头到尾移动的值的元素。
 *  count<0：删除等于从尾到头移动的值的元素。

以下代码用于删除列表中第一次出现的值：

@Autowired
    private RedisTemplate redisTemplate;
    
    @Test
    public void list5()
    {
        String[] user = new String[]{"1","pan_junbiao的博客","您好，欢迎访问 pan_junbiao的博客"};
        redisTemplate.opsForList().rightPushAll("user",user);
        System.out.println(redisTemplate.opsForList().range("user",0,-1));
    
        //将删除列表中第一次出现的pan_junbiao的博客
        redisTemplate.opsForList().remove("user",1,"pan_junbiao的博客");
        System.out.println(redisTemplate.opsForList().range("user",0,-1));
    }

**执行结果：**

![20200930183043381.jpg][]

## 2.7 V leftPop(K key)；V rightPop(K key) ##

leftPop方法：弹出最左边的元素，弹出之后该值在列表中将不复存在。

rightPop方法：弹出最右边的元素，弹出之后该值在列表中将不复存在。具体用法见以下代码：

@Autowired
    private RedisTemplate redisTemplate;
    
    @Test
    public void list6()
    {
        String[] user = new String[]{"1","pan_junbiao的博客","您好，欢迎访问 pan_junbiao的博客"};
        redisTemplate.opsForList().rightPushAll("user",user);
        System.out.println(redisTemplate.opsForList().range("user",0,-1));
        //弹出最右边的元素，弹出之后该值在列表中将不复存在
        System.out.println(redisTemplate.opsForList().rightPop("user"));
        System.out.println(redisTemplate.opsForList().range("user",0,-1));
    }

**执行结果：**

![20200930184422139.jpg][]

# 3、哈希（Hash） #

Redis 中的 hash（哈希）是一个 string 类型的 field 和 value 的映射表，hash 特别适合用于存储对象。value 中存放的是结构化的对象。利用这样数据结果，可以方便地操作其中的某个字段。比如在“单点登录”时，可以用这种数据结构存储用户信息。以 CookieId 作为 key，设置30分钟为缓存过期时间，能很好地模拟出类似 Session 的效果。

## 3.1 void putAll(H key, Map<? extends HK, ? extends HV> m)；Map<HK, HV> entries(H key) ##

putAll方法：用 m 中提供的多个散列字段设置到 key 对应的散列表中。

entries方法：根据密钥获取整个散列存储。具体用法见以下代码：

/**
     * Redis操作哈希（Hash）
     * @author pan_junbiao
     **/
    @SpringBootTest
    public class HashTest
    {
        @Autowired
        private RedisTemplate redisTemplate;
    
        @Test
        public void hash1()
        {
            Map<String,Object> userMap = new HashMap<>();
            userMap.put("userName","pan_junbiao的博客");
            userMap.put("blogRemark","您好，欢迎访问 pan_junbiao的博客");
            redisTemplate.opsForHash().putAll("userHash",userMap);
            System.out.println(redisTemplate.opsForHash().entries("userHash"));
        }
    }

**执行结果：**

![20201001105402511.jpg][]

## 3.2 void put(H key, HK hashKey, HV value)；HV get(H key, Object hashKey) ##

put方法：设置 hashKey 的值。

get方法：从键中的散列获取给定 hashKey 的值。具体用法见以下代码：

@Autowired
    private RedisTemplate redisTemplate;
    
    @Test
    public void hash2()
    {
        redisTemplate.opsForHash().put("userHash","userName","pan_junbiao的博客");
        redisTemplate.opsForHash().put("userHash","blogUrl","https://blog.csdn.net/pan_junbiao");
        redisTemplate.opsForHash().put("userHash","blogRemark","您好，欢迎访问 pan_junbiao的博客");
        System.out.println("用户名称：" + redisTemplate.opsForHash().get("userHash","userName"));
        System.out.println("博客地址：" + redisTemplate.opsForHash().get("userHash","blogUrl"));
        System.out.println("博客信息：" + redisTemplate.opsForHash().get("userHash","blogRemark"));
    }

**执行结果：**

![20201001110835780.jpg][]

## 3.3 List<HV> values(H key)；Set<HK> keys(H key) ##

values方法：根据密钥获取整个散列存储的值。

keys方法：根据密钥获取整个散列存储的键。具体用法见以下代码：

@Autowired
    private RedisTemplate redisTemplate;
    
    @Test
    public void hash3()
    {
        redisTemplate.opsForHash().put("userHash","userName","pan_junbiao的博客");
        redisTemplate.opsForHash().put("userHash","blogRemark","您好，欢迎访问 pan_junbiao的博客");
        System.out.println("散列存储的值：" + redisTemplate.opsForHash().values("userHash"));
        System.out.println("散列存储的键：" + redisTemplate.opsForHash().keys("userHash"));
    }

**执行结果：**

![20201001112754503.jpg][]

## 3.4 Boolean hasKey(H key, Object hashKey)；Long size(H key) ##

hasKey方法：确定 hashKey 是否存在。

size方法：获取 key 所对应的散列表的大小个数。具体用法见以下代码：

@Autowired
    private RedisTemplate redisTemplate;
    
    @Test
    public void hash4()
    {
        redisTemplate.opsForHash().put("userHash","userName","pan_junbiao的博客");
        redisTemplate.opsForHash().put("userHash","blogUrl","https://blog.csdn.net/pan_junbiao");
        redisTemplate.opsForHash().put("userHash","blogRemark","您好，欢迎访问 pan_junbiao的博客");
        System.out.println(redisTemplate.opsForHash().hasKey("userHash","userName"));
        System.out.println(redisTemplate.opsForHash().hasKey("userHash","age"));
        System.out.println(redisTemplate.opsForHash().size("userHash"));
    }

**执行结果：**

![20201001114216176.jpg][]

## 3.5 Long delete(H key, Object... hashKeys) ##

删除给定的 hashKeys。具体用法见以下代码：

@Autowired
    private RedisTemplate redisTemplate;
    
    @Test
    public void hash5()
    {
        redisTemplate.opsForHash().put("userHash","userName","pan_junbiao的博客");
        redisTemplate.opsForHash().put("userHash","blogRemark","您好，欢迎访问 pan_junbiao的博客");
        System.out.println(redisTemplate.opsForHash().delete("userHash","blogRemark"));
        System.out.println(redisTemplate.opsForHash().entries("userHash"));
    }

**执行结果：**

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3Bhbl9qdW5iaWFv_size_16_color_FFFFFF_t_70 3][]

# 4、集合（Set） #

set 是存放不重复值的集合。利用 set 可以做全局去重复的功能。还可以进行交集、并集、差集等操作，也可用来实现计算共同喜好、全部的喜好、自己独有的喜好等功能。

Redis 的 set 是 string 类型的无序集合，通过散列表实现。

## 4.1 Long add(K key, V... values)；Set<V> members(K key) ##

add方法：在无序集合中添加元素，返回添加个数；如果存在重复的则不进行添加。

members方法：返回集合中的所有成员。具体用法见以下代码：

/**
     * Redis操作集合（Set）
     * @author pan_junbiao
     **/
    @SpringBootTest
    public class SetTest
    {
        @Autowired
        private RedisTemplate redisTemplate;
    
        @Test
        public void set1()
        {
            String[] citys = new String[]{"北京","上海","广州","深圳"};
            System.out.println(redisTemplate.opsForSet().add("citySet",citys));
            System.out.println(redisTemplate.opsForSet().add("citySet","香港","澳门","台湾"));
            //返回集合中的所有元素
            System.out.println(redisTemplate.opsForSet().members("citySet"));
        }
    }

**执行结果：**

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3Bhbl9qdW5iaWFv_size_16_color_FFFFFF_t_70 4][]

## 4.2 Long remove(K key, Object... values) ##

移除集合中一个或多个成员。具体用法见以下代码：

@Autowired
    private RedisTemplate redisTemplate;
    
    @Test
    public void set2()
    {
        String[] citys = new String[]{"北京","上海","广州","深圳"};
        System.out.println(redisTemplate.opsForSet().add("citySet",citys));
        System.out.println(redisTemplate.opsForSet().remove("citySet",citys));
    }

**执行结果：**

![20201001154222257.jpg][]

## 4.3 V pop(K key) ##

移除并返回集合中的一个随机元素。具体用法见以下代码：

@Autowired
    private RedisTemplate redisTemplate;
    
    @Test
    public void set3()
    {
        String[] citys = new String[]{"北京","上海","广州","深圳"};
        System.out.println(redisTemplate.opsForSet().add("citySet",citys));
        System.out.println(redisTemplate.opsForSet().pop("citySet"));
        System.out.println(redisTemplate.opsForSet().members("citySet"));
    }

**执行结果：**

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3Bhbl9qdW5iaWFv_size_16_color_FFFFFF_t_70 5][]

## 4.4 Boolean move(K key, V value, K destKey) ##

将 member 元素移动。具体用法见以下代码：

@Autowired
    private RedisTemplate redisTemplate;
    
    @Test
    public void set4()
    {
        String[] citys = new String[]{"北京","上海","广州","深圳"};
        System.out.println(redisTemplate.opsForSet().add("citySet",citys));
        System.out.println(redisTemplate.opsForSet().move("citySet","深圳","citySet2"));
        System.out.println(redisTemplate.opsForSet().members("citySet"));
        System.out.println(redisTemplate.opsForSet().members("citySet2"));
    }

**执行结果：**

![20201001155943756.jpg][]

## 4.5 Cursor<V> scan(K key, ScanOptions options) ##

用于遍历 Set。具体用法见以下代码：

@Autowired
    private RedisTemplate redisTemplate;
    
    @Test
    public void set5()
    {
        String[] citys = new String[]{"北京","上海","广州","深圳"};
        System.out.println(redisTemplate.opsForSet().add("citySet",citys));
        Cursor<Object> cursor = redisTemplate.opsForSet().scan("citySet", ScanOptions.NONE);
        while(cursor.hasNext())
        {
            System.out.println(cursor.next());
        }
    }

**执行结果：**

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3Bhbl9qdW5iaWFv_size_16_color_FFFFFF_t_70 6][]

## 4.6 交集、并集、差集 ##

Set<V> intersect(K key1, K key2)方法、Long intersectAndStore(K key1, K key2, K destKey)方法：交集。

Set<V> union(K key1, K key2)方法、Long unionAndStore(K key1, K key2, K destKey)方法：并集。

Set<V> difference(K key1, K key2)方法、Long differenceAndStore(K key1, K key2, K destKey)方法：差集。

具体用法见以下代码：

@Autowired
    private RedisTemplate redisTemplate;
    
    @Test
    public void set6()
    {
        String[] city1 = new String[]{"北京", "上海", "广州", "深圳", "昆明"};
        String[] city2 = new String[]{"北京", "深圳", "昆明", "成都"};
        System.out.println(redisTemplate.opsForSet().add("citySet1", city1));
        System.out.println(redisTemplate.opsForSet().add("citySet2", city2));
    
        //返回集合中的所有元素
        System.out.println("城市集合1：" + redisTemplate.opsForSet().members("citySet1"));
        System.out.println("城市集合2：" + redisTemplate.opsForSet().members("citySet2"));
    
        //求交集、并集、差集（方式一）
        System.out.println("求交集、并集、差集（方式一）:");
        System.out.println("交集：" + redisTemplate.opsForSet().intersect("citySet1","citySet2"));
        System.out.println("并集：" + redisTemplate.opsForSet().union("citySet1","citySet2"));
        System.out.println("差集：" + redisTemplate.opsForSet().difference("citySet1","citySet2"));
    
        //求交集、并集、差集（方式二）
        redisTemplate.opsForSet().intersectAndStore("citySet1","citySet2", "intersectCity");
        redisTemplate.opsForSet().unionAndStore("citySet1","citySet2", "unionCity");
        redisTemplate.opsForSet().differenceAndStore("citySet1","citySet2", "differenceCity");
        System.out.println("求交集、并集、差集（方式二）:");
        System.out.println("交集：" + redisTemplate.opsForSet().members("intersectCity"));
        System.out.println("并集：" + redisTemplate.opsForSet().members("unionCity"));
        System.out.println("差集：" + redisTemplate.opsForSet().members("differenceCity"));
    }

**执行结果：**

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3Bhbl9qdW5iaWFv_size_16_color_FFFFFF_t_70 7][]

# 5、有序集合（Sorted Set） #

zset（Sorted Set 有序集合）也是 string 类型元素的集合，且不允许重复的成员。每个元素都会关联一个 double 类型的分数。可以通过分数将该集合中的成员从小到大进行排序。

zset 的成员是唯一的，但权重参数分数（score）却可以重复。集合中的元素能够按 score 进行排列。它可以用来做排行榜应用、取TOP/N、延时任务、范围查找等。

## 5.1 Long add(K key, Set<ZSetOperations.TypedTuple<V>> tuples) ##

增加一个有序集合。具体用法见以下代码：

import org.junit.jupiter.api.AfterEach;
    import org.junit.jupiter.api.BeforeEach;
    import org.junit.jupiter.api.Test;
    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.boot.test.context.SpringBootTest;
    import org.springframework.data.redis.core.DefaultTypedTuple;
    import org.springframework.data.redis.core.RedisTemplate;
    import org.springframework.data.redis.core.ZSetOperations;
    
    import java.util.HashSet;
    import java.util.Set;
    /**
     * Redis操作有序集合（Sorted Set）
     * @author pan_junbiao
     **/
    @SpringBootTest
    public class SortedSetTest
    {
        @Autowired
        private RedisTemplate redisTemplate;
    
        @Test
        public void Zset1() 
        {
            ZSetOperations.TypedTuple<String> objectTypedTuple1 = new DefaultTypedTuple<>("pan_junbiao的博客_01",9.6);
            ZSetOperations.TypedTuple<String> objectTypedTuple2 = new DefaultTypedTuple<>("pan_junbiao的博客_02",1.5);
            ZSetOperations.TypedTuple<String> objectTypedTuple3 = new DefaultTypedTuple<>("pan_junbiao的博客_03",7.4);
    
            Set<ZSetOperations.TypedTuple<String>> typles = new HashSet<ZSetOperations.TypedTuple<String>>();
            typles.add(objectTypedTuple1);
            typles.add(objectTypedTuple2);
            typles.add(objectTypedTuple3);
    
            System.out.println(redisTemplate.opsForZSet().add("typles",typles));
            System.out.println(redisTemplate.opsForZSet().range("typles",0,-1));
        }
    }

**执行结果：**

![20201003162950427.jpg][]

## 5.2 Boolean add(K key, V value, double score) ##

新增一个有序集合，存在的话为false，不存在的话为true。具体用法见以下代码：

@Autowired
    private RedisTemplate redisTemplate;
    
    @Test
    public void Zset2()
    {
        System.out.println(redisTemplate.opsForZSet().add("zset2", "pan_junbiao的博客_01", 9.6));
        System.out.println(redisTemplate.opsForZSet().add("zset2", "pan_junbiao的博客_01", 9.6));
    }

**执行结果：**

![20201003161358108.jpg][]

## 5.3 Long remove(K key, Object... values) ##

从有序集合中移除一个或者多个元素。具体用法见以下代码：

@Autowired
    private RedisTemplate redisTemplate;
    
    @Test
    public void Zset3()
    {
        System.out.println(redisTemplate.opsForZSet().add("zset3", "pan_junbiao的博客_01", 1.0));
        System.out.println(redisTemplate.opsForZSet().add("zset3", "pan_junbiao的博客_02", 1.0));
        System.out.println(redisTemplate.opsForZSet().range("zset3", 0, -1));
        System.out.println(redisTemplate.opsForZSet().remove("zset3", "pan_junbiao的博客_02"));
        System.out.println(redisTemplate.opsForZSet().range("zset3", 0, -1));
    }

**执行结果：**

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3Bhbl9qdW5iaWFv_size_16_color_FFFFFF_t_70 8][]

## 5.4 Long rank(K key, Object value) ##

返回有序集中指定成员的排名，其中有序集成员按分数值递增(从小到大)顺序排列。具体用法见以下代码：

@Autowired
    private RedisTemplate redisTemplate;
    
    @Test
    public void Zset4()
    {
        System.out.println(redisTemplate.opsForZSet().add("zset4", "pan_junbiao的博客_01",9.6));
        System.out.println(redisTemplate.opsForZSet().add("zset4", "pan_junbiao的博客_02",1.5));
        System.out.println(redisTemplate.opsForZSet().add("zset4", "pan_junbiao的博客_03",7.4));
        System.out.println(redisTemplate.opsForZSet().range("zset4", 0, -1));
        System.out.println(redisTemplate.opsForZSet().rank("zset4", "pan_junbiao的博客_02"));
    }

**执行结果：**

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3Bhbl9qdW5iaWFv_size_16_color_FFFFFF_t_70 9][]

> **注意：**结果中的0表示第一（最小）。

## 5.5 Set<V> range(K key, long start, long end)；Set<V> rangeByScore(K key, double score1, double score2) ##

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

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

具体用法见以下代码：

@Autowired
    private RedisTemplate redisTemplate;
    
    @Test
    public void Zset5()
    {
        ZSetOperations.TypedTuple<String> objectTypedTuple1 = new DefaultTypedTuple<>("pan_junbiao的博客_01",9.6);
        ZSetOperations.TypedTuple<String> objectTypedTuple2 = new DefaultTypedTuple<>("pan_junbiao的博客_02",1.5);
        ZSetOperations.TypedTuple<String> objectTypedTuple3 = new DefaultTypedTuple<>("pan_junbiao的博客_03",7.4);
    
        Set<ZSetOperations.TypedTuple<String>> typles = new HashSet<ZSetOperations.TypedTuple<String>>();
        typles.add(objectTypedTuple1);
        typles.add(objectTypedTuple2);
        typles.add(objectTypedTuple3);
    
        System.out.println(redisTemplate.opsForZSet().add("zset5",typles));
        System.out.println(redisTemplate.opsForZSet().range("zset5",0,-1));
        System.out.println(redisTemplate.opsForZSet().rangeByScore("zset5", 0, 8));
    }

**执行结果：**

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3Bhbl9qdW5iaWFv_size_16_color_FFFFFF_t_70 10][]

## 5.6 Long count(K key, double score1, double score2)；Long size(K key) ##

count方法：通过分数返回有序集合指定区间内的成员个数。

size方法：获取有序集合的成员数。

具体用法见以下代码：

@Autowired
    private RedisTemplate redisTemplate;
    
    @Test
    public void Zset6()
    {
        ZSetOperations.TypedTuple<String> objectTypedTuple1 = new DefaultTypedTuple<>("pan_junbiao的博客_01",9.6);
        ZSetOperations.TypedTuple<String> objectTypedTuple2 = new DefaultTypedTuple<>("pan_junbiao的博客_02",1.5);
        ZSetOperations.TypedTuple<String> objectTypedTuple3 = new DefaultTypedTuple<>("pan_junbiao的博客_03",7.4);
    
        Set<ZSetOperations.TypedTuple<String>> typles = new HashSet<ZSetOperations.TypedTuple<String>>();
        typles.add(objectTypedTuple1);
        typles.add(objectTypedTuple2);
        typles.add(objectTypedTuple3);
    
        redisTemplate.opsForZSet().add("zset6", typles);
        System.out.println("分数在0至8区间内的成员个数：" + redisTemplate.opsForZSet().count("zset6", 0, 8));
        System.out.println("有序集合的成员数：" + redisTemplate.opsForZSet().size("zset6"));
    }

**执行结果：**

![20201003174435992.jpg][]

## 5.7 Double score(K key, Object o) ##

获取指定成员的score值。具体用法见以下代码：

@Test
    public void Zset7()
    {
        redisTemplate.opsForZSet().add("zset7", "pan_junbiao的博客_01", 9.6);
        redisTemplate.opsForZSet().add("zset7", "pan_junbiao的博客_02", 1.5);
        redisTemplate.opsForZSet().add("zset7", "pan_junbiao的博客_03", 7.4);
    
        System.out.println("pan_junbiao的博客_01的分数：" + redisTemplate.opsForZSet().score("zset7", "pan_junbiao的博客_01"));
        System.out.println("pan_junbiao的博客_02的分数：" + redisTemplate.opsForZSet().score("zset7", "pan_junbiao的博客_02"));
        System.out.println("pan_junbiao的博客_03的分数：" + redisTemplate.opsForZSet().score("zset7", "pan_junbiao的博客_03"));
    }

**执行结果：**

![20201003175542804.jpg][]

## 5.8 Long removeRange(K key, long start, long end) ##

移除指定索引位置的成员，有序集合成员按照分数值递增(从小到大)顺序排列。具体用法见以下代码：

@Autowired
    private RedisTemplate redisTemplate;
    
    @Test
    public void Zset8()
    {
        ZSetOperations.TypedTuple<String> objectTypedTuple1 = new DefaultTypedTuple<>("pan_junbiao的博客_01",9.6);
        ZSetOperations.TypedTuple<String> objectTypedTuple2 = new DefaultTypedTuple<>("pan_junbiao的博客_02",1.5);
        ZSetOperations.TypedTuple<String> objectTypedTuple3 = new DefaultTypedTuple<>("pan_junbiao的博客_03",7.4);
    
        Set<ZSetOperations.TypedTuple<String>> tuples = new HashSet<ZSetOperations.TypedTuple<String>>();
        tuples.add(objectTypedTuple1);
        tuples.add(objectTypedTuple2);
        tuples.add(objectTypedTuple3);
    
        System.out.println(redisTemplate.opsForZSet().add("zset8", tuples));
        System.out.println(redisTemplate.opsForZSet().range("zset8", 0, -1));
        System.out.println(redisTemplate.opsForZSet().removeRange("zset8", 1, 5));
        System.out.println(redisTemplate.opsForZSet().range("zset8", 0, -1));
    }

**执行结果：**

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3Bhbl9qdW5iaWFv_size_16_color_FFFFFF_t_70 11][]

## 5.9 Cursor<ZSetOperations.TypedTuple<V>> scan(K key, ScanOptions options) ##

遍历 zset。具体用法见以下代码：

@Autowired
    private RedisTemplate redisTemplate;
    
    @Test
    public void Zset9()
    {
        ZSetOperations.TypedTuple<String> objectTypedTuple1 = new DefaultTypedTuple<>("pan_junbiao的博客_01",9.6);
        ZSetOperations.TypedTuple<String> objectTypedTuple2 = new DefaultTypedTuple<>("pan_junbiao的博客_02",1.5);
        ZSetOperations.TypedTuple<String> objectTypedTuple3 = new DefaultTypedTuple<>("pan_junbiao的博客_03",7.4);
    
        Set<ZSetOperations.TypedTuple<String>> tuples = new HashSet<ZSetOperations.TypedTuple<String>>();
        tuples.add(objectTypedTuple1);
        tuples.add(objectTypedTuple2);
        tuples.add(objectTypedTuple3);
    
        System.out.println(redisTemplate.opsForZSet().add("zset9", tuples));
        Cursor<ZSetOperations.TypedTuple<Object>> cursor = redisTemplate.opsForZSet().scan("zset9", ScanOptions.NONE);
        while (cursor.hasNext())
        {
            ZSetOperations.TypedTuple<Object> item = cursor.next();
            System.out.println(item.getValue() + " 的分数值：" + item.getScore());
        }
    }

**执行结果：**

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3Bhbl9qdW5iaWFv_size_16_color_FFFFFF_t_70 12][]

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3Bhbl9qdW5iaWFv_size_16_color_FFFFFF_t_70]: /images/20221123/3ad41f9b2ad347bf8a75c9a1dfe955fd.png
[20200930114151959.jpg]: /images/20221123/50d3eaec830c4a639e191d76d77efa9d.png
[20200930120416951.jpg]: /images/20221123/7bc4b0d720ea4d3da381513d04f26a86.png
[20200930162722711.jpg]: /images/20221123/12f41c6a71694e4b87dac71eabc59442.png
[20200930164130803.jpg]: /images/20221123/d7500577a2a0408ca98e75b78e8a2a38.png
[2020093017271483.jpg]: /images/20221123/d65c354e42444d6a810ba1fe2154deef.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3Bhbl9qdW5iaWFv_size_16_color_FFFFFF_t_70 1]: /images/20221123/6394d54281f041e294ce28811fa0b8da.png
[20200930175036276.jpg]: /images/20221123/b3e63d1de135447a8e65148d429dbdd2.png
[20200930181502752.jpg]: /images/20221123/38663aec4d554e1fb5604a555e2aab15.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3Bhbl9qdW5iaWFv_size_16_color_FFFFFF_t_70 2]: /images/20221123/9607d635b2c54e9990c3fe14c9cb491e.png
[20200930183043381.jpg]: /images/20221123/a76357974d5045f89e02c7ddbe2dba27.png
[20200930184422139.jpg]: /images/20221123/517c73013b674a1092667d6d671cde27.png
[20201001105402511.jpg]: /images/20221123/1ad95d958ebc45deba2d31167d48f102.png
[20201001110835780.jpg]: /images/20221123/4987ee35036c47a79560d9d61c5ca2a7.png
[20201001112754503.jpg]: /images/20221123/209ab2097ae14cdf8b43d8d0b9aff916.png
[20201001114216176.jpg]: /images/20221123/08192fbd6ef34f34982b4960695e4d27.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3Bhbl9qdW5iaWFv_size_16_color_FFFFFF_t_70 3]: /images/20221123/2e5b26880a104131aa12656c3861a390.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3Bhbl9qdW5iaWFv_size_16_color_FFFFFF_t_70 4]: /images/20221123/9d6ab0d9fd7d43f7a107988b01457ac4.png
[20201001154222257.jpg]: /images/20221123/d5a5ef3656c94d4cbaaed5f1aa7e1afc.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3Bhbl9qdW5iaWFv_size_16_color_FFFFFF_t_70 5]: /images/20221123/30d59e965ae349329dac5256d61056a5.png
[20201001155943756.jpg]: /images/20221123/64a71057cfe843139e955e12887335d9.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3Bhbl9qdW5iaWFv_size_16_color_FFFFFF_t_70 6]: /images/20221123/bad8d3e40320448b9430e80439ee3031.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3Bhbl9qdW5iaWFv_size_16_color_FFFFFF_t_70 7]: /images/20221123/a0d3c94680924daa8928d5eef176e214.png
[20201003162950427.jpg]: /images/20221123/2b86423bc4b240f1a1b8b8b13c9156d1.png
[20201003161358108.jpg]: /images/20221123/2d6a768bea5e4b669ed732b7ceb3c755.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3Bhbl9qdW5iaWFv_size_16_color_FFFFFF_t_70 8]: /images/20221123/4f4b480c4b264848be661f5268082f2e.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3Bhbl9qdW5iaWFv_size_16_color_FFFFFF_t_70 9]: /images/20221123/8340c4450fb94a8ab6626aa1e7fa9485.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3Bhbl9qdW5iaWFv_size_16_color_FFFFFF_t_70 10]: /images/20221123/c73bf3681c51456db265bb0fbc366621.png
[20201003174435992.jpg]: /images/20221123/d2b9a0ec115f4e4b9cae7ff786665ae2.png
[20201003175542804.jpg]: /images/20221123/f0cfc173430c476ba80da738a9f96fab.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3Bhbl9qdW5iaWFv_size_16_color_FFFFFF_t_70 11]: /images/20221123/7a36cfbc4abb4a1491aae136b29da59f.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3Bhbl9qdW5iaWFv_size_16_color_FFFFFF_t_70 12]: /images/20221123/53eabdf6a2ca4046a704d81471862ddd.png