自丢网»教程 › 【教程】编程记录 › JAVA教程 › Spring Data Redis使用方式
返回列表 发新帖

Spring Data Redis使用方式

[复制链接]
admin 发表于 2025-9-18 08:55:04 | 显示全部楼层 |阅读模式
Spring Data Redis使用方式

1，进入到sky-server模块
导入Spring Data Redis的maven坐标(已完成)
  1. <dependency>
  2.      <groupId>org.springframework.boot</groupId>
  3.      <artifactId>spring-boot-starter-data-redis</artifactId>
  4. </dependency>
复制代码

2). 配置Redis数据源
在application-dev.yml中添加
  1. sky:
  2.   redis:
  3.     host: localhost
  4.     port: 6379
  5.     password: 123456
  6.     database: 10
复制代码
解释说明：
database:指定使用Redis的哪个数据库，Redis服务启动后默认有16个数据库，编号分别是从0到15，不写默认为0。
可以通过修改Redis配置文件来指定数据库的数量。
在application.yml中添加读取application-dev.yml中的相关Redis配置
  1. spring:
  2.   profiles:
  3.     active: dev
  4.   redis:
  5.     host: ${sky.redis.host}
  6.     port: ${sky.redis.port}
  7.     password: ${sky.redis.password}
  8.     database: ${sky.redis.database}
复制代码
3). 编写配置类，创建RedisTemplate对象
  1. package com.sky.config;

  3. import lombok.extern.slf4j.Slf4j;
  4. import org.springframework.context.annotation.Bean;
  5. import org.springframework.context.annotation.Configuration;
  6. import org.springframework.data.redis.connection.RedisConnectionFactory;
  7. import org.springframework.data.redis.core.RedisTemplate;
  8. import org.springframework.data.redis.serializer.StringRedisSerializer;

  10. @Configuration
  11. @Slf4j
  12. public class RedisConfiguration {

  14.     @Bean
  15.     public RedisTemplate redisTemplate(RedisConnectionFactory redisConnectionFactory){
  16.         log.info("开始创建redis模板对象...");
  17.         RedisTemplate redisTemplate = new RedisTemplate();
  18.         //设置redis的连接工厂对象
  19.         redisTemplate.setConnectionFactory(redisConnectionFactory);
  20.         //设置redis key的序列化器
  21.         redisTemplate.setKeySerializer(new StringRedisSerializer());
  22.         return redisTemplate;
  23.     }
  24. }
复制代码
解释说明：
当前配置类不是必须的，因为 Spring Boot 框架会自动装配 RedisTemplate 对象，但是默认的key序列化器为
JdkSerializationRedisSerializer，导致我们存到Redis中后的数据和原始数据有差别，故设置为
StringRedisSerializer序列化器。

4). 通过RedisTemplate对象操作Redis
在test下新建测试类
  1. package com.sky.test;

  3. import org.junit.jupiter.api.Test;
  4. import org.springframework.beans.factory.annotation.Autowired;
  5. import org.springframework.boot.test.context.SpringBootTest;
  6. import org.springframework.data.redis.core.*;

  8. @SpringBootTest
  9. public class SpringDataRedisTest {
  10.     @Autowired
  11.     private RedisTemplate redisTemplate;

  13.     @Test
  14.     public void testRedisTemplate(){
  15.         System.out.println(redisTemplate);
  16.         //string数据操作
  17.         ValueOperations valueOperations = redisTemplate.opsForValue();
  18.         //hash类型的数据操作
  19.         HashOperations hashOperations = redisTemplate.opsForHash();
  20.         //list类型的数据操作
  21.         ListOperations listOperations = redisTemplate.opsForList();
  22.         //set类型数据操作
  23.         SetOperations setOperations = redisTemplate.opsForSet();
  24.         //zset类型数据操作
  25.         ZSetOperations zSetOperations = redisTemplate.opsForZSet();
  26.     }
  27. }
复制代码
1.jpg
1). 操作字符串类型数据
  1. /**
  2.      * 操作字符串类型的数据
  3.      */
  4.     @Test
  5.     public void testString(){
  6.         // set get setex setnx
  7.         redisTemplate.opsForValue().set("name","小明");
  8.         String city = (String) redisTemplate.opsForValue().get("name");
  9.         System.out.println(city);
  10.         redisTemplate.opsForValue().set("code","1234",3, TimeUnit.MINUTES);
  11.         redisTemplate.opsForValue().setIfAbsent("lock","1");
  12.         redisTemplate.opsForValue().setIfAbsent("lock","2");
  13.     }
复制代码
2). 操作哈希类型数据
  1. /**
  2.      * 操作哈希类型的数据
  3.      */
  4.     @Test
  5.     public void testHash(){
  6.         //hset hget hdel hkeys hvals
  7.         HashOperations hashOperations = redisTemplate.opsForHash();

  9.         hashOperations.put("100","name","tom");
  10.         hashOperations.put("100","age","20");

  12.         String name = (String) hashOperations.get("100", "name");
  13.         System.out.println(name);

  15.         Set keys = hashOperations.keys("100");
  16.         System.out.println(keys);

  18.         List values = hashOperations.values("100");
  19.         System.out.println(values);

  21.         hashOperations.delete("100","age");
  22.     }
复制代码
3). 操作列表类型数据
  1. /**
  2.      * 操作列表类型的数据
  3.      */
  4.     @Test
  5.     public void testList(){
  6.         //lpush lrange rpop llen
  7.         ListOperations listOperations = redisTemplate.opsForList();

  9.         listOperations.leftPushAll("mylist","a","b","c");
  10.         listOperations.leftPush("mylist","d");

  12.         List mylist = listOperations.range("mylist", 0, -1);
  13.         System.out.println(mylist);

  15.         listOperations.rightPop("mylist");

  17.         Long size = listOperations.size("mylist");
  18.         System.out.println(size);
  19.     }
复制代码
4). 操作集合类型数据
  1. /**
  2.      * 操作集合类型的数据
  3.      */
  4.     @Test
  5.     public void testSet(){
  6.         //sadd smembers scard sinter sunion srem
  7.         SetOperations setOperations = redisTemplate.opsForSet();

  9.         setOperations.add("set1","a","b","c","d");
  10.         setOperations.add("set2","a","b","x","y");

  12.         Set members = setOperations.members("set1");
  13.         System.out.println(members);

  15.         Long size = setOperations.size("set1");
  16.         System.out.println(size);

  18.         Set intersect = setOperations.intersect("set1", "set2");
  19.         System.out.println(intersect);

  21.         Set union = setOperations.union("set1", "set2");
  22.         System.out.println(union);

  24.         setOperations.remove("set1","a","b");
  25.     }
复制代码
5). 操作有序集合类型数据
  1. /**
  2.      * 操作有序集合类型的数据
  3.      */
  4.     @Test
  5.     public void testZset(){
  6.         //zadd zrange zincrby zrem
  7.         ZSetOperations zSetOperations = redisTemplate.opsForZSet();

  9.         zSetOperations.add("zset1","a",10);
  10.         zSetOperations.add("zset1","b",12);
  11.         zSetOperations.add("zset1","c",9);

  13.         Set zset1 = zSetOperations.range("zset1", 0, -1);
  14.         System.out.println(zset1);

  16.         zSetOperations.incrementScore("zset1","c",10);

  18.         zSetOperations.remove("zset1","a","b");
  19.     }
复制代码
6). 通用命令操作
  1. /**
  2.      * 通用命令操作
  3.      */
  4.     @Test
  5.     public void testCommon(){
  6.         //keys exists type del
  7.         Set keys = redisTemplate.keys("*");
  8.         System.out.println(keys);

  10.         Boolean name = redisTemplate.hasKey("name");
  11.         Boolean set1 = redisTemplate.hasKey("set1");

  13.         for (Object key : keys) {
  14.             DataType type = redisTemplate.type(key);
  15.             System.out.println(type.name());
  16.         }

  18.         redisTemplate.delete("mylist");
  19.     }
复制代码
测试
  1. package com.sky.test;

  3. import org.junit.jupiter.api.Test;
  4. import org.springframework.beans.factory.annotation.Autowired;
  5. import org.springframework.boot.test.context.SpringBootTest;
  6. import org.springframework.data.redis.connection.DataType;
  7. import org.springframework.data.redis.core.*;

  9. import java.util.List;
  10. import java.util.Set;
  11. import java.util.concurrent.TimeUnit;

  13. @SpringBootTest
  14. public class SpringDataRedisTest {
  15.     @Autowired
  16.     private RedisTemplate redisTemplate;

  18.     @Test
  19.     public void testRedisTemplate(){
  20.         System.out.println(redisTemplate);
  21.     }

  23.     /**
  24.      * 操作字符串类型的数据
  25.      */
  26.     @Test
  27.     public void testString(){
  28.         // set get setex setnx
  29.         redisTemplate.opsForValue().set("name","小明");
  30.         String city = (String) redisTemplate.opsForValue().get("name");
  31.         System.out.println(city);
  32.         redisTemplate.opsForValue().set("code","1234",3, TimeUnit.MINUTES);
  33.         redisTemplate.opsForValue().setIfAbsent("lock","1");
  34.         redisTemplate.opsForValue().setIfAbsent("lock","2");
  35.     }
  36. }
复制代码
1.jpg
springboot教程, redis储存, java教程

相关帖子

网站建设，公众号小程序开发，多商户单商户小程序制作，高端系统定制开发，App软件开发联系我们【手机/微信：17817817816】
回复

举报

 楼主| admin 发表于 2025-9-18 14:11:40 | 显示全部楼层
实际开发中案例：

  1. package com.sky.controller.admin;

  3. import com.sky.result.Result;
  4. import io.swagger.annotations.Api;
  5. import io.swagger.annotations.ApiOperation;
  6. import lombok.extern.slf4j.Slf4j;
  7. import org.springframework.beans.factory.annotation.Autowired;
  8. import org.springframework.data.redis.core.RedisTemplate;
  9. import org.springframework.web.bind.annotation.*;

  11. @RestController("adminShopController")
  12. @RequestMapping("/admin/shop")
  13. @Api(tags = "店铺相关接口")
  14. @Slf4j
  15. public class ShopController {

  17.     public static final String KEY = "SHOP_STATUS";

  19.     @Autowired
  20.     private RedisTemplate redisTemplate;

  22.     /**
  23.      * 设置店铺的营业状态
  24.      * @param status
  25.      * @return
  26.      */
  27.     @PutMapping("/{status}")
  28.     @ApiOperation("设置店铺的营业状态")
  29.     public Result setStatus(@PathVariable Integer status){
  30.         log.info("设置店铺的营业状态为：{}",status == 1 ? "营业中" : "打烊中");
  31.         redisTemplate.opsForValue().set(KEY,status);
  32.         return Result.success();
  33.     }

  35.     /**
  36.      * 获取店铺的营业状态
  37.      * @return
  38.      */
  39.     @GetMapping("/status")
  40.     @ApiOperation("获取店铺的营业状态")
  41.     public Result<Integer> getStatus(){
  42.         Integer status = (Integer) redisTemplate.opsForValue().get(KEY);
  43.         log.info("获取到店铺的营业状态为：{}",status == 1 ? "营业中" : "打烊中");
  44.         return Result.success(status);
  45.     }
  46. }
复制代码


网站建设，公众号小程序开发，多商户单商户小程序制作，高端系统定制开发，App软件开发联系我们【手机/微信：17817817816】
回复

举报

返回列表 发新帖
微信扫码
Archiver|手机版|自丢网

网站建设，公众号小程序开发，商城小程序，系统定制开发，App软件开发等

粤ICP备2024252464号

在本版发帖
微信扫码
QQ客服返回顶部
快速回复 返回顶部 返回列表