6.4 定制化

---

需求：保存一个 Person 对象到 redis

• 创建 Person 类

package com.zhong.redis.entity;import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;import java.io.Serializable;
import java.util.Date;/*** @ClassName : Person* @Description :* @Author : zhx* @Date: 2024-06-14 16:11*/
@Data
@AllArgsConstructor
@NoArgsConstructor
public class Person implements Serializable {// implements Serializable 实现序列化接口不然会报错private Long id;private String name;private Integer age;private Date birthday;
}

• 创建 RedisTestController 接口

package com.zhong.redis.controller;import com.zhong.redis.entity.Person;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.data.redis.core.StringRedisTemplate;
import org.springframework.data.redis.core.ValueOperations;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.RestController;import java.util.Date;/*** @ClassName : RedisTestController* @Description :* @Author : zhx* @Date: 2024-06-14 15:13*/
@RestController
public class RedisTestController {@Autowired  // 如果给 redis 中保存数据会使用默认序列化机制，导致 redis 中保存对象不合适RedisTemplate redisTemplate;@GetMapping("/person/save")public String savePerson() {Person person = new Person(1L,"小钟",23,new Date());redisTemplate.opsForValue().set("person", person);return "ok";}@GetMapping("/person/get")public Person getPerson() {return (Person) redisTemplate.opsForValue().get("person");}
}

• 浏览器依次访问接口测试

http://localhost:8080/person/save

http://localhost:8080/person/get

• 查看 Redis 数据库发现乱码

• 开始定制

1、创建 RedisConfiguartion 配置类将 对象 序列化为 JSON

package com.zhong.redis.config;import org.springframework.boot.autoconfigure.condition.ConditionalOnMissingBean;
import org.springframework.boot.autoconfigure.condition.ConditionalOnSingleCandidate;
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.GenericJackson2JsonRedisSerializer;/*** @ClassName : RedisConfiguartion* @Description :* @Author : zhx* @Date: 2024-06-14 16:33*/@Configuration
public class RedisConfiguration {/*** template.setDefaultSerializer(new GenericJackson2JsonRedisSerializer()); 所有使用 JSON 存储* @param redisConnectionFactory 自动配置好了连接工程* @return*/@Beanpublic RedisTemplate<Object, Object> redisTemplate(RedisConnectionFactory redisConnectionFactory) {RedisTemplate<Object, Object> template = new RedisTemplate<>();template.setConnectionFactory(redisConnectionFactory);// 将对象转换为 JSON 字符串的序列化工具template.setDefaultSerializer(new GenericJackson2JsonRedisSerializer());return template;}}

2、重新启动项目并按上述流程访问 接口