springboot实战(八)之整合redis
目录
序言:
Redis是我们Java开发中,使用频次非常高的一个nosql数据库,数据以key-value键值对的形式存储在内存中。它的使用场景多样可以做缓存,分布式锁,自增序列等,且数据类型丰富,支持5中数据类型的存储,分别是String、has、list、set、zset,还有单线程作业速度超快。
使用redis的方式也和我们使用关系型数据库的方式一样,首先我们要在自己的本机电脑或者服务器上安装一个redis的服务器,然后在我们的项目中通过java进行其客户端集成,最后通过java集成的客户端完成对redis的增删改查操作。
Redis的Java客户端类型常见的有jedis, redission,lettuce等,所以我们在集成的时候,可以选择直接集成这些原生客户端。但是在springBoot中更常见的方式是集成spring-data-redis,这是spring提供的一个专门用来操作redis的项目,封装了对redis的常用操作,里边主要封装了jedis和lettuce两个客户端,但是默认使用的是lettuce客户端。
环境:
版本:spring boot:2.7.15
jdk:1.8
redis:安装最新的redis服务端就OK了
依赖:
由于springboot项目已经集成了各种中间件的starter,所以这里我们直接引用redis的starter依赖就行了。
<!-- redis 依赖 -->
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-data-redis</artifactId>
</dependency>
配置:
依赖添加完后,我们需要在yml文件中进行redis链接配置。
spring:
redis:
host: localhost
#有密码就写,没有就注释掉
#password:
port: 6379
database: 1
完整的配置信息:
server:
port: 8081
spring:
datasource:
driver-class-name: com.mysql.cj.jdbc.Driver
url: jdbc:mysql://localhost:3306/test?characterEncoding=utf-8&autoReconnect=true&failOverReadOnly=false&useSSL=false&serverTimezone=Asia/Shanghai
username: root
password: root
redis:
host: localhost
#有密码就写,没有就注释掉
#password:
port: 6379
database: 1
#这里配置日志生效文件,用于多环境部署时切换(通常部署会有三个环境:线上、测试、开发)
logging:
config: classpath:log4j2/log4j2-dev.yml
测试:
配置完以上信息后,我们可以创建一个测试类进行测试。
package com.iterge.iterge_pre.redis;
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.RedisTemplate;
/**
* @author liuph
* @date 2023/9/26 14:36:45
*/
@SpringBootTest
public class RedisTest {
@Autowired
private RedisTemplate redisTemplate;
@Test
public void stringTest(){
redisTemplate.opsForValue().set("name","hi redis!");
}
@Test
public void getStringTest(){
Object name = redisTemplate.opsForValue().get("name");
System.out.println(name);
}
}
图上我们可以看到获取的value的时候,返回值类型是object,控制台打印的时候信息也是正确的。
但是我们通过终端连接redis后进行信息查看,发现get name是没有数据的,是不是很奇怪,我们明明插入进去了并且在程序中查了出来怎么就没有呢?然后我们用keys *name*,命令模糊查找下我们的key,发现有个"xacxedx00x05tx00x04name",然后get "xacxedx00x05tx00x04name"发现,好像是我们我们设置的“hi redis”,图如下。但是为什么key和value都有个前缀?上述涉及到一切问题这就涉及到redis的序列化操作了,接着往下看序列化配置和描述。
命令:
#连接redis的客户端命令
redis-cli
#选择使用的数据库,因为我们用的是1,所以是select 1
select 1
redis序列化配置:
Redis的序列化是我们在使用RedisTemplate的过程中非常需要注意的事情。上面的案例中,其实我们并没有特殊设置redis的序列化方式,那么它其实使用的是默认的序列化方式。RedisTemplate这个类的泛型是<String,Object>,也就是为什么刚刚提到返回值类型是Object了,它写入的其实是个对象。
什么是redis的序列化呢?这个对象采取什么方式序列化存入内存中就是它的序列化方式。
就是我们把对象存入到redis中到底以什么方式存储的,可以是二进制数据,可以是xml也可以是json。比如说我们经常会将POJO对象存储到 Redis 中,一般情况下会使用 JSON 方式序列化成字符串,存储到 Redis 中 。
Redis本身提供了一下一种序列化的方式:
- GenericToStringSerializer: 可以将任何对象泛化为字符串并序列化
- JacksonJsonRedisSerializer: 序列化object对象为json字符串
- Jackson2JsonRedisSerializer: 跟JacksonJsonRedisSerializer实际上是一样的
- JdkSerializationRedisSerializer: 序列化java对象,默认序列化方式
- StringRedisSerializer: 简单的字符串序列化
如果我们存储的是String类型,默认使用的是StringRedisSerializer 这种序列化方式。如果我们存储的是对象,默认使用的是 JdkSerializationRedisSerializer,也就是Jdk的序列化方式(通过ObjectOutputStream和ObjectInputStream实现,缺点是我们无法直观看到存储的对象内容)。
配置:
package com.iterge.iterge_pre.config;
import com.fasterxml.jackson.annotation.JsonAutoDetect;
import com.fasterxml.jackson.annotation.JsonTypeInfo;
import com.fasterxml.jackson.annotation.PropertyAccessor;
import com.fasterxml.jackson.databind.ObjectMapper;
import com.fasterxml.jackson.databind.jsontype.impl.LaissezFaireSubTypeValidator;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.data.redis.connection.RedisConnectionFactory;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.data.redis.serializer.Jackson2JsonRedisSerializer;
import org.springframework.data.redis.serializer.StringRedisSerializer;
/**
* @author liuph
* @date 2023/9/26 15:47:09
*/
@Configuration
public class RedisConfig {
@Bean(name = "redisTemplate")
public RedisTemplate<String, Object> getRedisTemplate(RedisConnectionFactory factory) {
RedisTemplate<String, Object> redisTemplate = new RedisTemplate<>();
redisTemplate.setConnectionFactory(factory);
Jackson2JsonRedisSerializer jackson2JsonRedisSerializer = new Jackson2JsonRedisSerializer(Object.class);
ObjectMapper objectMapper = new ObjectMapper();
objectMapper.setVisibility(PropertyAccessor.ALL, JsonAutoDetect.Visibility.ANY);
// 方法过期,改为下面代码
//objectMapper.enableDefaultTyping(ObjectMapper.DefaultTyping.NON_FINAL);
objectMapper.activateDefaultTyping(LaissezFaireSubTypeValidator.instance ,
ObjectMapper.DefaultTyping.NON_FINAL, JsonTypeInfo.As.PROPERTY);
jackson2JsonRedisSerializer.setObjectMapper(objectMapper);
// key的序列化类型
redisTemplate.setKeySerializer(new StringRedisSerializer());
redisTemplate.setHashKeySerializer(new StringRedisSerializer());
// value的序列化类型
redisTemplate.setValueSerializer(jackson2JsonRedisSerializer);
redisTemplate.setHashValueSerializer(jackson2JsonRedisSerializer);
redisTemplate.afterPropertiesSet();
return redisTemplate;
}
}
测试:
如下图所示可以看出是,redisTemplate中的key和value的序列化方式已经改为我们所设置的。
再通过终端查看设置结果,key:user设置成功,并且get user能正常获取到存储的value。
连接池:
在生产环境中我们往往需要配置redis连接池,目的是为了增加对于redis数据库连接的管理,提升访问的效率,也保证了对资源的合理利用。
由于我们使用的是默认的客户端lettuce,那么我们就用lettuce连接池,如果大家想使用jedis连接池,改成jedis连接池就OK,并且需要引入jedis核心jar包。
lettuce连接池配置信息如下:
首先需要添加一个连接池连接依赖,不加依赖配置不会生效,切记哦~
<dependency>
<groupId>org.apache.commons</groupId>
<artifactId>commons-pool2</artifactId>
</dependency>
spring:
redis:
host: localhost
#有密码就写,没有就注释掉
#password:
port: 6379
database: 1
lettuce:
pool:
#连接池同时能维持的最大连接数
max-active: 16
#最多维持多少个空闲连接
max-idle: 16
#最少维持多少个空闲连接
min-idle: 4
配置好以上信息就OK,运行程序,查看连接池配置是否生效,如图,如果有以下信息说明配置已经生效,配置完成:
注意如果不添加上面的链接池依赖,redisTemplate运行时是没有连接池信息的,如下图:
创作不易,您的鼓励是我前进的动力,如果有用记得点点关注哈~