解决shiro-redis集成序列化的问题

迈不过友情╰ 2022-05-18 04:34 248阅读 0赞

1.spring-redis.xml

<?xml version="1.0" encoding="UTF-8"?>
    <beans xmlns="http://www.springframework.org/schema/beans"
           xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:cache="http://www.springframework.org/schema/cache"
           xmlns:c="http://www.springframework.org/schema/c" xmlns:p="http://www.springframework.org/schema/p"
           xsi:schemaLocation="http://www.springframework.org/schema/beans
    		http://www.springframework.org/schema/beans/spring-beans.xsd http://www.springframework.org/schema/cache http://www.springframework.org/schema/cache/spring-cache.xsd">
    						
    	
    	<bean id="jedisPoolConfig" class="redis.clients.jedis.JedisPoolConfig">
    		<property name="maxTotal" value="${redis.maxIdle}" />
    		<property name="maxIdle" value="${redis.maxTotal}" />
    		<property name="maxWaitMillis" value="${redis.maxWaitMillis}" />
    		<property name="testOnBorrow" value="${redis.testOnBorrow}" />
            <property name="testOnReturn" value="${redis.testOnReturn}" />
            <property name="minEvictableIdleTimeMillis" value="${redis.minEvictableIdleTimeMillis}" />
            <property name="numTestsPerEvictionRun" value="${redis.numTestsPerEvictionRun}" />
            <property name="timeBetweenEvictionRunsMillis" value="${redis.timeBetweenEvictionRunsMillis}" />
     	</bean>
    
        
        <bean id="jedisConnectionFactory" class="org.springframework.data.redis.connection.jedis.JedisConnectionFactory">
            <property name="hostName" value="${redis.hostName}" />
            <property name="port" value="${redis.port}" />
            <property name="password" value="${redis.password}" />
            <property name="timeout" value="${redis.timeout}" />
            <property name="database" value="${redis.database}" />
            <property name="poolConfig" ref="jedisPoolConfig" />
        </bean>
    
        <bean id="redisTemplate" class="org.springframework.data.redis.core.RedisTemplate"
              p:connectionFactory-ref="jedisConnectionFactory">
            <property name="valueSerializer">
                <bean class="org.springframework.data.redis.serializer.JdkSerializationRedisSerializer"/>
            </property>
            <property name="hashValueSerializer">
                <bean class="org.springframework.data.redis.serializer.JdkSerializationRedisSerializer"/>
            </property>
            <property name="keySerializer">
                <bean class="com.ytsd.common.common.StringRedisSerializer"/>
            </property>
            <property name="hashKeySerializer">
                <bean class="com.ytsd.common.common.StringRedisSerializer"/>
            </property>
        </bean>
    
        
        <bean id="cacheManager" class="org.springframework.data.redis.cache.RedisCacheManager"
              c:redisOperations-ref="redisTemplate">
            
            <property name="defaultExpiration" value="${redis.expiration}"/>
            <property name="usePrefix" value="true"/>
            
            <property name="expires">
                <map key-type="java.lang.String" value-type="java.lang.Long">
                    <entry key="halfHour" value="1800"/>
                    <entry key="hour" value="3600"/>
                    <entry key="oneDay" value="86400"/>
                    
                    <entry key="authorizationCacheAdmin" value="1800"/>
                    <entry key="authenticationCacheAdmin" value="1800"/>
                    <entry key="activeSessionCacheAdmin" value="1800"/>
                </map>
            </property>
        </bean>
    
        
        <bean id="redisService" class="com.ytsd.service.service.impl.RedisServiceImpl">
            <property name="redisTemplate" ref="redisTemplate" />
        </bean>
    
        
        <cache:annotation-driven cache-manager="cacheManager" proxy-target-class="true"/>
    
    </beans>

2.StringRedisSerializer.java

package com.ytsd.common.common;
    
    import com.alibaba.fastjson.JSON;
    import org.apache.shiro.util.Assert;
    import org.springframework.data.redis.serializer.RedisSerializer;
    
    import java.nio.charset.Charset;
    
    /**
     * Created by zhanghao
     * 2018-05-26 10:32
     */
    public class StringRedisSerializer implements RedisSerializer<Object> {
    
        private final Charset charset;
    
        private final String target = "\"";
    
        private final String replacement = "";
    
        public StringRedisSerializer() {
            this(Charset.forName("UTF8"));
        }
    
        public StringRedisSerializer(Charset charset) {
            Assert.notNull(charset, "Charset must not be null!");
            this.charset = charset;
        }
    
        @Override
        public String deserialize(byte[] bytes) {
            return (bytes == null ? null : new String(bytes, charset));
        }
    
        @Override
        public byte[] serialize(Object object) {
            String string = JSON.toJSONString(object);
            if (string == null) {
                return null;
            }
            string = string.replace(target, replacement);
            return string.getBytes(charset);
        }
    }

ps：其中redis中的key使用string类型的，value使用JdkSerializationRedisSerializer序列化，value会出现乱码，不影响使用。