|  |  |  | 
|---|
|  |  |  | package com.zy.asrs.wms.common.config; | 
|---|
|  |  |  |  | 
|---|
|  |  |  | import com.fasterxml.jackson.annotation.JsonAutoDetect; | 
|---|
|  |  |  | import com.fasterxml.jackson.annotation.PropertyAccessor; | 
|---|
|  |  |  | import com.fasterxml.jackson.databind.ObjectMapper; | 
|---|
|  |  |  | import org.springframework.cache.annotation.CachingConfigurerSupport; | 
|---|
|  |  |  | 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.*; | 
|---|
|  |  |  | import org.springframework.data.redis.serializer.Jackson2JsonRedisSerializer; | 
|---|
|  |  |  | import org.springframework.data.redis.serializer.StringRedisSerializer; | 
|---|
|  |  |  |  | 
|---|
|  |  |  | /** | 
|---|
|  |  |  | * Redis配置类 | 
|---|
|  |  |  | * Created by vincent on 2019-12-23 | 
|---|
|  |  |  | */ | 
|---|
|  |  |  | @Configuration | 
|---|
|  |  |  | //@EnableCaching // 开启数据缓存机制 | 
|---|
|  |  |  | public class RedisConfig extends CachingConfigurerSupport { | 
|---|
|  |  |  |  | 
|---|
|  |  |  |  | 
|---|
|  |  |  | /** | 
|---|
|  |  |  | * RedisTemplate相关配置 | 
|---|
|  |  |  | */ | 
|---|
|  |  |  | @Bean | 
|---|
|  |  |  | public RedisTemplate<String, Object> redisTemplate(RedisConnectionFactory factory) { | 
|---|
|  |  |  |  | 
|---|
|  |  |  | RedisTemplate<String, Object> template = new RedisTemplate<>(); | 
|---|
|  |  |  | // 配置连接工厂 | 
|---|
|  |  |  | template.setConnectionFactory(factory); | 
|---|
|  |  |  |  | 
|---|
|  |  |  | //使用Jackson2JsonRedisSerializer来序列化和反序列化redis的value值(默认使用JDK的序列化方式) | 
|---|
|  |  |  | Jackson2JsonRedisSerializer<Object> jacksonSerializer = new Jackson2JsonRedisSerializer<>(Object.class); | 
|---|
|  |  |  |  | 
|---|
|  |  |  | ObjectMapper om = new ObjectMapper(); | 
|---|
|  |  |  | // 指定要序列化的域,field,get和set,以及修饰符范围,ANY是都有包括private和public | 
|---|
|  |  |  | om.setVisibility(PropertyAccessor.ALL, JsonAutoDetect.Visibility.ANY); | 
|---|
|  |  |  | // 指定序列化输入的类型,类必须是非final修饰的,final修饰的类,比如String,Integer等会跑出异常 | 
|---|
|  |  |  | om.enableDefaultTyping(ObjectMapper.DefaultTyping.NON_FINAL); | 
|---|
|  |  |  | jacksonSerializer.setObjectMapper(om); | 
|---|
|  |  |  |  | 
|---|
|  |  |  | // 值采用json序列化 | 
|---|
|  |  |  | template.setValueSerializer(jacksonSerializer); | 
|---|
|  |  |  | //使用StringRedisSerializer来序列化和反序列化redis的key值 | 
|---|
|  |  |  | template.setKeySerializer(new StringRedisSerializer()); | 
|---|
|  |  |  |  | 
|---|
|  |  |  | // 设置hash key 和value序列化模式 | 
|---|
|  |  |  | template.setHashKeySerializer(new StringRedisSerializer()); | 
|---|
|  |  |  | template.setHashValueSerializer(jacksonSerializer); | 
|---|
|  |  |  | template.afterPropertiesSet(); | 
|---|
|  |  |  |  | 
|---|
|  |  |  | return template; | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  |  | 
|---|
|  |  |  | /** | 
|---|
|  |  |  | * 对redis字符串类型数据操作 | 
|---|
|  |  |  | */ | 
|---|
|  |  |  | @Bean | 
|---|
|  |  |  | public ValueOperations<String, Object> valueOperations(RedisTemplate<String, Object> redisTemplate) { | 
|---|
|  |  |  | return redisTemplate.opsForValue(); | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  | /** | 
|---|
|  |  |  | * 对hash类型的数据操作 | 
|---|
|  |  |  | */ | 
|---|
|  |  |  | @Bean | 
|---|
|  |  |  | public HashOperations<String, String, Object> hashOperations(RedisTemplate<String, Object> redisTemplate) { | 
|---|
|  |  |  | return redisTemplate.opsForHash(); | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  | /** | 
|---|
|  |  |  | * 对链表类型的数据操作 | 
|---|
|  |  |  | */ | 
|---|
|  |  |  | @Bean | 
|---|
|  |  |  | public ListOperations<String, Object> listOperations(RedisTemplate<String, Object> redisTemplate) { | 
|---|
|  |  |  | return redisTemplate.opsForList(); | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  | /** | 
|---|
|  |  |  | * 对无序集合类型的数据操作 | 
|---|
|  |  |  | */ | 
|---|
|  |  |  | @Bean | 
|---|
|  |  |  | public SetOperations<String, Object> setOperations(RedisTemplate<String, Object> redisTemplate) { | 
|---|
|  |  |  | return redisTemplate.opsForSet(); | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  | /** | 
|---|
|  |  |  | * 对有序集合类型的数据操作 | 
|---|
|  |  |  | */ | 
|---|
|  |  |  | @Bean | 
|---|
|  |  |  | public ZSetOperations<String, Object> zSetOperations(RedisTemplate<String, Object> redisTemplate) { | 
|---|
|  |  |  | return redisTemplate.opsForZSet(); | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  |  | 
|---|
|  |  |  | } | 
|---|
|  |  |  | package com.zy.asrs.wms.common.config; | 
|---|
|  |  |  |  | 
|---|
|  |  |  | import com.fasterxml.jackson.annotation.JsonAutoDetect; | 
|---|
|  |  |  | import com.fasterxml.jackson.annotation.PropertyAccessor; | 
|---|
|  |  |  | import com.fasterxml.jackson.databind.ObjectMapper; | 
|---|
|  |  |  | import org.springframework.cache.annotation.CachingConfigurerSupport; | 
|---|
|  |  |  | 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.*; | 
|---|
|  |  |  | import org.springframework.data.redis.serializer.Jackson2JsonRedisSerializer; | 
|---|
|  |  |  | import org.springframework.data.redis.serializer.StringRedisSerializer; | 
|---|
|  |  |  |  | 
|---|
|  |  |  | /** | 
|---|
|  |  |  | * Redis配置类 | 
|---|
|  |  |  | * Created by vincent on 2019-12-23 | 
|---|
|  |  |  | */ | 
|---|
|  |  |  | @Configuration | 
|---|
|  |  |  | //@EnableCaching // 开启数据缓存机制 | 
|---|
|  |  |  | public class RedisConfig extends CachingConfigurerSupport { | 
|---|
|  |  |  |  | 
|---|
|  |  |  |  | 
|---|
|  |  |  | /** | 
|---|
|  |  |  | * RedisTemplate相关配置 | 
|---|
|  |  |  | */ | 
|---|
|  |  |  | @Bean | 
|---|
|  |  |  | public RedisTemplate<String, Object> redisTemplate(RedisConnectionFactory factory) { | 
|---|
|  |  |  |  | 
|---|
|  |  |  | RedisTemplate<String, Object> template = new RedisTemplate<>(); | 
|---|
|  |  |  | // 配置连接工厂 | 
|---|
|  |  |  | template.setConnectionFactory(factory); | 
|---|
|  |  |  |  | 
|---|
|  |  |  | //使用Jackson2JsonRedisSerializer来序列化和反序列化redis的value值(默认使用JDK的序列化方式) | 
|---|
|  |  |  | Jackson2JsonRedisSerializer<Object> jacksonSerializer = new Jackson2JsonRedisSerializer<>(Object.class); | 
|---|
|  |  |  |  | 
|---|
|  |  |  | ObjectMapper om = new ObjectMapper(); | 
|---|
|  |  |  | // 指定要序列化的域,field,get和set,以及修饰符范围,ANY是都有包括private和public | 
|---|
|  |  |  | om.setVisibility(PropertyAccessor.ALL, JsonAutoDetect.Visibility.ANY); | 
|---|
|  |  |  | // 指定序列化输入的类型,类必须是非final修饰的,final修饰的类,比如String,Integer等会跑出异常 | 
|---|
|  |  |  | om.enableDefaultTyping(ObjectMapper.DefaultTyping.NON_FINAL); | 
|---|
|  |  |  | jacksonSerializer.setObjectMapper(om); | 
|---|
|  |  |  |  | 
|---|
|  |  |  | // 值采用json序列化 | 
|---|
|  |  |  | template.setValueSerializer(jacksonSerializer); | 
|---|
|  |  |  | //使用StringRedisSerializer来序列化和反序列化redis的key值 | 
|---|
|  |  |  | template.setKeySerializer(new StringRedisSerializer()); | 
|---|
|  |  |  |  | 
|---|
|  |  |  | // 设置hash key 和value序列化模式 | 
|---|
|  |  |  | template.setHashKeySerializer(new StringRedisSerializer()); | 
|---|
|  |  |  | template.setHashValueSerializer(jacksonSerializer); | 
|---|
|  |  |  | template.afterPropertiesSet(); | 
|---|
|  |  |  |  | 
|---|
|  |  |  | return template; | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  |  | 
|---|
|  |  |  | /** | 
|---|
|  |  |  | * 对redis字符串类型数据操作 | 
|---|
|  |  |  | */ | 
|---|
|  |  |  | @Bean | 
|---|
|  |  |  | public ValueOperations<String, Object> valueOperations(RedisTemplate<String, Object> redisTemplate) { | 
|---|
|  |  |  | return redisTemplate.opsForValue(); | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  | /** | 
|---|
|  |  |  | * 对hash类型的数据操作 | 
|---|
|  |  |  | */ | 
|---|
|  |  |  | @Bean | 
|---|
|  |  |  | public HashOperations<String, String, Object> hashOperations(RedisTemplate<String, Object> redisTemplate) { | 
|---|
|  |  |  | return redisTemplate.opsForHash(); | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  | /** | 
|---|
|  |  |  | * 对链表类型的数据操作 | 
|---|
|  |  |  | */ | 
|---|
|  |  |  | @Bean | 
|---|
|  |  |  | public ListOperations<String, Object> listOperations(RedisTemplate<String, Object> redisTemplate) { | 
|---|
|  |  |  | return redisTemplate.opsForList(); | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  | /** | 
|---|
|  |  |  | * 对无序集合类型的数据操作 | 
|---|
|  |  |  | */ | 
|---|
|  |  |  | @Bean | 
|---|
|  |  |  | public SetOperations<String, Object> setOperations(RedisTemplate<String, Object> redisTemplate) { | 
|---|
|  |  |  | return redisTemplate.opsForSet(); | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  | /** | 
|---|
|  |  |  | * 对有序集合类型的数据操作 | 
|---|
|  |  |  | */ | 
|---|
|  |  |  | @Bean | 
|---|
|  |  |  | public ZSetOperations<String, Object> zSetOperations(RedisTemplate<String, Object> redisTemplate) { | 
|---|
|  |  |  | return redisTemplate.opsForZSet(); | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  |  | 
|---|
|  |  |  | } | 
|---|