RedisTemplate 的基本使用手把手教

1、引入 spring-boot-starter-data-redis 依赖

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

2、在 application.yml 配置 Redis 的信息

spring:
 redis:
  host: 127.0.0.1
  port: 6379
  password: 123456
  database: 0 # 几号库
  lettuce:
   pool:
    max-active: 8 # 最大连接
    max-idle: 8 # 最大空闲连接
    min-idle: 0 # 最小空闲连接
    max-wait: 100ms # 连接等待时间

3、注入 RedisTemplate

@Autowired
private RedisTemplate redisTemplate;

Demo1

package com.test;


import org.junit.Test;
import org.junit.runner.RunWith;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;
import org.springframework.data.redis.core.DefaultTypedTuple;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.data.redis.core.ZSetOperations;
import org.springframework.test.context.junit4.SpringRunner;

import java.util.HashSet;
import java.util.List;
import java.util.Map;
import java.util.Set;

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

 // 注入 RedisTemplate
 @Autowired
 private RedisTemplate redisTemplate;

 // String 类型
 @Test
 public void testString () {
 redisTemplate.opsForValue().set("name", "xiaobai");
 Object name = redisTemplate.opsForValue().get("name");
 System.out.println(name);
 }

 // Hash 类型
 @Test
 public void testHash () {
 redisTemplate.opsForHash().put("user1", "name", "clarence");
 redisTemplate.opsForHash().put("user1", "age", "25");
 Map map = redisTemplate.opsForHash().entries("user1");
 System.out.println(map);
 }

 // List 类型
 @Test
 public void testList () {
 redisTemplate.opsForList().leftPushAll("names", "xiaobai", "xiaohei", "xiaolan");
 List<String> names = redisTemplate.opsForList().range("names", 0, 3);
 System.out.println(names);
 }

 // Set 类型
 @Test
 public void testSet () {
 redisTemplate.opsForSet().add("set", "a", "b", "c");
 Set<String> set = redisTemplate.opsForSet().members("set");
 System.out.println(set);
 }

 // SortedSet 类型
 @Test
 public void testSortedSet () {
 redisTemplate.opsForZSet().add("class", "xiaobai", 90);
 Set aClass = redisTemplate.opsForZSet().rangeByScore("class", 90, 100);
 System.out.println(aClass);
 Set<ZSetOperations.TypedTuple<String>> set = new HashSet<>();
 set.add(new DefaultTypedTuple<>("xiaohei", 88.0));
 set.add(new DefaultTypedTuple<>("xiaohui", 94.0));
 set.add(new DefaultTypedTuple<>("xiaolan", 84.0));
 set.add(new DefaultTypedTuple<>("xiaolv", 82.0));
 set.add(new DefaultTypedTuple<>("xiaohong", 99.0));
 redisTemplate.opsForZSet().add("class", set);
 Set aClass1 = redisTemplate.opsForZSet().range("class", 0, 6);
 System.out.println(aClass1);
 }
}

序列化

1、默认是 JdkSerializationRedisSerializer

2、添加配置文件，使用 String 序列化、Json 序列化

package com.test.config;

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.RedisSerializer;

@Configuration
public class RedisConfig {

 @Bean
 public RedisTemplate<String, Object> redisTemplate(RedisConnectionFactory connectionFactory) {
 // 创建 RedisTemplate 对象
 RedisTemplate<String, Object> redisTemplate = new RedisTemplate<>();
 // 设置连接工厂
 redisTemplate.setConnectionFactory(connectionFactory);
 // 设置 Key 的序列化 - String 序列化 RedisSerializer.string() => StringRedisSerializer.UTF_8
 redisTemplate.setKeySerializer(RedisSerializer.string());
 redisTemplate.setHashKeySerializer(RedisSerializer.string());
 // 设置 Value 的序列化 - JSON 序列化 RedisSerializer.json() => GenericJackson2JsonRedisSerializer
 redisTemplate.setValueSerializer(RedisSerializer.json());
 redisTemplate.setHashValueSerializer(RedisSerializer.json());
 // 返回
 return redisTemplate;
 }
}

<!--Jackson依赖-->
<dependency>
 <groupId>com.fasterxml.jackson.core</groupId>
 <artifactId>jackson-databind</artifactId>
 <version>2.11.4</version>
</dependency>

package com.test.entity;

import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;

@Data
@NoArgsConstructor
@AllArgsConstructor
public class User {
 private String name;
 private Integer age;
}

Demo2

package com.test;


import com.test.entity.User;
import org.junit.Test;
import org.junit.runner.RunWith;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;
import org.springframework.data.redis.core.DefaultTypedTuple;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.data.redis.core.ZSetOperations;
import org.springframework.test.context.junit4.SpringRunner;

import java.util.HashSet;
import java.util.List;
import java.util.Map;
import java.util.Set;

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

 // 注入 RedisTemplate
 @Autowired
 private RedisTemplate redisTemplate;

 // String 类型
 @Test
 public void testString () {
 redisTemplate.opsForValue().set("name", "xiaobai");
 Object name = redisTemplate.opsForValue().get("name");
 System.out.println(name);
 }
 @Test
 public void testSaveUser() {
 redisTemplate.opsForValue().set("user", new User("小白", 23));
 User user = (User) redisTemplate.opsForValue().get("user");
 System.out.println(user);
 }
}

运行结果

引入 fastjson 依赖

<!--fastjson依赖-->
<dependency>
 <groupId>com.alibaba</groupId>
 <artifactId>fastjson</artifactId>
 <version>1.2.62</version>
</dependency>

运行结果