CrazyCoding123
CrazyCoding123
2016-07-03 14:00

JAVA中在使用Socket从客户端项服务端传文件时,程序阻塞在获取Socket套接字输入流那一行是为什么?

2
  • java

这样写会阻塞在下面那一行,而调整位置后成功时什么问题,在我的理解中这一行的声明只要出现在使用之前就可以了。望解答,感谢

客户端上传文件程序

 Socket socket = new Socket("127.0.0.1", 8888);
        File file = new File("D:\\1610\\android素材\\bg04.jpg");
        BufferedInputStream bis = new BufferedInputStream(new FileInputStream(file));
        ObjectOutputStream oos = new ObjectOutputStream(socket.getOutputStream());
        **ObjectInputStream ois = new ObjectInputStream(socket.getInputStream());**           //阻塞在这一行?我把这一行放在下面时该程序就运行成功,这之间有什么关系吗?希望大神解答,感谢!!!!
        System.out.println(file.getName());
        oos.writeUTF(file.getName());
        oos.writeLong(file.length());

        byte[] arr = new byte[1024];
        int len;
        while((len = bis.read(arr)) != -1){
            oos.write(arr,0,len);
            oos.flush();
        }
        //  上面那一行放在该位置
        System.out.println("1111");
        if(ois.readUTF().equals("下载成功")){
            System.out.println("文件上传成功");
            ois.close();
            oos.close();
            bis.close();
            socket.close();
        }

服务端接受文件代码块

 ServerSocket serverSocket = new ServerSocket(8888);
        System.out.println("服务器已启动...");
        while (true) {
            Socket socket = serverSocket.accept();
            ObjectInputStream ois = new ObjectInputStream(socket.getInputStream());
            //这个位置
            String fileName=ois.readUTF();
            long extent = ois.readLong();
            System.out.println(extent);
            File file = new File("D:/TestFile");
            if (file.isDirectory()) {
                System.out.println("文件夹已存在");
            } else {
                file.mkdirs();
            }
            BufferedOutputStream bos = new BufferedOutputStream(new FileOutputStream(file.getAbsolutePath() +"/"+ fileName));
            BufferedWriter bw = new BufferedWriter(new FileWriter("down.log",true));
            _**ObjectOutputStream oos = new ObjectOutputStream(socket.getOutputStream());**_//或者是我把这一行放在上面位置也能成功
            byte[] arr = new byte[1024];
            int len;
            long total = 0;
            while ((len = ois.read(arr)) != -1) {
                bos.write(arr, 0, len);
                total += len;
                bw.write("当前已下载" + (total * 100) / extent + "%"
                        + new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(new Date()));
                bw.newLine();
                bw.flush();
                if (total == extent) {
                    oos.writeUTF("下载成功");
                    break;
                }
            }
            System.out.println("下载成功");
            oos.close();
            bw.close();
            bos.close();
            ois.close();
            socket.close();
        }
  • 点赞
  • 回答
  • 收藏
  • 复制链接分享

4条回答