java - 如何找出存储在 ByteBuffer 中的总字节数？

Question

我正在尝试提取存储在我的 ByteBuffer data_record_value 中的总字节数。

下面是我们如何将data_record_value 表示为一个字节数组，然后从 Java 代码写入我们的数据库。

Offset   Length (in bytes)          Purpose

0           2                       - clientId byte array
2           8                       - value of lastModifiedDate
2+8         4                       - length of avroBinaryValue array
2+8+4       Y                       - avroBinaryValue array

这就是我从数据库中提取它的方式 -

ByteBuffer data_record_value = r.getBytes("data_record_value");

// now how do I extract total number of bytes I have stored in data_record_value?

在做了一些研究之后，我发现了多种提取存储在我的 ByteBuffer data_record_value 中的总字节数的方法，但我不确定哪一种是正确的？

第一种方式是:

byte[] b = new byte[data_record_value.remaining()];
record_value.get(b);

// this will be in bytes right?
System.out.println("Byte Array Length: " + b.length);

第二种方式是:

int numberOfBytesInRecord = data_record_value.limit();

第三种方式是:

int numberOfBytesInRecord = data_record_value.remaining();

但是以上所有方式的数字根本不匹配？我不确定应该使用哪一个？我需要提取存储在 data_record_value 中的总字节数。

为了交叉检查，我们可以从 data_record_value ByteBuffer 中提取各个字段并计算我们存储的总字节数，并与上述任何一种方法进行比较。

// clientId (of two bytes by using short)
short extractClientId = data_record_value.getShort();

// lastModifiedDate ( of 8 bytes which can be long )
long extractLastModifiedDate = data_record_value.getLong();

int extractAvroBinaryValueLength = data_record_value.getInt();

byte[] extractAvroBinaryValue = new byte[extractAvroBinaryValueLength];

data_record_value.get(extractAvroBinaryValue); // read attributeValue from the remaining buffer

System.out.println(extractClientId);
System.out.println(extractLastModifiedDate);
System.out.println(new String(extractAvroBinaryValue));

更新:-

在其中一个 ByteBuffer data_record_value 上，这是我打印出来的 -

System.out.println("Record Value Capacity: " + data_record_value.capacity());
System.out.println("Record Value Position: " + data_record_value.position());
System.out.println("Record Value Limit: " + data_record_value.limit());
System.out.println("Record Value Remaining: " + data_record_value.remaining());
System.out.println("Record Value: " + data_record_value);

这就是打印的内容 -

Record Value Capacity: 387
Record Value Position: 185
Record Value Limit: 250
Record Value Remaining: 65
Record Value: java.nio.HeapByteBuffer[pos=185 lim=250 cap=387]

Answer 1

当使用 ByteBuffer 时，在缓冲区中放入和获取值是有区别的。

当字节被放入缓冲区时，它们会被添加到当前位置。如果达到限制，则缓冲区已满。所以 position() 显示了缓冲区中的数据量，而 remaining() 显示了还有多少字节可以放在缓冲区中。我在这里假设要考虑的数据从位置 0 开始(通常情况下应该如此)。

当从缓冲区中检索到字节时，缓冲区通常已被“翻转”。这意味着位置设置为 0，限制设置为旧位置。现在 position() 返回的值显示已经检索了多少字节，remaining() 显示了多少字节尚未检索。

---

在您的示例中，您会返回一个预先存在的缓冲区。数据库将数据放入这个缓冲区，并将position放在数据所在的位置，limit放在数据结束后的字节处。所以数据库将数据放入缓冲区，然后翻转缓冲区。

如果 position() 未设置为 0，则数据库可能会使用更高级的方案来缓冲数据，但位置在数据的开头，限制在最终保持不变。

因此，缓冲区中的数据总量由 ByteBuffer.remaining() 在您使用相对 get 方法从缓冲区检索任何数据之前返回。

一旦您开始检索信息，此信息就会丢失(尽管当然有一些方法可以取回它，例如使用 mark() 和 reset())。但是，如果您稍后在此过程中需要此信息，您只需将其存储在局部变量或字段中即可:

int received = buffer.remaining();