使用历史记录映射和byte[]或byte缓冲区

Question

ChronicleMap<Long, ByteBuffer> map = ChronicleMap
    .of(Long.class, ByteBuffer.class)
    .name("shard_map")
    .averageValueSize(1000)
    .entries(1_000_000)
    .create();

ByteBuffer ts2 = ByteBuffer.allocateDirect(10);
ts2.putInt(10);
map.put(1L, ts2);
System.out.println(map.get(1L).getInt());

Exception in thread "main" java.nio.BufferUnderflowException
    at java.nio.Buffer.nextGetIndex(Buffer.java:506)
    at java.nio.HeapByteBuffer.getInt(HeapByteBuffer.java:361)

我尝试用values.NewHeapInstance创建value对象，但失败了，出现错误：

Exception in thread "main" java.lang.IllegalArgumentException: class java.nio.ByteBuffer is not an interface nor a generated class native or heap class
    at net.openhft.chronicle.values.ValueModel.notValueInterfaceOfImpl(ValueModel.java:68)
    at net.openhft.chronicle.values.ValueModel.lambda$acquire$0(ValueModel.java:64)
    at net.openhft.chronicle.values.ValueModel.doSomethingForInterfaceOr(ValueModel.java:85)
    at net.openhft.chronicle.values.ValueModel.acquire(ValueModel.java:63)
    at net.openhft.chronicle.values.Values.heapClassFor(Values.java:68)
    at net.openhft.chronicle.values.Values.newHeapInstance(Values.java:37)

文档中说Byte[]和ByteBuffer是开箱即用的，但是我找不到一个实用的例子，所以决定在这里询问一下。

Answer 1

您的测试在我的机器上工作（没有错误地结束），但打印意外的输出“0”。这是因为您忘记调用ts2.flip()，代码应该如下所示：

ts2.putInt(10);
ts2.flip();
map.put(1L, ts2);

通过此更改，代码段将打印“10”。

开箱即用，Chronicle Map在ByteBuffer的位置和限制之间序列化ByteBuffer的内容。您可以在自定义序列化程序中重写此内容，并写入整个缓冲区。