redis value compression

redis 설정할 때, value에 json으로 넣게 되면 많은 용량을 차지 할 것 같아서 변경하려 한다.

https://blog.naver.com/kkforgg/221695024408

java Object Compression

Class binary를 압축하는 방법에 대해서 고민 하던 도중 위와 같은 방법이 있는걸 확인. 하지만 몇가지 -_…

객체 압축 방법은 위와 같이 진행했었는데, 최근에 redis template 작성할 때, key, value Serializer를 사용할 수 있다는것을 알게되었다.

​

/**
 * 레디스 설정.
 */
@Configuration
public class RedisConfig {

  @Value("${redis.host}")
  private String host;

  @Value("${redis.port}")
  private int port;

  /**
   * redis connection factory bean을 등록합니다.
   */
  @Bean
  public RedisConnectionFactory redisConnectionFactory() {
    return new LettuceConnectionFactory(host, port);
  }

  /**
   * redis connection ban을 등록합니다.
   *
   * @param factory redis connection factory bean
   * @return redis connection
   */
  @Bean
  public RedisTemplate redisTemplate(final RedisConnectionFactory factory) {
    final RedisTemplate redisTemplate = new RedisTemplate<>();
    redisTemplate.setConnectionFactory(factory);
    redisTemplate.setKeySerializer(new StringRedisSerializer());
    redisTemplate.setValueSerializer(new RedisSerializerGzip());
    return redisTemplate;
  }

}
/**
 * redis value compressiong Gzip 클래스.
 */
public class RedisSerializerGzip extends JdkSerializationRedisSerializer {

  @Override
  public Object deserialize(final byte[] bytes) {
    return super.deserialize(decompress(bytes));
  }

  @Override
  public byte[] serialize(final Object object) {
    return compress(super.serialize(object));
  }

  ////////////////////////
  // Helpers
  ////////////////////////
  private byte[] compress(final byte[] content) {
    final ByteArrayOutputStream byteArrayOutputStream = new ByteArrayOutputStream();
    try (final GZIPOutputStream gzipOutputStream = new GZIPOutputStream(byteArrayOutputStream)) {
      gzipOutputStream.write(content);
    } catch (final IOException e) {
      throw new SerializationException("Unable to compress data", e);
    }
    return byteArrayOutputStream.toByteArray();
  }

  private byte[] decompress(final byte[] contentBytes) {
    final ByteArrayOutputStream out = new ByteArrayOutputStream();
    try {
      IOUtils.copy(new GZIPInputStream(new ByteArrayInputStream(contentBytes)), out);
    } catch (final IOException e) {
      throw new SerializationException("Unable to decompress data", e);
    }
    return out.toByteArray();
  }

}

​

출처 : https://cache.one/read/15568742

​