Redis Cache with spring
카테고리 없음 / 2018. 9. 6. 14:12
1. Redis Connection Factory
@Component @Configuration public class RedisConnectionConfig { @Value("${redis.host}") private String redisHost; @Value("${redis.port}") private int redisPort; @Bean public RedisConnectionFactory XXXRedisConnectionFactory() { JedisPoolConfig poolConfig = new JedisPoolConfig(); poolConfig.setMaxTotal(5); poolConfig.setJmxNamePrefix("redispool"); poolConfig.setJmxNameBase("redis.client.jedis:type=XXXSentinelPool,name="); JedisConnectionFactory connectionFactory = new JedisConnectionFactory(poolConfig); connectionFactory.setUsePool(true); connectionFactory.setHostName(redisHost); connectionFactory.setPort(redisPort); return connectionFactory; } } |
2. RedisTemplate extends
@Getter @Setter public class XXXRedisTemplate<K, V> extends RedisTemplate { private String cacheName; } |
3. RedisSerializer impletemt
@Slf4j public class XXXRedisSingleSerializer<T> implements RedisSerializer<Object> { private Class<?> clazz; private ObjectMapper objectMapper = new ObjectMapper(); public XXXRedisSingleSerializer(Class<?> clazz) { this.clazz = clazz; } @Override public byte[] serialize(Object o) throws SerializationException { try { return objectMapper.writeValueAsBytes(o); } catch (IOException e) { log.warn("serialize exception list : {}, message : {}", o, e.getMessage(), e); } return null; } @Override public T deserialize(byte[] bytes) throws SerializationException { try { Object o = objectMapper.readValue(bytes, objectMapper.getTypeFactory().constructType(clazz)); return (T) o; } catch (IOException e) { log.warn("deserialize exception data : {}, message : {}", bytes, e.getMessage(), e); } return null; } } |
@Slf4j public class XXXRedisSerializer implements RedisSerializer<List> { private Class<?> clazz; private ObjectMapper objectMapper = new ObjectMapper(); public XXXRedisSerializer(Class<?> clazz) { this.clazz = clazz; } @Override public byte[] serialize(List ts) throws SerializationException { try { return objectMapper.writeValueAsBytes(ts); } catch (IOException e) { log.warn("serialize exception list : {}, message : {}", ts, e.getMessage(), e); } return null; } @Override public List deserialize(byte[] bytes) throws SerializationException { try { List<?> list = objectMapper.readValue( bytes, objectMapper.getTypeFactory().constructCollectionType(List.class, clazz)); return list; } catch (IOException e) { log.warn("deserialize exception data : {}, message : {}", bytes, e.getMessage(), e); } return Lists.newArrayList(); } } |
4. RedisTemplate Bean 등록
@Configuration public class XXXRedisTemplateConfig { @Autowired @Qualifier("XXXRedisConnectionFactory") private RedisConnectionFactory XXXPortalRedisConnectionFactory; @Bean public XXXRedisTemplate<String, XXXdto1> xxx1RedisTemplate() { return redisTemplate(XXXdto1.class, XXXCacheConst.XXX1); }
@Bean public XXXRedisTemplate<String, xxx2Dto> xxx2Template() { XXXRedisTemplate<String, xxx2Dto> redisTemplate = new XXXRedisTemplate<>(); redisTemplate.setKeySerializer(new StringRedisSerializer()); redisTemplate.setValueSerializer( new XXXRedisSingleSerializer<xxx2Dto>(xxx2Dto)); redisTemplate.setConnectionFactory(XXXRedisConnectionFactory); redisTemplate.setCacheName(XXXCacheConst.xxx2); return redisTemplate; } @NotNull private XXXRedisTemplate redisTemplate(Class<?> clazz, String cacheName) { XXXRedisTemplate redisTemplate = new XXXRedisTemplate<>(); redisTemplate.setKeySerializer(new StringRedisSerializer()); redisTemplate.setValueSerializer(new XXXRedisSerializer(clazz)); redisTemplate.setConnectionFactory(XXXRedisConnectionFactory); redisTemplate.setCacheName(cacheName); return redisTemplate; } } |
5. CacheManager에 등록
@Autowired private List<XXXRedisTemplate> XXXRedisTemplates; @Bean public CacheManager cacheManager() { List<RedisCacheManager> cacheManagers = XXXRedisTemplates .stream() .map( redisTemplate -> { RedisCacheManager redisCacheManager = new RedisCacheManager(redisTemplate); redisCacheManager.setCacheNames(Lists.newArrayList(redisTemplate.getCacheName())); redisCacheManager.setDefaultExpiration(300); redisCacheManager.afterPropertiesSet(); return redisCacheManager; }) .collect(Collectors.toList()); CompositeCacheManager compositeCacheManager = new CompositeCacheManager(); compositeCacheManager.setCacheManagers(Lists.newArrayList(cacheManagers)); return compositeCacheManager; } } |