SpringBoot整合Redis

>>强大,10k+点赞的 SpringBoot 后台管理系统竟然出了详细教程!

redis是最常用的缓存数据库,常用于存储用户登录token、临时数据、定时相关数据等。

redis是单线程的,所以redis的操作是原子性的,这样可以保证不会出现并发问题。

redis基于内存,速度非常快,据测试,redis读的速度是110000次/s,写的速度是81000次/s

本节介绍SpringBoot引入redis,以及使用RedisTemplate来操作redis数据。

采用SpringBoot 2.1.9.RELEASE,对应示例代码在:https://github.com/laolunsi/spring-boot-examples/tree/master/07-spring-boot-redis-demo


一、A Simple Demo-使用SpringBoot连接redis

maven:

<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-data-redis</artifactId>
</dependency>

yml:

server:
port: 8867
spring:
redis:
host: localhost
port: 6379
#password: ''
database: 6

测试类:

@SpringBootTest
@RunWith(SpringRunner.class)
public class RedisTest {

@Autowired
private RedisTemplate redisTemplate;

@Test
public void testRedis() {
String key = "hello";
redisTemplate.opsForValue().set("hello", "你好");

String res = (String) redisTemplate.opsForValue().get(key);
System.out.println(res);
}
}

执行结果:

SpringBoot整合Redis

看一下redis:

SpringBoot整合Redis

这里存在一个问题:默认的存储方式导致key在redis-manager里面显示出来是乱码的,并且存储结果是二进制了。这样不利用我们查看redis里面的数据。

我们需要自定义redis存储的序列化规则。


二、解决RedisTemplate默认序列化的问题

完善一下maven:

<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter</artifactId>
</dependency>

<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-test</artifactId>
<scope>test</scope>
</dependency>

<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-web</artifactId>
</dependency>

<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-data-redis</artifactId>
</dependency>

定义RedisConfig类:

/**
* redis配置
* 主要是配置Redis的序列化规则,替换默认的jdkSerializer
* key的序列化规则用StringRedisSerializer
* value的序列化规则用Jackson2JsonRedisSerializer
*/

@Configuration
public class RedisConfig {

@Bean
public RedisTemplate<Object, Object> redisTemplate(RedisConnectionFactory connectionFactory) {
RedisTemplate<Object, Object> redisTemplate = new RedisTemplate<>();
redisTemplate.setConnectionFactory(connectionFactory);

// 使用Jackson2JsonRedisSerialize替换默认序列化
Jackson2JsonRedisSerializer jackson2JsonRedisSerializer = new Jackson2JsonRedisSerializer(Object.class);

ObjectMapper objectMapper = new ObjectMapper();
objectMapper.setVisibility(PropertyAccessor.ALL, JsonAutoDetect.Visibility.ANY);
objectMapper.enableDefaultTyping(ObjectMapper.DefaultTyping.NON_FINAL);

jackson2JsonRedisSerializer.setObjectMapper(objectMapper);

// 设置key和value的序列化规则
redisTemplate.setKeySerializer(new StringRedisSerializer());
redisTemplate.setValueSerializer(jackson2JsonRedisSerializer);

redisTemplate.setHashKeySerializer(new StringRedisSerializer());
redisTemplate.setHashValueSerializer(jackson2JsonRedisSerializer);

redisTemplate.afterPropertiesSet();
return redisTemplate;
}
}

删除之前的key,重新执行一下test方法:SpringBoot整合Redis

下面来演示一下SpringBoot使用RedisTemplate进行redis数据的操作


三、基于SpringBoot的redis操作——key/list/hash

RedisTemplate内置redis操作如下:

SpringBoot整合Redis

这里主要展示value/hash/list三种用法:


3.1 RedisTemplate.opsForValue

  @Test
public void testKeyOps()
{
// 测试redis操作key-value形式
Set<String> keySet = new HashSet<>();

String key1 = "name";
keySet.add(key1);
// 存储简单的key-value,并设置过期时间
redisTemplate.opsForValue().set(key1, "eknown", 1, TimeUnit.MINUTES);

String key2 = "token:user1";
String key3 = "token:user2";
keySet.add(key2);
keySet.add(key3);
//
redisTemplate.opsForValue().set(key2, "{"name":"eknown"}, "role":"admin"");
redisTemplate.opsForValue().set(key3, "{"name":"test"}, "role":"test"");

// 根据key的集合获取多个value
List<String> valueList = redisTemplate.opsForValue().multiGet(keySet);
for (String value : valueList) {
System.out.println(value);
}
}

执行结果:

SpringBoot整合Redis

redis中的数据:

SpringBoot整合Redis

redis中的key显示出了一个层级关系,这个小技巧对于实际项目有个非常好的作用:通过prefix:suffix这样的形式,可以将redis中存储的数据分出层级。


3.2 RedisTemplate.opsForHash

清空该database下的数据,测试redisTemplate.opsForHash:

    @Test
public void testHashOps() {
String key = "hash";
// 单次往hash中存放一个数据
redisTemplate.opsForHash().put(key, "1", "你好");

Map<String, Object> map = new HashMap<>();
map.put("2", "hello");
map.put("3a", "china1=2");

// 一次性向hash中存放一个map
redisTemplate.opsForHash().putAll(key, map);

// 获取hash下的所有key和value
Map<String, Object> resultMap = redisTemplate.opsForHash().entries(key);
for (String hashKey : resultMap.keySet()) {
System.out.println(hashKey + ": " + resultMap.get(hashKey));
}
}

执行结果:

SpringBoot整合Redis

redis:SpringBoot整合Redis


3.3 RedisTemplate.opsForList

    @Test
public void testListOps()
{
String listKey = "list";
redisTemplate.opsForList().leftPush(listKey, "first value"); // 从list最左边插入数据
redisTemplate.opsForList().leftPush(listKey, "second value but left");
redisTemplate.opsForList().rightPush(listKey, 3); // 从list最右边插入数据

List<Object> list = new ArrayList<>();
list.add("hello");
list.add("http://www.eknown.cn");
list.add(23344);
list.add(false);
redisTemplate.opsForList().rightPushAll(listKey, list); // 从list右边批量插入数据

long size = redisTemplate.opsForList().size(listKey);
if (size > 0) {
for (int i = 0; i < size -1 ; i++) {
// 从list最左边开始读取list中的数据,注意pop会导致出栈,也就是数据被取出来了(redis中就没有这个值了)
// 此处我们读取size-1条数据,仅留下最后一条数据
System.out.println(i + ":" + redisTemplate.opsForList().leftPop(listKey).toString());
}
}
}

执行上面的脚本,注意在最后的读取list数据代码前面加一个断点,此时redis中是这样的:

SpringBoot整合Redis

放开断点,程序继续执行,控制台如下:

SpringBoot整合Redis

注意,此时redis中仅剩余最后一条数据,这是由于pop的问题,list中的数据被读取并删除了:

SpringBoot整合Redis


好了,这一节主要讲了SpringBoot引入redis,以及使用redis的一些基本操作和相关技巧,在此基础上,我们可以让我们的项目变得更加快速、灵活!


原文始发于微信公众号(猿生物语):SpringBoot整合Redis