1
public class JedisConnectionFactory {
2

3
    private static JedisPool jedisPool;
4

5
    static {
6
        // 配置连接池
7
        JedisPoolConfig poolConfig = new JedisPoolConfig();
8
        poolConfig.setMaxTotal(8);
9
        poolConfig.setMaxIdle(8);
10
        poolConfig.setMinIdle(0);
11
        poolConfig.setMaxWaitMillis(1000);
12
        // 创建连接池对象，参数：连接池配置、服务端 IP、服务端端口、超时时间、密码
13
        jedisPool = new JedisPool(poolConfig, "101.42.225.160", 6379, 1000, "root");
14
    }
15

16
    public static Jedis getJedis() {
17
        return jedisPool.getResource();
18
    }
19
}

1
@SpringBootTest
2
class RedisTestApplicationTests {
3

4
    private Jedis jedis = JedisConnectionFactory.getJedis();
5

6
    @Test
7
    void testString() {
8
        jedis.set("name", "Kyle");
9
        String name = jedis.get("name");
10
        System.out.println("name = " + name);
11
    }
12

13
    @Test
14
    void testHash() {
15
        jedis.hset("reggie:user:1", "name", "Jack");
16
        jedis.hset("reggie:user:2", "name", "Rose");
17
        jedis.hset("reggie:user:3", "name", "Kyle");
18
        jedis.hset("reggie:user:1", "age", "21");
19
        jedis.hset("reggie:user:2", "age", "18");
20
        jedis.hset("reggie:user:3", "age", "18");
21
        Map<String, String> map = jedis.hgetAll("reggie:user:1");
22
        System.out.println(map);
23
    }
24

25
    @AfterEach
26
    void tearDown() {
27
        if (jedis != null) {
28
            jedis.close();
29
        }
30
    }
31
}

1
@Configuration
2
public class RedisConfig {
3

4
    @Bean
5
    public RedisTemplate<String, Object> redisTemplate(RedisConnectionFactory connectionFactory) {
6
        // 创建 RedisTemplate 对象
7
        RedisTemplate<String, Object> template = new RedisTemplate<>();
8
        // 设置连接工厂
9
        template.setConnectionFactory(connectionFactory);
10
        // 创建 JSON 序列化工具
11
        GenericJackson2JsonRedisSerializer jsonRedisSerializer =
12
                new GenericJackson2JsonRedisSerializer();
13
        // 设置 Key 的序列化
14
        template.setKeySerializer(RedisSerializer.string());
15
        template.setHashKeySerializer(RedisSerializer.string());
16
        // 设置 Value 的序列化
17
        template.setValueSerializer(jsonRedisSerializer);
18
        template.setHashValueSerializer(jsonRedisSerializer);
19
        // 返回
20
        return template;
21
    }
22
}

1
@Autowired
2
private StringRedisTemplate stringRedisTemplate;
3

4
@Autowired
5
private ObjectMapper mapper;
6

7
@Test
8
void stringTest() throws JsonProcessingException {
9
    // 创建对象
10
    User user = new User("张三", 18);
11
    // 手动序列化
12
    String json = mapper.writeValueAsString(user);
13
    // 写入数据
14
    stringRedisTemplate.opsForValue().set("userdata", json);
15
    // 获取数据
16
    String userdata = stringRedisTemplate.opsForValue().get("userdata");
17
    // 手动反序列化
18
    User readValue = mapper.readValue(userdata, User.class);
19
    System.out.println(readValue);
20
}