提交redis封装

freemud-framework-redis/src/main/java/com/freemud/framework/redis/RedisConfig.java

+package com.freemud.framework.redis;
+
+import org.springframework.cache.CacheManager;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+import org.springframework.data.redis.cache.RedisCacheManager;
+import org.springframework.data.redis.connection.RedisConnectionFactory;
+import org.springframework.data.redis.core.RedisTemplate;
+import org.springframework.data.redis.serializer.StringRedisSerializer;
+
+@Configuration
+public class RedisConfig {
+	
+	@Bean
+    public CacheManager cacheManager(RedisTemplate<Object, Object> redisTemplate) {
+        RedisCacheManager cacheManager = new RedisCacheManager(redisTemplate);
+        cacheManager.setDefaultExpiration(1800);
+        return cacheManager;
+    }
+    
+    @Bean
+    public RedisTemplate<Object, Object> redisTemplate(RedisConnectionFactory factory) {
+        RedisTemplate<Object, Object> template = new RedisTemplate<Object, Object>();
+        StringRedisSerializer stringRedisSerializer = new StringRedisSerializer();
+        RedisObjectSerializer redisObjectSerializer = new RedisObjectSerializer();
+        template.setConnectionFactory(factory);
+        template.setKeySerializer(stringRedisSerializer);
+        template.setValueSerializer(redisObjectSerializer);
+        template.setHashKeySerializer(stringRedisSerializer);
+        template.setHashValueSerializer(redisObjectSerializer);
+        template.setStringSerializer(stringRedisSerializer);
+        return template;
+    }
+	
+}

freemud-framework-redis/src/main/java/com/freemud/framework/redis/RedisObjectSerializer.java

+package com.freemud.framework.redis;
+
+import org.springframework.core.convert.converter.Converter;
+import org.springframework.core.serializer.support.DeserializingConverter;
+import org.springframework.core.serializer.support.SerializingConverter;
+import org.springframework.data.redis.serializer.RedisSerializer;
+import org.springframework.data.redis.serializer.SerializationException;
+
+/**
+ * redis序列化对象
+ */
+public class RedisObjectSerializer implements RedisSerializer<Object> {
+    private Converter<Object, byte[]> serializer = new SerializingConverter();
+    private Converter<byte[], Object> deserializer = new DeserializingConverter();
+    static final byte[] EMPTY_ARRAY = new byte[0];
+
+    public Object deserialize(byte[] bytes) {
+        if (isEmpty(bytes)) {
+            return null;
+        }
+        try {
+            return deserializer.convert(bytes);
+        } catch (Exception ex) {
+            throw new SerializationException("Cannot deserialize", ex);
+        }
+    }
+
+    public byte[] serialize(Object object) {
+        if (object == null) {
+            return EMPTY_ARRAY;
+        }
+        try {
+            return serializer.convert(object);
+        } catch (Exception ex) {
+            return EMPTY_ARRAY;
+        }
+    }
+
+    private boolean isEmpty(byte[] data) {
+        return (data == null || data.length == 0);
+    }
+}

freemud-framework-redis/src/main/java/com/freemud/framework/redis/RedisServiceImpl.java

@@ -9,9 +9,11 @@ import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.data.redis.core.RedisTemplate;
+import org.springframework.data.redis.core.StringRedisTemplate;
 import org.springframework.stereotype.Service;
 import org.springframework.util.CollectionUtils;
 
+import com.freemud.framework.redis.RedisService;
 
 @Service
 public class RedisServiceImpl<T> implements RedisService<T> {