RedisTemplate序列化

news2024/11/26 15:42:48

SpringBoot整合Redis，配置RedisTemplate序列化。如果使用StringRedisTemplate，那么不需要配置序列化，但是StringRedisTemplate只能存储简单的String类型数据，如图：

如果使用StringRedisTemplate存储一个常规对象，只能转换成JSON字符串存储，取出后再把JSON字符串转成需要的对象，比较麻烦，所以一般使用RedisTemplate。

一、RedisTemplate配置使用

使用RedisTemplate之前一般需要配置序列化方式，这里以单节点Redis为例：

1、添加maven依赖

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

2、添加配置

import lombok.extern.slf4j.Slf4j;
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;
import org.springframework.data.redis.serializer.StringRedisSerializer;

/**
 * Redis配置
 */
@Slf4j
@Configuration
public class RedisConfig {

    /**
     * 实例化 RedisTemplate 对象
     * 设置序列化方式
     * 默认序列化为：JdkSerializationRedisSerializer
     * JdkSerializationRedisSerializer       占用空间小，序列化速度慢，客户端可读性差
     * GenericJackson2JsonRedisSerializer    占用空间大，序列化速度快，客户端可读性好
     *
     * @return
     */
    @Bean
    public RedisTemplate<String, Object> redisTemplate(RedisConnectionFactory factory) {
        log.info("redisTemplate init. serializer=GenericJackson2JsonRedisSerializer");
        RedisTemplate<String, Object> redisTemplate = new RedisTemplate<>();
        StringRedisSerializer stringRedisSerializer = new StringRedisSerializer();
        // 设置 key 的序列化器 StringRedisSerializer
        redisTemplate.setKeySerializer(stringRedisSerializer);
        redisTemplate.setHashKeySerializer(stringRedisSerializer);
        // 设置 value 的序列化器 GenericJackson2JsonRedisSerializer
        GenericJackson2JsonRedisSerializer genericJackson2JsonRedisSerializer = new GenericJackson2JsonRedisSerializer();
        redisTemplate.setHashValueSerializer(genericJackson2JsonRedisSerializer);
        redisTemplate.setValueSerializer(genericJackson2JsonRedisSerializer);
        redisTemplate.setConnectionFactory(factory);
        return redisTemplate;
    }

3、使用

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.stereotype.Component;
import java.util.concurrent.TimeUnit;

/**
 * Redis常用方法
 */
@Component
public class RedisCache {

    /**
     * 1分钟，单位：秒
     */
    private static final long ONE_MINUTE = 60;

    @Autowired
    private RedisTemplate redisTemplate;

    /**
     * 存储
     * @param key   唯一键
     * @param value     值
     * @param expireTime    过期时间，单位：秒
     * @param <T>
     */
    public <T> void set(String key, T value, long expireTime) {
        redisTemplate.opsForValue().set(key, value, expireTime, TimeUnit.SECONDS);
    }

    /**
     * 查询
     * @param key   唯一键
     * @param <T>
     * @return
     */
    public <T> T get(String key) {
        return (T) redisTemplate.opsForValue().get(key);
    }