NioDemos中NioSendClient发送时没有对write后的buffer做判断，网络拥塞时可能会导致丢包

源码位置：
NioDemos/src/main/java/com/crazymakercircle/iodemo/socketDemos/NioSendClient.java

```
while ((length = fileChannel.read(buffer)) > 0)
            {
                buffer.flip();
                socketChannel.write(buffer);
                buffer.clear();
                progress += length;
                Logger.debug("| " + (100 * progress / file.length()) + "% |");
            }
```

Java API文档中有描述：![api文档说明](https://images.gitee.com/uploads/images/2021/0412/200300_d3fd9b98_7730544.png "Annotation 2021-04-12 200253.png")
write的返回值可能为0，此时此段数据包没能写入到channel中无法进行发送，会导致文件发送的不完整，可修改为

```
while ((length = fileChannel.read(buffer)) > 0)
            {
                buffer.flip();
                socketChannel.write(buffer);
                while(buffer.position()<buffer.limit()){
                    Logger.debug("network congestion ，not send temporarily ，sleep for one                 
                        second")；
                    try {
                        Thread.sleep(1000);
                    } catch (InterruptedException e) {
                        log.error("InterruptedException", e);
                    }
                    socketChannel.write(buffer);
                }
                buffer.clear();
                progress += length;
                Logger.debug("| " + (100 * progress / file.length()) + "% |");
            }
```

疯狂创客圈/netty_redis_zookeeper高并发实战源码

内容风险标识

评论 (0)

疯狂创客圈/netty_redis_zookeeper高并发实战源码 .gitee-modal { width: 500px !important; }

内容风险标识