鱼C论坛

 找回密码
 立即注册
查看: 3269|回复: 2

通过socket完成zip文件的网络传输,但是传输过去会出现文件损坏。

[复制链接]
发表于 2020-8-17 22:01:36 | 显示全部楼层 |阅读模式
10鱼币
本帖最后由 木目丶人言 于 2020-8-18 11:08 编辑

遇到的问题:我定义了一个字节数组data: byte[],用来暂存读取的字节数据, 当这个字节数组的大小设置为8192时传输的文件没有问题,8192字节应该是BufferedInputStream和BufferedOutputStream的默认缓存大小。当我吧这个字节数组的大小定义为非8192的数时传输的文件就会出现文件损坏,使用BufferedInputStream(socket.getInputStream(), databig)和BufferedOutputStream(socket.getOutputStream(), databig);这两个构造函数时应该已经把默认的缓存大小更改了,但是传输依然出现文件损坏。到这里我就不知道是哪里出错了,如果是因为缓存大小与我定义的字节数组大小不合适的话,那在我修改默认缓存大小后应该能正常传输才对,但是并非如此。请求大神讲解一下,谢谢。


接收端代码:
import java.io.BufferedInputStream;
import java.io.DataInputStream;
import java.io.File;
import java.io.FileOutputStream;
import java.net.ServerSocket;
import java.net.Socket;

public class Receive {
        final static String name = "E:\\2.zip";//接收文件储存位置
        final static int port = 9999;
        final static int databig = 8192;
       
        public static void main(String[] args){
                File file = new File(name);
                byte[] data = new byte[databig];
                long big = 0;
                long count = 0;
               
                try {
                        ServerSocket server = new ServerSocket(port);
                        System.out.println("等待发送端连接");
                        Socket socket = server.accept();
                        System.out.println("连接成功");
                        file.createNewFile();
                        FileOutputStream out = new FileOutputStream(file);
                        BufferedInputStream in = new BufferedInputStream(socket.getInputStream(), databig);
                        DataInputStream in2 = new DataInputStream(socket.getInputStream());
                        //接收文件大小
                        big = in2.readLong();
                        System.out.println(big);
                       
                        while(true)
                        {                               
                                in.read(data, 0, data.length);
                                out.write(data, 0, data.length);
                                System.out.println((count*1.0/big*1.0)*100);       
                                count+=databig;
                        }                       
                }
                catch (Exception e) {
                        System.out.println(e.toString());
                }
                System.out.println("接收成功");
        }
}

发送端代码:
import java.io.BufferedOutputStream;
import java.io.DataOutputStream;
import java.io.File;
import java.io.FileInputStream;
import java.net.Socket;

public class Send {
        final static String name = "E:\\2.zip";
        final static String ip = "19.168.43.01";
        final static int port = 9999;
        final static int filebig = 8192;
       
        public static void main(String[] args) {       
                File file = new File(name);
                long big = file.length();
                System.out.printf("文件总大小(Byte): ");
                System.out.println(big);
                byte[] data = new byte[filebig];
                long count = 0;
               
                try {
                        Socket socket = new Socket(ip, port);
                        FileInputStream in = new FileInputStream(file);
                        BufferedOutputStream out = new BufferedOutputStream(socket.getOutputStream(), filebig);
                        DataOutputStream out2 = new DataOutputStream(socket.getOutputStream());               
                        //发送文件大小
                        out2.writeLong(big);
                        out2.flush();
                                       
                        while(in.read(data, 0, data.length) != -1)
                        {
                                System.out.printf("发送文件百分比:");
                                System.out.println((count*1.0/big*1.0)*100);
                                out.write(data, 0, data.length);
                                out.flush();
                                count+=filebig;
                        }

                        System.out.println("发送成功");
                }
                catch (Exception e) {
                        e.printStackTrace();
                }
        }
}

想知道小甲鱼最近在做啥?请访问 -> ilovefishc.com
回复

使用道具 举报

 楼主| 发表于 2020-8-18 21:55:35 | 显示全部楼层
已经知道原因了,谢谢。
想知道小甲鱼最近在做啥?请访问 -> ilovefishc.com
回复

使用道具 举报

 楼主| 发表于 2020-8-18 21:57:51 | 显示全部楼层
已经知道原因了,是因为在写入文件的过程中因为定义的字节数组在最后一轮传输时会出现没有写满数据的情况,需要对字节数组内的信息进行判断再写入文件,否则最后文件会出现很多null。
想知道小甲鱼最近在做啥?请访问 -> ilovefishc.com
回复

使用道具 举报

您需要登录后才可以回帖 登录 | 立即注册

本版积分规则

小黑屋|手机版|Archiver|鱼C工作室 ( 粤ICP备18085999号-1 | 粤公网安备 44051102000585号)

GMT+8, 2024-5-11 02:59

Powered by Discuz! X3.4

© 2001-2023 Discuz! Team.

快速回复 返回顶部 返回列表