在 DirectMemory 中找不到 PooledUnsafeDirectByteBuf

Question

我正在使用 Netty 4.1.17-Final。

我编写了发送和接收 100 MB 随机 ASCII 的代码。在 ByteBuf 变为 100 MB 之前，解码器不会读取。

@Override
public void decode(ByteBuffer _in, List<Object> _out) {
    if (_in.remaining() == size) {   // size = 100 * 1024 * 1024
        _in.get(new byte[size]);
    }
}

因此Netty缓冲了100MB，但是监控Direct Memory也没有发现

System.out.println(sun.misc.SharedSecrets.getJavaNioAccess().getDirectBufferPool().getMemoryUsed());
ManagementFactory.getPlatformMXBeans(BufferPoolMXBean.class).forEach(buf -> {
    System.out.printf("%s: Used=%d, TotalCap=%d%n", buf.getName(), buf.getMemoryUsed(), buf.getTotalCapacity());
});

// Result
// 10
// direct: Used=9, TotalCap=8
// mapped: Used=0, TotalCap=0

Netty使用了PooledUnsafeDirectByteBuf，但是你把接收到的数据缓存在哪里呢？还是直接缓冲区监控方式不对？

Answer 1

自我回答，在我的代码中，Netty 使用 com.sun.Unsafe 获取了 DirectMemory。这个区域不能用 BufferPoolMXBean 或 SharedSecrets 捕获。

我尝试用Unsafe获取内存，但是没有输出到监控结果

Field unsafeField = Unsafe.class.getDeclaredField("theUnsafe");
unsafeField.setAccessible(true);
Unsafe unsafe = (Unsafe) unsafeField.get(null);
unsafe.allocateMemory(1000);

我找到了以下请求。
extension for tracking off-heap memory use for netty · Issue #475 · Netflix/spectator

请告诉我是否有办法获取 Unsafe 获取的大小。

Answer 2

您可以告诉 Netty 不要将 Unsafe 用于直接缓冲区，这样它就会再次出现在 JMX 中。不幸的是，这也会对性能产生一些影响。

只需使用-Dio.netty.maxDirectMemory=0。

参见：https://github.com/netty/netty/blob/4.1/common/src/main/java/io/netty/util/internal/PlatformDependent.java#L153

在 DirectMemory 中找不到 PooledUnsafeDirectByteBuf

PooledUnsafeDirectByteBuf not found in DirectMemory

java

memory

netty

directmemory