zoukankan      html  css  js  c++  java
  • Netty返回数据丢包的问题之一

    这个问题是在一个群友做压力测试的时候发现的。使用客户端和netty创建一条连接,然后写了一个for循环不停的给服务器发送1500条信息,发现返回只有几百条。另外几百条不知道哪去了。查看代码,发现在服务器发送前做了一个判断:


     

    通过查看源码,问题就在isWriteable()里面,下面看一下源码,在AbstractChannel里面:


     

    再看buf.isWritebale()的实现:


     

    这里有一个变量,控制了是否可以写,那这个变量什么时候发生变化呢,我们接着找,先看看是什么情况下被修改为非0的


     

    这个方法是在这里被调用 的:


     

    这个方法是用来接收发送数据的缓存的,从这里可以看出,当缓存的数据长库大于channel.config.getWriteBufferHighWaterMark()的时候,就不能再写了。这是一种限流 措施,防止数据写入太大,导致消息堆积,内存不足的情况。

    我们看到这个值是在channel config中配置的,那么就可以在channel config中修改这个值,

     ctx.channel().config().setWriteBufferHighWaterMark(1024*1024 * 8);

    也可以在服务启动的时候设置:


     给孩子的礼物:


     

     


    欢迎加群交流,QQ群:66728073,197321069,398808948 还可以扫描博客左上角二维码,关注游戏技术网公众号

  • 相关阅读:
    线程(C++11)
    初始化、赋值
    优质学习资料总结
    移植之乱谈
    采集音频和摄像头视频并实时H264编码及AAC编码
    H264解码器源码(Android 1.6 版)
    移植ffmpeg到VC环境心得
    收集的网络上大型的开源图像处理软件代码(提供下载链接)
    C++开源库,欢迎补充。
    一个轻量级AOP的实现(开源)
  • 原文地址:https://www.cnblogs.com/wgslucky/p/9815896.html
Copyright © 2011-2022 走看看