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;
    }

总结

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

相关文章

  • SpringBoot常用计量与bean属性校验和进制数据转换规则全面分析

    SpringBoot常用计量与bean属性校验和进制数据转换规则全面分析

    这篇文章主要介绍了SpringBoot常用计量、bean属性校验与进制数据转换规则,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习吧
    2022-10-10
  • SpringBoot Bean被加载时进行控制

    SpringBoot Bean被加载时进行控制

    很多时候我们需要根据不同的条件在容器中加载不同的Bean,或者根据不同的条件来选择是否在容器中加载某个Bean,这就是Bean的加载控制,一般我们可以通过编程式或注解式两种不同的方式来完成Bean的加载控制
    2023-02-02
  • 程序包org.springframework.boot不存在的问题解决

    程序包org.springframework.boot不存在的问题解决

    本文主要介绍了程序包org.springframework.boot不存在的问题解决,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧
    2024-09-09
  • spring boot 实现Minio分片上传的步骤

    spring boot 实现Minio分片上传的步骤

    分片上传,就是将所要上传的文件,按照一定的大小,将整个文件分隔成多个数据块来进行分别上传,上传完之后再由服务端对所有上传的文件进行汇总整合成原始的文件,本文给大家介绍spring boot 实现Minio分片上传的步骤,感兴趣的朋友跟随小编一起看看吧
    2023-10-10
  • JVM自定义类加载器在代码扩展性实践分享

    JVM自定义类加载器在代码扩展性实践分享

    这篇文章主要介绍了JVM自定义类加载器在代码扩展性实践分享,一个类型从被加载到虚拟机内存中开始,到卸载出内存为止,它的整个生命周期将会经历加载、验证、准备、解析、初始化 、使用和卸载七个阶段,其中验证、准备、解析三个部分统称为连接
    2022-06-06
  • Mybatis Plus条件构造器ConditionConstructor用法实例解析

    Mybatis Plus条件构造器ConditionConstructor用法实例解析

    这篇文章主要介绍了Mybatis Plus条件构造器ConditionConstructor用法实例解析,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下
    2020-08-08
  • Java sdk安装及配置案例详解

    Java sdk安装及配置案例详解

    这篇文章主要介绍了Java sdk安装及配置案例详解,本篇文章通过简要的案例,讲解了该项技术的了解与使用,以下就是详细内容,需要的朋友可以参考下
    2021-08-08
  • SpringBoot服务设置禁止server.point端口的使用

    SpringBoot服务设置禁止server.point端口的使用

    本文主要介绍了SpringBoot服务设置禁止server.point端口的使用,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧
    2024-01-01
  • Maven编译报错:未与 -source 8 一起设置引导类路径的完美解决方案

    Maven编译报错:未与 -source 8 一起设置引导类路径的完美解决方案

    这篇文章主要为大家详细介绍了Maven编译报错:未与 -source 8 一起设置引导类路径的相关解决方案,文中的示例代码讲解详细,有需要的小伙伴可以了解下
    2025-10-10
  • SpringBoot实现公共字段自动填充的方法步骤

    SpringBoot实现公共字段自动填充的方法步骤

    这篇文章主要介绍了SpringBoot实现公共字段自动填充的方法步骤,文中通过代码示例讲解的非常详细,对大家的学习或工作有一定的帮助,需要的朋友可以参考下
    2024-11-11

最新评论