使用LettuceConnectionFactory向Spring数据Redis添加压缩

Question

我看到莴苣可以为Redis序列化对象做压缩：https://lettuce.io/core/release/reference/#codecs.compression

有没有办法在Spring Boot Data LettuceConnectionFactory或其他bean中设置此配置？我在这里也看到了这样一个问题：https://github.com/lettuce-io/lettuce-core/issues/633

我想压缩所有发送到Redis的序列化对象，以减少盒子之间的网络流量。

谢谢

Answer 1

下面是JavaSpring Boot Redis Cluster Data配置的示例。

它是一个带有Redis群集和Redis缓存管理器的实现。

1. 快速压缩
2. Kryo序列化
3. 支持每个缓存密钥的ttl
4. Gradle配置
5. sping-data-redis
6. snappy-java
7. kryo
8. 公共资源-编解码器

链接到githubhttps://github.com/cboursinos/java-spring-redis-compression-snappy-kryo

Answer 2

我最终以以下方式解决了它。

1. 创建一个springbean模板。这允许我们设置自定义序列化程序

    @Bean
    public RedisTemplate<Object, Object> redisTemplate(LettuceConnectionFactory connectionFactory) {
        RedisTemplate<Object, Object> template = new RedisTemplate<>();
        template.setConnectionFactory(connectionFactory);

        // Set a custom serializer that will compress/decompress data to/from redis
        RedisSerializerGzip serializerGzip = new RedisSerializerGzip();
        template.setValueSerializer(serializerGzip);
        template.setHashValueSerializer(serializerGzip);
        return template;
    }

public class RedisSerializerGzip extends JdkSerializationRedisSerializer {

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

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


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

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

}