服务器之家：专注于服务器技术及软件下载分享
分类导航

Mysql|Sql Server|Oracle|Redis|MongoDB|PostgreSQL|Sqlite|DB2|mariadb|Access|数据库技术|

服务器之家 - 数据库 - 数据库技术 - SpringBoot怎么使用RedisTemplate操作Redis数据类型

SpringBoot怎么使用RedisTemplate操作Redis数据类型

2023-06-10 12:08未知服务器之家 数据库技术

Spring 封装了 RedisTemplate 来操作 Redis，它支持所有的 Redis 原生的 API。在 RedisTemplate 中定义了对5种数据结构的操作方法。 opsForValue()：操作字符串。 opsForList()：操作列表。 opsForHash()：操作哈希。 opsForSet()：操作集合。 opsForZSet()：操

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/> <!-- lookup parent from repository -->
</parent>

添加Redis依赖：

<!-- 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 最基本的数据类型。每个键（Key）在 String 中对应一个对应值（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"));
    }
}

执行结果：

SpringBoot怎么使用RedisTemplate操作Redis数据类型

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();
    }
}

执行结果：

SpringBoot怎么使用RedisTemplate操作Redis数据类型

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);
}

执行结果：

SpringBoot怎么使用RedisTemplate操作Redis数据类型

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"));
}

执行结果：

SpringBoot怎么使用RedisTemplate操作Redis数据类型

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

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"));
}

执行结果：

SpringBoot怎么使用RedisTemplate操作Redis数据类型

2、列表（List）

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

使用list数据结果，可以做简单的消息队列的功能。Irange command can also be used to implement high-performance pagination based on Redis.。

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));
    }
}

执行结果：

SpringBoot怎么使用RedisTemplate操作Redis数据类型

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));
}

执行结果：

SpringBoot怎么使用RedisTemplate操作Redis数据类型

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"));
}

执行结果：

SpringBoot怎么使用RedisTemplate操作Redis数据类型

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));
}

执行结果：

SpringBoot怎么使用RedisTemplate操作Redis数据类型

2.5 V index(K key, long index)

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

@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));
}

执行结果：

SpringBoot怎么使用RedisTemplate操作Redis数据类型

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

从键中存储的列表中删除第一个计数事件等于给定“count”值的元素。其中，参数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));
}

执行结果：

SpringBoot怎么使用RedisTemplate操作Redis数据类型

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));
}

执行结果：

SpringBoot怎么使用RedisTemplate操作Redis数据类型

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 hash2()
    {
        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"));
    }
}

执行结果：

SpringBoot怎么使用RedisTemplate操作Redis数据类型

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 hash3()
{
    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"));
}

执行结果：

SpringBoot怎么使用RedisTemplate操作Redis数据类型

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

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

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

@Autowired
private RedisTemplate redisTemplate;
 
@Test
public void hash4()
{
    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"));
}

执行结果：

SpringBoot怎么使用RedisTemplate操作Redis数据类型

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

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

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

@Autowired
private RedisTemplate redisTemplate;
 
@Test
public void hash5()
{
    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"));
}

执行结果：

SpringBoot怎么使用RedisTemplate操作Redis数据类型

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

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

@Autowired
private RedisTemplate redisTemplate;
 
@Test
public void hash6()
{
    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"));
}

执行结果：

SpringBoot怎么使用RedisTemplate操作Redis数据类型

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"));
    }
}

执行结果：

SpringBoot怎么使用RedisTemplate操作Redis数据类型

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));
}

执行结果：

SpringBoot怎么使用RedisTemplate操作Redis数据类型

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"));
}

执行结果：

SpringBoot怎么使用RedisTemplate操作Redis数据类型

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"));
}

执行结果：

SpringBoot怎么使用RedisTemplate操作Redis数据类型

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());
    }
}

执行结果：

SpringBoot怎么使用RedisTemplate操作Redis数据类型

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"));
}

执行结果：

SpringBoot怎么使用RedisTemplate操作Redis数据类型

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));
    }
}

执行结果：

SpringBoot怎么使用RedisTemplate操作Redis数据类型

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));
}

执行结果：

SpringBoot怎么使用RedisTemplate操作Redis数据类型

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));
}

执行结果：

SpringBoot怎么使用RedisTemplate操作Redis数据类型

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"));
}

执行结果：

SpringBoot怎么使用RedisTemplate操作Redis数据类型

注意：结果中的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));
}

执行结果：

SpringBoot怎么使用RedisTemplate操作Redis数据类型

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"));
}

执行结果：

SpringBoot怎么使用RedisTemplate操作Redis数据类型

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"));
}

执行结果：

SpringBoot怎么使用RedisTemplate操作Redis数据类型

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));
}

执行结果：

SpringBoot怎么使用RedisTemplate操作Redis数据类型

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());
    }
}

执行结果：

SpringBoot怎么使用RedisTemplate操作Redis数据类型

免费资源网,http://www.zzvips.com/uploads/allimg/h2svg4qjsqb

延伸 · 阅读

精彩推荐
  • 数据库技术SpringBoot怎么监听redis Key变化事件

    SpringBoot怎么监听redis Key变化事件

    键空间通知使得客户端可以通过订阅频道或模式， 来接收那些以某种方式改动了 Redis key变化的事件。 所有修改key键的命令。 所有接收到 LPUSH key value [va...

    未知1902023-05-27
  • 数据库技术通过Qt连接OpenGauss数据库的详细教程

    通过Qt连接OpenGauss数据库的详细教程

    本教程介绍如何通过Qt连接OpenGauss数据库，在openGauss所在的root环境下执行相关步骤，需要Windows下配置ODBC数据源，本文给大家介绍的非常详细，需要的朋友...

    一 学12622021-12-11
  • 数据库技术mysql连接数指的是什么

    mysql连接数指的是什么

    mysql连接数是指数据库最多能够同时接受的客户连接数。MySQL连接数是一个必须要考虑到的组件，它可以在帮助数据库能够安全运行的同时，最大化数据库当...

    未知1662023-05-27
  • 数据库技术使用DataGrip连接Hive的详细步骤

    使用DataGrip连接Hive的详细步骤

    这篇文章主要介绍了DataGrip连接Hive的详细图文教程,本文通过图文并茂的形式给大家介绍的非常详细，对大家的学习或工作具有一定的参考借鉴价值，需要的...

    潘书鹏的BigData7792021-12-08
  • 数据库技术DataGrip 数据导出与导入的实现示例

    DataGrip 数据导出与导入的实现示例

    DataGrip 是一款类似于Workbench的数据库设计工具。文中通过示例代码介绍的非常详细，具有一定的参考价值，感兴趣的小伙伴们可以参考一下...

    zhangjunjie537272021-12-13
  • 数据库技术数据库查询中遭遇特殊字符导致问题的解决方法

    数据库查询中遭遇特殊字符导致问题的解决方法

    数据库查询中遭遇特殊字符导致问题的解决方法，我们提供的是asp的，但其它的数据库与语言下的解决方法也大同小异。...

    数据库技术网8812021-09-08
  • 数据库技术sql注入之新手入门示例详解

    sql注入之新手入门示例详解

    这篇文章仅仅是对SQL注入进行了一个简单的入门知识的讲解，是sql注入的基础篇，有个好的开头能够帮助大家对SQL注入有一个具体清晰的了解和认识。下面...

    数据库技术网12092021-10-27
  • 数据库技术PostgreSQL中json数据类型详解

    PostgreSQL中json数据类型详解

    前言 JSON（JavaScript Object Notation）是一种轻量级的数据交换格式。它基于 ECMAScript（European Computer Manufacturers Association, 欧洲计算机协会制定的js规范）的一个...

    未知872023-05-31
最近更新
编辑推荐
阅读排行
热门标签
3680 　 10038 　 压缩解压 　 汇总 　 连续序号 　 隐藏开销 　 datastage 　 dsjob 　 关系连接 　 移动加权 　 平均算法 　 DB驱动 　 DB连接串 　 MDAC 　 规范化 　 TSDB 　 列式数据库 　 Trafodion 　 异构数据库 　 存储系统 　 交付 　 LSM 　 CAP定理 　 iwms 　 数据库平台 　 合区 　 where 1=1 　 dba_indexes 　 rpm-ostree 　 更新日志 　
© 2019-2023 服务器之家(www.zzvips.com) 版权所有关于我们联系我们版权申明网站地图