java socket大数据传输丢失问题及解决

 更新时间:2024年08月10日 14:05:30   作者:yahahassr  
这篇文章主要介绍了java socket大数据传输丢失问题及解决,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教

java socket大数据传输丢失

最近遇见一个问题。利用java 的socket进行数据传输时,当数据量过大,比如4w个字节。

这时候我在客户端输出流将数据发送给服务器。

服务器如果利用数组接收时(即is.read(byte[])方法),接收到的数据不全。网上解决方法。

一、分批发送,分批读取,并不要直接读取

将输入输出流利用BufferedInputStream包装。

实测这种方法不能根本上解决问题,治标不治本。还是会有概率丢失。

二、实际上,数据是不会丢失的

即使输入数据过大导致溢出。数据也不会丢失。

根据观察,应该只是数据还没有传输过来,但是利用is.read(byte[])方法时,即使读取到的数据不到byte[]数组长度时,该方法也可以进行下去,不会阻塞!!!

譬如以下代码:

public class Test {
    @org.junit.Test
    public void server() throws IOException {
        ServerSocket serverSocket = new ServerSocket(8080);
        while (true){
            Socket accept = serverSocket.accept();
            InputStream is = accept.getInputStream();
            byte[] bytes = new byte[5];
            int len = is.read(bytes);
            System.out.println(Arrays.toString(bytes));//发送端发送的数据只有两个字节,我们接收端设置为5个字节的字节数组,结果打印[1,2,0,0,0],而不会在上一步阻塞
        }
    }

    @org.junit.Test
    public void client() throws IOException {
        Socket socket = new Socket("127.0.0.1",8080);
        OutputStream os = socket.getOutputStream();
        os.write(new byte[]{1,2});
    }
}

从这个例子我们就知道为什么会丢失数据了。

原因有两点:

  • 网络延时
  • inputStream.read(byte[])方法读取的数据长度不一定等于byte[]数组长度

根据以上两点,修改后的接收端代码应该如此。

public static byte[] readData(InputStream is,int length) throws IOException {
        byte[] bytes = new byte[length];
        int index = 0;
        int len = 0;
        while(index < length){
            len = is.read(bytes,index,length - index);
            //每次读取完判断数据是否全部读取完毕
            if(len > 0){
                index += len;
            }else {
                break;
            }
        }
        return bytes;
    }

总结

以上为个人经验,希望能给大家一个参考,也希望大家多多支持脚本之家。

相关文章

  • 解决Java中SimpleDateFormat线程不安全的五种方案

    解决Java中SimpleDateFormat线程不安全的五种方案

    SimpleDateFormat 就是一个典型的线程不安全事例,本文主要介绍了解决Java中SimpleDateFormat线程不安全的五种方案,需要的朋友们下面随着小编来一起学习学习吧
    2021-05-05
  • 面试题:Java 实现查找旋转数组的最小数字

    面试题:Java 实现查找旋转数组的最小数字

    这篇文章主要介绍了Java 实现查找旋转数组的最小数字,小编觉得挺不错的,现在分享给大家,也给大家做个参考。一起跟随小编过来看看吧
    2018-07-07
  • java获取各种路径的基本方法

    java获取各种路径的基本方法

    这篇文章主要为大家详细介绍了java获取各种路径的基本方法,具有一定的参考价值,感兴趣的小伙伴们可以参考一下
    2016-10-10
  • Spring更简单的存储方式与获取方式详解

    Spring更简单的存储方式与获取方式详解

    Spring是一个轻量级的IoC和AOP容器框架,是为Java应用程序提供基础性服务的一套框架,目的是用于简化企业应用程序的开发,它使得开发者只需要关心业务需求,下面这篇文章主要给大家介绍了关于Spring更简单的存储方式与获取方式的相关资料,需要的朋友可以参考下
    2022-06-06
  • Java 8 Stream 的终极技巧——Collectors 功能与操作方法详解

    Java 8 Stream 的终极技巧——Collectors 功能与操作方法详解

    这篇文章主要介绍了Java 8 Stream Collectors 功能与操作方法,结合实例形式详细分析了Java 8 Stream Collectors 功能、操作方法及相关注意事项,需要的朋友可以参考下
    2020-05-05
  • spring boot拦截器实现IP黑名单实例代码

    spring boot拦截器实现IP黑名单实例代码

    本篇文章主要介绍了spring boot拦截器实现IP黑名单实例代码,具有一定的参考价值,感兴趣的小伙伴们可以参考一下
    2017-04-04
  • Java冒泡排序及优化介绍

    Java冒泡排序及优化介绍

    大家好,本篇文章主要讲的是Java冒泡排序及优化介绍,感兴趣的同学赶快来看一看吧,对你有帮助的话记得收藏一下,方便下次浏览
    2021-12-12
  • IntelliJ IDEA 2023.2最新版激活方法及验证ja-netfilter配置是否成功

    IntelliJ IDEA 2023.2最新版激活方法及验证ja-netfilter配置是否成功

    随着2023.2版本的发布,用户们渴望了解如何激活这个最新版的IDE,本文将介绍三种可行的激活方案,包括许可证服务器、许可证代码和idea vmoptions配置,帮助读者成功激活并充分利用IDEA的功能,感兴趣的朋友参考下吧
    2023-08-08
  • springboot bean循环依赖实现以及源码分析

    springboot bean循环依赖实现以及源码分析

    最近在使用Springboot做项目的时候,遇到了一个循环依赖的 问题,所以下面这篇文章主要给大家介绍了关于springboot bean循环依赖实现以及源码分析的相关资料,需要的朋友可以参考下
    2021-06-06
  • Java中类赋值的解释实例详解

    Java中类赋值的解释实例详解

    这篇文章主要介绍了Java中类赋值的解释实例详解的相关资料,需要的朋友可以参考下
    2017-06-06

最新评论