chronicle - Serialize Java object ByteBuffer using Chronicle Wire

Question

I have been using "javolution" that facilitates me to create Java objects which can be serialized to nio.ByteBuffer that can be further mapped to C structs.

How can I achieve the same using Chronicle Wire?

Answer 1

您可以写入由 Bytes 包装的 ByteBuffer。

我在这里添加了一些测试用例https://github.com/OpenHFT/Chronicle-Wire/blob/master/src/test/java/net/openhft/chronicle/wire/marshallable/ByteBufferMarshallingTest.java

@Test
public void writeReadByteBuffer() {
    Bytes<ByteBuffer> bytes = Bytes.elasticByteBuffer();
    Wire wire = new RawWire(bytes);

    AClass o1 = new AClass(1, true, (byte) 2, '3', (short) 4, 5, 6, 7, 8, "nine");

    o1.writeMarshallable(wire);

    AClass o2 = ObjectUtils.newInstance(AClass.class);
    o2.readMarshallable(wire);

    assertEquals(o1, o2);
}

@Test
public void writeReadViaByteBuffer() {
    Bytes<ByteBuffer> bytes = Bytes.elasticByteBuffer();
    Wire wire = new RawWire(bytes);

    AClass o1 = new AClass(1, true, (byte) 2, '3', (short) 4, 5, 6, 7, 8, "nine");

    o1.writeMarshallable(wire);

    ByteBuffer bb = bytes.underlyingObject();
    bb.position((int) bytes.readPosition());
    bb.limit((int) bytes.readLimit());

    Bytes<ByteBuffer> bytes2 = Bytes.elasticByteBuffer();
    bytes2.ensureCapacity(bb.remaining());

    ByteBuffer bb2 = bytes2.underlyingObject();
    bb2.clear();

    bb2.put(bb);
    // read what we just wrote
    bytes2.readPosition(0);
    bytes2.readLimit(bb2.position());

    Wire wire2 = new RawWire(bytes2);

    AClass o2 = ObjectUtils.newInstance(AClass.class);
    o2.readMarshallable(wire2);
    assertEquals(o1, o2);
}

但是，如果您打算只使用 RawWire，则最好extend不要AbstractBytesMarshallable使用 Wire 进行序列化。

@Test
public void writeReadBytesViaByteBuffer() {
    Bytes<ByteBuffer> bytes = Bytes.elasticByteBuffer();

    BClass o1 = new BClass(1, true, (byte) 2, '3', (short) 4, 5, 6, 7, 8, "nine");

    o1.writeMarshallable(bytes);

    ByteBuffer bb = bytes.underlyingObject();
    bb.position((int) bytes.readPosition());
    bb.limit((int) bytes.readLimit());

    Bytes<ByteBuffer> bytes2 = Bytes.elasticByteBuffer();
    bytes2.ensureCapacity(bb.remaining());

    ByteBuffer bb2 = bytes2.underlyingObject();
    bb2.clear();

    bb2.put(bb);
    // read what we just wrote
    bytes2.readPosition(0);
    bytes2.readLimit(bb2.position());

    BClass o2 = ObjectUtils.newInstance(BClass.class);
    o2.readMarshallable(bytes2);
    assertEquals(o1, o2);
}