整合SpringDataRedis的SpringBoot配置步骤

SpringBoot 整合 Spring Data Redis 是一项简单的任务，仅需几个步骤。首先，在项目的依赖项中添加 springboot-starter-data-redis，然后配置 application.properties 文件以设置 Redis 服务器信息。接下来，创建一个 Redis 配置类（例如 RedisConfig），其中包含 Redis 池配置、连接工厂和 Redis 模板的 Bean 定义。最后，使用 Redis 模板执行 Redis 操作，例如设置和获取值。本文提供了一个分步指南，包括 Java 配置、添加 POJO 和单元测试，以帮助您轻松地将 Spring Data Redis 整合到您的 SpringBoot 项目中。

SpringBoot整合SpringDataRedis
1.创建项目添加依赖
  创建SpringBoot项目，并添加如下依赖:

   
   
       org.springframework.boot
       spring-boot-starter-web
   
   
   
       org.springframework.boot
       spring-boot-starter-data-redis
   

       org.springframework.boot
       spring-boot-starter-test
       test
   
   
       redis.clients
       jedis
       2.9.0
   

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
2.设置application.properties文件
spring.redis.jedis.pool.max-idle=10
spring.redis.jedis.pool.min-idle=5
spring.redis.pool.max-total=20
spring.redis.hostName=192.168.88.120
spring.redis.port=6379
1
2
3
4
5
3.添加Redis的配置类
  添加Redis的java配置类，设置相关的信息。

/**
* @program: springboot-redis-demo
* @description: Redis的配置类
* @author: 波波烤鸭
* @create: 2019-05-20 23:40
*/
@Configuration
public class RedisConfig {

/**
    * 1.创建JedisPoolConfig对象。在该对象中完成一些链接池配置
    * @ConfigurationProperties:会将前缀相同的内容创建一个实体。
    */
   @Bean
   @ConfigurationProperties(prefix=”spring.redis.pool”)
   public JedisPoolConfig jedisPoolConfig(){
       JedisPoolConfig config = new JedisPoolConfig();
/*//最大空闲数
config.setMaxIdle(10);
//最小空闲数
config.setMinIdle(5);
//最大链接数
config.setMaxTotal(20);*/
       System.out.println(“默认值：”+config.getMaxIdle());
       System.out.println(“默认值：”+config.getMinIdle());
       System.out.println(“默认值：”+config.getMaxTotal());
       return config;
   }

/**
    * 2.创建JedisConnectionFactory：配置redis链接信息
    */
   @Bean
   @ConfigurationProperties(prefix=”spring.redis”)
   public JedisConnectionFactory jedisConnectionFactory(JedisPoolConfig config){
       System.out.println(“配置完毕：”+config.getMaxIdle());
       System.out.println(“配置完毕：”+config.getMinIdle());
       System.out.println(“配置完毕：”+config.getMaxTotal());

JedisConnectionFactory factory = new JedisConnectionFactory();
       //关联链接池的配置对象
       factory.setPoolConfig(config);
       //配置链接Redis的信息
       //主机地址
/*factory.setHostName(“192.168.70.128”);
//端口
factory.setPort(6379);*/
       return factory;
   }

/**
    * 3.创建RedisTemplate:用于执行Redis操作的方法
    */
   @Bean
   public RedisTemplate redisTemplate(JedisConnectionFactory factory){
       RedisTemplate template = new RedisTemplate<>();
       //关联
       template.setConnectionFactory(factory);

//为key设置序列化器
       template.setKeySerializer(new StringRedisSerializer());
       //为value设置序列化器
       template.setValueSerializer(new StringRedisSerializer());

return template;
   }
}
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
4.添加pojo
/**
* @program: springboot-redis-demo
* @description: Users
* @author: 波波烤鸭
* @create: 2019-05-20 23:47
*/
public class Users implements Serializable {

private Integer id;
   private String name;
   private Integer age;
   public Integer getId() {
       return id;
   }
   public void setId(Integer id) {
       this.id = id;
   }
   public String getName() {
       return name;
   }
   public void setName(String name) {
       this.name = name;
   }
   public Integer getAge() {
       return age;
   }
   public void setAge(Integer age) {
       this.age = age;
   }
   @Override
   public String toString() {
       return “Users [id=” + id + “, name=” + name + “, age=” + age + “]”;
   }

}
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
5.单元测试

@RunWith(SpringRunner.class)
@SpringBootTest(classes = SpringbootRedisDemoApplication.class)
public class SpringbootRedisDemoApplicationTests {

@Autowired
   private RedisTemplate redisTemplate;

/**
    * 添加一个字符串
    */
   @Test
   public void testSet(){
       this.redisTemplate.opsForValue().set(“key”, “bobokaoya…”);
   }

/**
    * 获取一个字符串
    */
   @Test
   public void testGet(){
       String value = (String)this.redisTemplate.opsForValue().get(“key”);
       System.out.println(value);
   }

/**
    * 添加Users对象
    */
   @Test
   public void testSetUesrs(){
       Users users = new Users();
       users.setAge(20);
       users.setName(“张三丰”);
       users.setId(1);
       //重新设置序列化器
       this.redisTemplate.setValueSerializer(new JdkSerializationRedisSerializer());
       this.redisTemplate.opsForValue().set(“users”, users);
   }

/**
    * 取Users对象
    */
   @Test
   public void testGetUsers(){
       //重新设置序列化器
       this.redisTemplate.setValueSerializer(new JdkSerializationRedisSerializer());
       Users users = (Users)this.redisTemplate.opsForValue().get(“users”);
       System.out.println(users);
   }

/**
    * 基于JSON格式存Users对象
    */
   @Test
   public void testSetUsersUseJSON(){
       Users users = new Users();
       users.setAge(20);
       users.setName(“李四丰”);
       users.setId(1);
       this.redisTemplate.setValueSerializer(new Jackson2JsonRedisSerializer<>(Users.class));
       this.redisTemplate.opsForValue().set(“users_json”, users);
   }

/**
    * 基于JSON格式取Users对象
    */
   @Test
   public void testGetUseJSON(){
       this.redisTemplate.setValueSerializer(new Jackson2JsonRedisSerializer<>(Users.class));
       Users users = (Users)this.redisTemplate.opsForValue().get(“users_json”);
       System.out.println(users);
   }

}

到这里，我们也就讲完了《整合SpringDataRedis的SpringBoot配置步骤》的内容了。个人认为，基础知识的学习和巩固，是为了更好的将其运用到项目中，欢迎关注golang学习网公众号，带你了解更多关于SpringBoot,springdataredis的知识点！