CrazyCoding123 2016-07-03 14:00 采纳率: 100%
浏览 2058
已采纳

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

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

客户端上传文件程序

 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条回答 默认 最新

  • _1_1_7_ 2016-07-04 01:33
    关注

    看jdk官方的文档就知道答案了:
    public ObjectInputStream(InputStream in)
    throws IOException创建从指定 InputStream 读取的 ObjectInputStream。从流读取序列化头部并予以验证。在对应的 ObjectOutputStream 写入并刷新头部之前,此构造方法将阻塞。

                                    这时候socket.getInputStream()还没有数据流过来,所以就等待数据,阻塞了
    
    本回答被题主选为最佳回答 , 对您是否有帮助呢?
    评论
查看更多回答(3条)

报告相同问题?

悬赏问题

  • ¥15 对于相关问题的求解与代码
  • ¥15 ubuntu子系统密码忘记
  • ¥15 信号傅里叶变换在matlab上遇到的小问题请求帮助
  • ¥15 保护模式-系统加载-段寄存器
  • ¥15 电脑桌面设定一个区域禁止鼠标操作
  • ¥15 求NPF226060磁芯的详细资料
  • ¥15 使用R语言marginaleffects包进行边际效应图绘制
  • ¥20 usb设备兼容性问题
  • ¥15 错误(10048): “调用exui内部功能”库命令的参数“参数4”不能接受空数据。怎么解决啊
  • ¥15 安装svn网络有问题怎么办