创建一个连接，将字符串存储为键，字节数组存储为值

Question

我有一个Spring boot应用程序，可以连接到AWS上的Redis集群。我正在尝试莴苣，想创建一个StatefulRedisConnection，用于将键存储为字符串，而将值存储为字节数组。我尝试使用内置的ByteArrayCodec，但它将键和值都作为字节数组。

我刚接触莴苣，所以我不确定是否需要编写自定义编解码器。如果是，我该怎么写？是否会出现性能问题？还是我走错了路？

Answer 1

我使用StatefulRedisClusterConnection连接到redis集群。没错，我没有在那里写数据，只是读了它。但是这种阅读结构对我来说已经成功了。

final RedisCodec<String, byte[]> codec = RedisCodec.of(new StringCodec(), new ByteArrayCodec());
final StatefulRedisClusterConnection<String, byte[]> connection = client.connect(codec);

Answer 2

下面的代码将允许您使用字符串键和字节数组作为值。

public class StringByteCodec implements RedisCodec<String, byte[]> {

    public static final StringByteCodec INSTANCE = new StringByteCodec();
    private static final byte[] EMPTY = new byte[0];
    private final Charset charset = Charset.forName("UTF-8");

    @Override
    public String decodeKey(final ByteBuffer bytes) {
        return charset.decode(bytes).toString();
    }

    @Override
    public byte[] decodeValue(final ByteBuffer bytes) {
        return getBytes(bytes);
    }

    @Override
    public ByteBuffer encodeKey(final String key) {
        return charset.encode(key);
    }

    @Override
    public ByteBuffer encodeValue(final byte[] value) {
        if (value == null) {
            return ByteBuffer.wrap(EMPTY);
        }

        return ByteBuffer.wrap(value);
    }

    private static byte[] getBytes(final ByteBuffer buffer) {
        final byte[] b = new byte[buffer.remaining()];
        buffer.get(b);
        return b;
    }

}