SpringBoot中RedisConfig配置类

客官°小女子只卖身不卖艺 2023-10-09 15:43 45阅读 0赞

#### 文章目录 ####

*  前言
 *  一、引入起步依赖
 *  二、RedisConfig配置类
 *   *  1.RedisConfig
     *  2.FastJson2JsonRedisSerializer

--------------------

## 前言 ##

本文主要记录SpringBoot中集成的Redis的配置类

--------------------

## 一、引入起步依赖 ##

> 代码示例

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

## 二、RedisConfig配置类 ##

### 1.RedisConfig ###

> 代码如下（示例）：

package com.lp.framework.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.StringRedisSerializer;
    
    /**
     * @author LuoPing
     * @project IntelliJ IDEA
     * 
     */
    @Configuration
    public class RedisConfig {
        
        @Bean
        public RedisTemplate<Object,Object> redisTemplate(RedisConnectionFactory factory){
        
            RedisTemplate<Object, Object> redisTemplate = new RedisTemplate<>();
            redisTemplate.setConnectionFactory(factory);
            FastJson2JsonRedisSerializer<Object> json2JsonRedisSerializer = new FastJson2JsonRedisSerializer<>(Object.class);
            // 使用StringRedisSerializer来序列化和反序列化redis的key值
            StringRedisSerializer serializer = new StringRedisSerializer();
            redisTemplate.setKeySerializer(serializer);
            redisTemplate.setValueSerializer(json2JsonRedisSerializer);
            //hash的value也采用jackson序列化方式
            redisTemplate.setHashKeySerializer(serializer);
            redisTemplate.setHashValueSerializer(json2JsonRedisSerializer);
            redisTemplate.afterPropertiesSet();
            return redisTemplate;
        }
    }

### 2.FastJson2JsonRedisSerializer ###

代码如下（示例）：

package com.lp.framework.config;
    
    import com.alibaba.fastjson2.JSON;
    import com.alibaba.fastjson2.JSONReader;
    import com.alibaba.fastjson2.JSONWriter;
    import org.springframework.data.redis.serializer.RedisSerializer;
    import org.springframework.data.redis.serializer.SerializationException;
    
    import java.nio.charset.Charset;
    
    /**
     * Redis使用FastJson序列化
     * 
     */
    public class FastJson2JsonRedisSerializer<T> implements RedisSerializer<T>
    {
        
        public static final Charset DEFAULT_CHARSET = Charset.forName("UTF-8");
    
        private Class<T> clazz;
    
        public FastJson2JsonRedisSerializer(Class<T> clazz)
        {
        
            super();
            this.clazz = clazz;
        }
    
        @Override
        public byte[] serialize(T t) throws SerializationException
        {
        
            if (t == null)
            {
        
                return new byte[0];
            }
            return JSON.toJSONString(t, JSONWriter.Feature.WriteClassName).getBytes(DEFAULT_CHARSET);
        }
    
        @Override
        public T deserialize(byte[] bytes) throws SerializationException
        {
        
            if (bytes == null || bytes.length <= 0)
            {
        
                return null;
            }
            String str = new String(bytes, DEFAULT_CHARSET);
    
            return JSON.parseObject(str, clazz, JSONReader.Feature.SupportAutoType);
        }
    }

--------------------