在冲突解决期间确定 RiakObject 的位置答案

【问题标题】：Determine Location of RiakObject during conflict resolution在冲突解决期间确定 RiakObject 的位置
【发布时间】：2015-04-15 10:21:33
【问题描述】：

我正在将我的 Java 代码从 Riak Client 1.4 迁移到 Riak Client 2.0。

我在 Riak 2.0 中存储了一个 BinaryValue，封装在一个 RiakObject 中。我需要提供自己的ConflictResolver 来处理兄弟姐妹，但为了做到这一点，我需要提取其他数据。该数据来源于存储对象的键。

在 Riak 1.4 中，我使用了IRiakObject，它暴露了getKey()。 Riak 2.0 的RiakObject 不提供此功能。

如何在ConflictResolver.resolve(List<RiakObject> siblings)期间确定对象的Location（特别是key）？

【问题讨论】：

标签： java riak

【解决方案1】：

不确定这是否是最好的方法，但它似乎有效：

创建一个 POJO 作为二进制数据的容器。用@RiakKey 注释String 字段：

public class Chunk {

    @RiakKey
    public String   chunkId;

    public byte[]   data;
}

创建自定义转换器：

import com.basho.riak.client.api.convert.ConversionException;
import com.basho.riak.client.api.convert.Converter;
import com.basho.riak.client.core.util.BinaryValue;
public class ChunkConverter extends Converter<Chunk> {

    public ChunkConverter() {
        super(Chunk.class);
    }

    public Chunk toDomain(BinaryValue val, String contentType) throws ConversionException {
        Chunk chunk = newDomainInstance();
        chunk.data = val.getValue();
    }

    public ContentAndType fromDomain(Chunk chunk) throws ConversionException {
        return new ContentAndType(BinaryValue.unsafeCreate(chunk.data), "application/octet-stream");
    }
}

为#1 中的类注册#2 中的转换器：

ConverterFactory.getInstance().registerConverterForClass(Chunk.class, new ChunkConverter());

为 #1 中的类创建冲突解决程序：

public class ChunkConflictResolver implements ConflictResolver<Chunk> {

    public Chunk resolve(List<Chunk> siblings) throws UnresolvedConflictException {
        if (siblings == null) {
            return null;
        }
        Chunk oneChunk = siblings.get(0);
        // finally, the key!
        String key = oneChunk.chunkId;
        ...
    }
}

为#1 中的类注册#4 中的新冲突解决程序：

ConflictResolverFactory.getInstance().registerConflictResolver(Chunk.class, new ChunkResolver());

从 Riak 获取对象时，将 #1 中的类指定为值类型：

Location loc = new Location(...);
FetchValue op = new FetchValue.Builder(loc).build();
Chunk chunk = riakClient.execute(op).getValue(Chunk.class);

在转换过程中，对象的上下文被转移，观察annotations。自定义转换器只需要传输数据的值部分。

【讨论】：