编年史字节共享 DirectBytesStores

Question

我已经为一个文件创建了一个 MappedBytes 实例，我将其用作不同 Java 进程之间的共享缓存。

我希望能够从原始实例中分离出额外的 MappedByte 实例（或 ByteBuffer 或任何其他实例），以提供对底层文件子集的直接 read/write 访问。

我今天尝试了不同的方法，但 subBytes()、rawCopy() 和 copyTo() 等选项似乎都创建了基础文件的本地副本，而不是访问文件直接。

例如：

File tmpFile = new File(System.getProperty("java.io.tmpdir"), "data.dat");
MappedFile mappedFile = MappedFile.mappedFile(tmpfile, 1000, 100, 10, false);
MappedBytes original = MappedBytes.mappedBytes(mappedFile);
original.zeroOut(0, 1000);

original.writeInt(0, 1234);
BytesStore copy = original.bytesStore().subBytes(0, 200);

// Print out the int in the two BytesStores.
// This shows that the copy has the same contents of the original.
System.out.println("Original(0): " + original.readInt(0));
System.out.println("Copy(0): " + copy.readInt(0));

// Now modify the copy and print out the new int in the two BytesStores again.
copy.writeInt(50, 4321);
System.out.println("Original(50): " + original.readInt(50));
System.out.println("Copy(50): " + copy.readInt(50));

产生输出：

Original(0): 1234
Copy(0): 1234
Original(50): 0
Copy(50): 4321

副本已修改，原件未修改。我想修改原件，chronicle-bytes可以吗？

感谢您的帮助，乔什.

Answer 1

这是一个独立的测试，我认为它的行为符合您的需要。

@Test
public void multiBytes() throws FileNotFoundException {
    String tmpfile = OS.TMP +  "/data.dat";
    MappedFile mappedFile = MappedFile.mappedFile(new File(tmpfile), 64 << 10);
    MappedBytes original = MappedBytes.mappedBytes(mappedFile);
    original.zeroOut(0, 1000);

    original.writeInt(0, 1234);

    PointerBytesStore pbs = new PointerBytesStore();
    pbs.set(original.addressForRead(50), 100);

    // Print out the int in the two BytesStores.
    // This shows that the copy has the same contents of the original.
    System.out.println("Original(0): " + original.readInt(0));
    System.out.println("PBS(0): " + pbs.readInt(0));

    // Now modify the copy and print out the new int in the two BytesStores again.
    pbs.writeInt(0, 4321);
    System.out.println("Original(50): " + original.readInt(50));
    System.out.println("PBS(0): " + pbs.readInt(0));
    original.writeInt(54, 12345678);
    System.out.println("Original(54): " + original.readInt(54));
    System.out.println("PBS(4): " + pbs.readInt(4));
}

打印

Original(0): 1234
PBS(0): 0
Original(50): 4321
PBS(0): 4321
Original(54): 12345678
PBS(4): 12345678

编年史字节共享 DirectBytesStores

chronicle-bytes shared DirectBytesStores

chronicle

chronicle-bytes