Netty 4/5实际上没有检测到Bytebuf的资源泄漏？

Question

我对Netty5（或4）中的引用计数bytebuf有些怀疑。我发现，当bytebuf超出生命周期时，我不释放它时不会发生任何事情，似乎bytebuf使用的内存可以正确地GCed。

在这个链接http://netty.io/wiki/reference-counted-objects.html中，它说设置JVM选项'-dio.netty.leakdetectionlevel=advanced'或调用resourceleakdetector.setlevel()可以检测资源泄漏，但我不能用下面的代码复制它。

public class App {
    public static ByteBuf a(ByteBuf input) {
        input.writeByte(42);
        return input;
    }

    public static ByteBuf b(ByteBuf input) {
        try {
            ByteBuf output;
            output = input.alloc().directBuffer(input.readableBytes() + 1);
            output.writeBytes(input);
            output.writeByte(42);
            return output;
        } finally {
            // input.release();
        }
    }

    public static void c(ByteBuf input) {
        //System.out.println(input);
        // input.release();
    }

    static class Task implements Runnable {
        ByteBuf bbBuf;

        public Task(ByteBuf buf) {
            bbBuf = buf;
        }

        public void run() {
            c(b(a(bbBuf)));
        }
    }

    public static void main(String[] args) {
        ResourceLeakDetector.setLevel(ResourceLeakDetector.Level.PARANOID);     
        AbstractByteBufAllocator allocator = new PooledByteBufAllocator();

        ByteBuf buf = allocator.buffer(10, 100);

        // buf.release();
        new Thread(new Task(buf)).start();
        System.out.println(buf.refCnt());
        assert buf.refCnt() == 0;
    }
}

那么问题出在哪里？

Answer 1

Netty中的资源泄漏检测机制依赖于ReferenceQueue和PhantomReference。当一个对象（在本例中是bytebuf)变得无法访问时，垃圾回收器并不十分确定何时通知referencequeue。如果VM终止得太早或者垃圾收集得不够快，资源泄漏检测器就无法判断是否存在泄漏，因为垃圾收集器没有告诉我们任何事情。

实际上，这并不是一个问题，因为一个Netty应用程序在现实中通常会运行更长的时间，您最终会得到通知。只需运行一个应用程序大约30秒，让它做一些繁忙的工作。您肯定会看到泄漏错误消息。