一直报这个错，是哪里使用有问题吗，我项目里本身没有用到 netty，这个错误应该是jkcp 层报出来的

[dingzhichao]

[nioEventLoopGroup-2-1] WARN io.netty.util.ReferenceCountUtil - Failed to release a message: DatagramPacket(/0.0.0.0:6000 => /127.0.0.1:64272, PooledUnsafeDirectByteBuf(freed)) io.netty.util.IllegalReferenceCountException: refCnt: 0, decrement: 1

[beykery]

请把代码贴出来。

[dingzhichao]

public void handleReceive(ByteBuf byteBuf, KcpOnUdp kcpOnUdp) { int sessionId = kcpOnUdp.getKcp().getConv(); int length = byteBuf.readableBytes();//得到可读字节数 byte[] bytes = new byte[length]; //分配一个具有length大小的数组 byteBuf.getBytes(0, bytes); //将缓冲区中的数据拷贝到这个数组中 byteBuf.release(); FSPSession session = null; boolean isNewSession = false; if (sessionMap.containsKey(sessionId)) { session = sessionMap.get(sessionId); } else { session = new FSPSession(sessionId, kcpOnUdp); sessionMap.put(sessionId, session); isNewSession = true; } session.handleReceive(bytes, isNewSession);

}

[dingzhichao]

public class UdpServer extends KcpServer {

Map<Integer, FSPSession> sessionMap = new HashMap<>();

private static Logger log = LoggerFactory.getLogger(UdpServer.class);

public UdpServer(int port, int workSize) {
    super(port, workSize);
}

@Override
public void handleReceive(ByteBuf byteBuf, KcpOnUdp kcpOnUdp) {
    int sessionId = kcpOnUdp.getKcp().getConv();
    int length = byteBuf.readableBytes();//得到可读字节数
    byte[] bytes = new byte[length];    //分配一个具有length大小的数组
    byteBuf.getBytes(0, bytes); //将缓冲区中的数据拷贝到这个数组中
    byteBuf.release();
    FSPSession session = null;
    boolean isNewSession = false;
    if (sessionMap.containsKey(sessionId)) {
        session = sessionMap.get(sessionId);
    } else {
        session = new FSPSession(sessionId, kcpOnUdp);
        sessionMap.put(sessionId, session);
        isNewSession = true;
    }
    session.handleReceive(bytes, isNewSession);

}

@Override
public void handleException(Throwable throwable, KcpOnUdp kcpOnUdp) {
    log.error(throwable.getMessage());
}

[dingzhichao]

麻烦请问下，该开源项目有线上游戏项目在用

[beykery]

很显然你需要把 byteBuf.release();这行注销掉

[dingzhichao]

很显然你需要把 byteBuf.release();这行注销掉

这个 byteBuf.release() 是后面加上才去的， 没加之前都报哪个错，我去掉之后也会报。 WARN io.netty.util.ReferenceCountUtil - Failed to release a message: DatagramPacket(/0.0.0.0:6666 => /127.0.0.1:51373, PooledUnsafeDirectByteBuf(freed))

大佬，你看下这个，貌似说 dp 释放失败。

[beykery]

int length = byteBuf.readableBytes();//得到可读字节数 byte[] bytes = new byte[length]; //分配一个具有length大小的数组 byteBuf.getBytes(0, bytes); //将缓冲区中的数据拷贝到这个数组中 byteBuf.release(); 这段是啥？ 你应该参考下我写的demo。

[beykery]

ResourceLeakDetector.setLevel(ResourceLeakDetector.Level.ADVANCED); 启动的时候加上这个试试？

[dingzhichao]

int length = byteBuf.readableBytes();//得到可读字节数 byte[] bytes = new byte[length]; //分配一个具有length大小的数组 byteBuf.getBytes(0, bytes); //将缓冲区中的数据拷贝到这个数组中 byteBuf.release(); 这段是啥？ 你应该参考下我写的demo。

嗯~ 其实就是参考你的那个testServer demo 来写的，因为你的demo里面对收到消息处理很简单，直接是字符串，我接受消息是结构体，所以需要解析 netty 的ByteBuf， int length = byteBuf.readableBytes();//得到可读字节数 byte[] bytes = new byte[length]; //分配一个具有length大小的数组 byteBuf.getBytes(0, bytes); //将缓冲区中的数据拷贝到这个数组中 这段的意思就是把ByteBuf 的所欲 读到 字节数组中来，以便给后续逻辑处理

[dingzhichao]

ResourceLeakDetector.setLevel(ResourceLeakDetector.Level.ADVANCED); 启动的时候加上这个试试？

这个其实加过，但是还是一样报错。

[dingzhichao]

int length = byteBuf.readableBytes();//得到可读字节数 byte[] bytes = new byte[length]; //分配一个具有length大小的数组 byteBuf.getBytes(0, bytes); //将缓冲区中的数据拷贝到这个数组中 byteBuf.release(); 这段是啥？ 你应该参考下我写的demo。

嗯~ 其实就是参考你的那个testServer demo 来写的，因为你的demo里面对收到消息处理很简单，直接是字符串，我接受消息是结构体，所以需要解析 netty 的ByteBuf， int length = byteBuf.readableBytes();//得到可读字节数 byte[] bytes = new byte[length]; //分配一个具有length大小的数组 byteBuf.getBytes(0, bytes); //将缓冲区中的数据拷贝到这个数组中 这段的意思就是把ByteBuf 的所欲 读到 字节数组中来，以便给后续逻辑处理

[dingzhichao]

int length = byteBuf.readableBytes();//得到可读字节数 byte[] bytes = new byte[length]; //分配一个具有length大小的数组 byteBuf.getBytes(0, bytes); //将缓冲区中的数据拷贝到这个数组中 byteBuf.release(); 这段是啥？ 你应该参考下我写的demo。

其实这段的 主要目的 就是把 数据 读到 byte数组，然后后面逻辑 用这个byte数组 进行反序列化 public void OnReceive(byte[] bytes, boolean isNewSession) { try { kcpNeedUpdateFlag = true; FSPDataC2S dataC2S = FSPDataC2S.parseFrom(bytes); //反序列化 onReceiveFSPData(dataC2S, isNewSession);//对接收到的数据进行 逻辑处理 } catch (Exception e) { e.printStackTrace(); } }

[beykery]

其实也不影响什么，它自己会保证不用的buf被release；不过我真没找到到底哪里的问题。

[dingzhichao]

嗯，通信过程中报错了，但是确实没有发生丢包，就是报错报到后面，内存溢出了，所以担心后面 通信的客户端数量上去了，服务器会crash掉

[beykery]

ResourceLeakDetector没关闭的话，没问题的。

[365082218]

我也有这个问题，就是自己handlerReceive里，如果不对bytebuf.release那么时间久了内存就申请溢出了，如果释放就会出现引用计数这个，然后服务端好像就不正常了，都是累积了一段时间才会这样，我感觉是库本身对bytebuf的申请和释放有问题