Spring Boot 2.1整合Redis

51次阅读

共计 3765 个字符,预计需要花费 10 分钟才能阅读完成。

1. 普通字符串存储
1. 引入 spring-boot-starter-data-redisjar 包, 注意 spring boot 2.1 没有对应的 spring-boot-starter-redis 版本,改名为 spring-boot-starter-data-redis。
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-data-redis</artifactId>
</dependency>
2. 在 application 中添加 redis 配置
spring:
redis:
host: 192.168.187.11
port: 6379
3. 测试
redis 客户端查看, 没有任何 key
192.168.187.11:6379> keys *
(empty list or set)
@RestController
@RequestMapping(value = “/string”)
public class RedisStringController {

@Autowired
private StringRedisTemplate stringRedisTemplate;

@PutMapping(value = “/put”)
public void put(String key, @RequestParam(required = false, defaultValue = “default”) String value) {
stringRedisTemplate.opsForValue().set(key, value);
}

@GetMapping(value = “/get”)
public Object get(String key) {
return stringRedisTemplate.opsForValue().get(key);
}
}
使用 postman 送请求: localhost:8080/string/put?key=hello&value=world

localhost:8080/string/get?key=hello

2. 对象存储
在上述使用中,是无法存储对象的,存储对象的话需要使用 RedisTemplate 并且要使用响应的序列化机制, 下面我们就来测试下:
1. 引入序列化的 jar 包,这里我们是使用 jackson
<dependency>
<groupId>com.fasterxml.jackson.core</groupId>
<artifactId>jackson-core</artifactId>
<version>2.9.5</version>
</dependency>
<dependency>
<groupId>com.fasterxml.jackson.core</groupId>
<artifactId>jackson-databind</artifactId>
<version>2.9.5</version>
</dependency>
2. 添加 redis 配置类
@Configuration
public class RedisConfig {

@Bean
public RedisTemplate<String, Object> redisTemplate(RedisConnectionFactory redisConnectionFactory) {

RedisTemplate<String, Object> redisTemplate = new RedisTemplate<>();

// 使用 Jackson2JsonRedisSerializer 来序列化和反序列化 redis 的 value 值
redisTemplate.setValueSerializer(new GenericJackson2JsonRedisSerializer());
redisTemplate.setHashValueSerializer(new GenericJackson2JsonRedisSerializer());

// 使用 StringRedisSerializer 来序列化和反序列化 redis 的 ke
redisTemplate.setKeySerializer(new StringRedisSerializer());
redisTemplate.setHashKeySerializer(new StringRedisSerializer());

// 开启事务
redisTemplate.setEnableTransactionSupport(true);

redisTemplate.setConnectionFactory(redisConnectionFactory);

return redisTemplate;
}
}

3. 添加测试 controller
@RestController
@RequestMapping(value = “/object”)
public class RedisObjectController {

@Autowired
private RedisTemplate<String, Object> redisTemplate;

@GetMapping(“/get/{username}”)
public Object get(@PathVariable String username) {
return redisTemplate.opsForValue().get(username);
}

@PutMapping(“/put”)
public void put(String username, String nickname) {
User user = new User(username, nickname);
redisTemplate.opsForValue().set(username, user);
}
}

4. 使用 postman 测试

使用 redis 客户端查看
192.168.187.11:6379> get qianjiangtao
“{\”@class\”:\”com.lvmama.tony.model.User\”,\”username\”:\”qianjiangtao\”,\”nickname\”:\”Tony-J\”}”
3.spring boot 整合 redis 自动化配置原理分析
我们都知道 spring boot 自动化配置中的配置都是通过 spring-configuration-metadata.json 来约束的,同理 redis 也是这样的,我们配置了 spring.redis.host, 不妨来找下这个配置项
{
“name”: “spring.redis.host”,
“type”: “java.lang.String”,
“description”: “Redis server host.”,
“sourceType”: “org.springframework.boot.autoconfigure.data.redis.RedisProperties”,
“defaultValue”: “localhost”
}
从这能看出来 redis 的配置都是通过 RedisProperties 这个类来配置的,在这里面我们能看到众多的 redis 配置及默认配置,我们可以从一个入口切入,就拿 port 切入, 来看下 port 在哪设置的
org.springframework.boot.autoconfigure.data.redis.RedisConnectionConfiguration#getStandaloneConfig 看出在 RedisConnectionConfiguration 中的 getStandaloneConfig 中赋值的, 那这个方法又是谁调用的呢? 继续找?

从图中能看出来有两个地方可能会调用,从类的名字能看出来,spring boot 是支持 Jedis 和 Lettuce 两种客户端来操作 redis,那到底是用哪个呢? 都看看呗

从图中截取的源码中能看出来,我是使用了 LettuceConnectionConfiguration,看注解是我引入了 RedisClient,我什么时候引入的?于是我就看看 maven 的依赖

从 maven 依赖中能看出一些重要的信息:

1.spring-boot-starter-data-redis 中其实用的是 spring-data-redis,其实是包装了下
2. 依赖了 lettuce-core,原来是从这里引入的,怪不得

如何验证呢?不能瞎说
​ 要想知道很简单的,在我们自己写的 RedisConfig 中打下断点,看看用的 RedisConnectionFactory 到底是不是 LettuceConnectionFactory 就能证明了

果然如此!
简单的流程就是:
1.spring boot 通过 application 配置加载 redis 配置
2. 解析封装成 RedisProperties
3. 根据 @ConditionalOnClass 判断使用哪个 Redis 客户端,封装成 LettuceClientConfiguration 并创建 LettuceConnectionFactory
4. 通过 @Bean 创建我们自己的配置类在 LettuceConnectionFactory 基础上添加我们自己自定义的配置

正文完
 0