1
{
2
  id: 1,
3
  name: "张三",
4
  orders: [
5
    {
6
       id: 1,
7
       item: {
8
     id: 10, title: "荣耀6", price: 4999
9
       }
10
    },
11
    {
12
       id: 2,
13
       item: {
14
     id: 20, title: "小米11", price: 3999
15
       }
16
    }
17
  ]
18
}

1
    项目名:业务名:类型:id

1
<!--jedis-->
2
<dependency>
3
    <groupId>redis.clients</groupId>
4
    <artifactId>jedis</artifactId>
5
    <version>3.7.0</version>
6
</dependency>
7
<!--单元测试-->
8
<dependency>
9
    <groupId>org.junit.jupiter</groupId>
10
    <artifactId>junit-jupiter</artifactId>
11
    <version>5.7.0</version>
12
    <scope>test</scope>
13
</dependency>

1
private Jedis jedis;
2

3
@BeforeEach
4
void setUp() {
5
    // 1.建立连接
6
    // jedis = new Jedis("192.168.150.101", 6379);
7
    jedis = JedisConnectionFactory.getJedis();
8
    // 2.设置密码
9
    jedis.auth("123321");
10
    // 3.选择库
11
    jedis.select(0);
12
}

1
@Test
2
void testString() {
3
    // 存入数据
4
    String result = jedis.set("name", "虎哥");
5
    System.out.println("result = " + result);
6
    // 获取数据
7
    String name = jedis.get("name");
8
    System.out.println("name = " + name);
9
}
10

11
@Test
12
void testHash() {
13
    // 插入hash数据
14
    jedis.hset("user:1", "name", "Jack");
15
    jedis.hset("user:1", "age", "21");
16

17
    // 获取
18
    Map<String, String> map = jedis.hgetAll("user:1");
19
    System.out.println(map);
20
}

1
@AfterEach
2
void tearDown() {
3
    if (jedis != null) {
4
        jedis.close();
5
    }
6
}

1
package com.heima.jedis.util;
2

3
import redis.clients.jedis.*;
4

5
public class JedisConnectionFactory {
6

7
    private static JedisPool jedisPool;
8

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

20
    public static Jedis getJedis(){
21
        return jedisPool.getResource();
22
    }
23
}

1
// 关闭连接池
2
    public static void closePool() {
3
        if (jedisPool != null) {
4
            jedisPool.close();
5
        }
6
    }

1
// 1. Spring Boot 自动配置会创建一个默认的 RedisTemplate Bean
2
// 2. 你创建了 RedisConfig 配置类
3
@Configuration
4
public class RedisConfig {
5

6
    // 3. 你用 @Bean 注解定义了一个方法
7
    @Bean
8
    public RedisTemplate<String, Object> redisTemplate(RedisConnectionFactory factory) {
9
        // 4. 你在这个方法里：
10
        RedisTemplate<String, Object> template = new RedisTemplate<>(); // a) 手动 new 一个新对象
11
        template.setConnectionFactory(factory);                           // b) 设置连接工厂
12
        template.setKeySerializer(new StringRedisSerializer());         // c) **自定义** key 序列化器
13
        template.setValueSerializer(new GenericJackson2JsonRedisSerializer()); // d) **自定义** value 序列化器
14
        // ...
15
        return template; // e) 将这个配置好的新对象返回
16
    }
17
    // 5. Spring 把你返回的这个对象（Bean）放入容器，替换掉了原来的默认对象
18
}

1
import lombok.AllArgsConstructor;
2
import lombok.Data;
3
import lombok.NoArgsConstructor;
4

5
@Data
6
@NoArgsConstructor
7
@AllArgsConstructor
8
public class User {
9
    private String name;
10
    private Integer age;
11
}
12

13
@Test
14
void testSaveUser() {
15
    User user = new User("lisi",19);
16
    redisTemplate.opsForValue().set("user:101",user);
17
    User o = (User) redisTemplate.opsForValue().get("user:101");
18
//注意 这个会自动反序列化回User 是因为在存的Json数据中第一行就有声明user
19
    System.out.println("user = " + o);
20
}

1
@Autowired
2
private StringRedisTemplate stringRedisTemplate;
3
// JSON序列化工具
4
private static final ObjectMapper mapper = new ObjectMapper();
5

6
@Test
7
void testSaveUser() throws JsonProcessingException {
8
    // 创建对象
9
    User user = new User("小王", 21);
10
    // 手动序列化
11
    String json = mapper.writeValueAsString(user);
12
    // 写入数据
13
    stringRedisTemplate.opsForValue().set("user:200", json);
14
    // 获取数据
15
    String jsonUser = stringRedisTemplate.opsForValue().get("user:200");
16
    // 手动反序列化
17
    User user1 = mapper.readValue(jsonUser, User.class);//指定反序列化对象class文件
18
    System.out.println("user1 = " + user1);
19

20
}

1
@SpringBootTest
2
class RedisStringTests {
3
    @Autowired
4
    private StringRedisTemplate stringRedisTemplate;
5
    @Test
6
    void testHash() {
7
        stringRedisTemplate.opsForHash().put("user:400", "name", "虎哥");
8
        stringRedisTemplate.opsForHash().put("user:400", "age", "21");
9

10
        Map<Object, Object> entries = stringRedisTemplate.opsForHash().entries("user:400");
11
//符合java语法习惯
12
        System.out.println("entries = " + entries);
13
    }
14
}