如何停止套接字 一直在循环 Java 中写入数据



我做了服务器客户端应用程序,服务器将向客户端发送文件,客户端将接收该文件并将其保存在C中:/在任何地方。我首先发送一个字符串"File",以告诉客户端接收文件,然后服务器将文件名和大小发送到客户端,然后开始发送它。问题是客户端没有接收文件,尽管它循环读取并获取所有字节,但没有写入所需的文件对象。请看一下我已经显示的客户端代码

以下是服务器代码:

public void run(){
    try{
        System.out.println("Starting writing file");
        objOut.writeObject("File");
        objOut.flush();
        File f= new File(filePath);
        String name= f.getName();
        int length =(int) f.length();
        objOut.writeObject(name);
        objOut.flush();
        objOut.writeObject(length);
        objOut.flush();
        byte[] filebytes = new byte[(int)f.length()];
        FileInputStream fin= new FileInputStream(f);
        BufferedInputStream bin = new BufferedInputStream(fin);
        bin.read(filebytes, 0, filebytes.length);
        BufferedOutputStream bout = new BufferedOutputStream(objOut);
        bout = new BufferedOutputStream(objOut);
        bout.write(filebytes, 0, filebytes.length);
        bout.flush();      
        System.out.println("File completelty sent");
    }
    catch(Exception ex)
    {
        System.out.println("error on writing file : "+ex.getMessage());
    }
}

以下是客户端代码:

 while(true){
            fobjIn = new ObjectInputStream(fileSock.getInputStream());
            String str = (String) fobjIn.readObject();
            if(str.equals("File"))
            {
                System.out.println("Starting receiving file");
                ReceiveFile();
            }
            System.out.println(str);
        }
 public void ReceiveFile() throws Exception{
     String name =(String)fobjIn.readObject();
   File f = new File("C:/Temp/" +name);
   f.createNewFile();
   int length = (int) fobjIn.readObject();
   FileOutputStream fout = new FileOutputStream(f);
   BufferedOutputStream buffout = new BufferedOutputStream(fout);
   byte[] filebyte = new byte[length];
   int bytesRead=0,current=0;
   bytesRead = fobjIn.read(filebyte, 0, filebyte.length);
    do {
        bytesRead = fobjIn.read(filebyte, current, (filebyte.length-current));
        if(bytesRead > 0) {
            current += bytesRead;
            System.out.println("writting" + bytesRead);
        }
        else break;
     } while(bytesRead > -1);

^^^^^^^它不会在乞讨时从循环中出来^^^^^^^^

    buffout.write(filebyte, 0 , current);
    buffout.flush();
    System.out.println("written");
}
完成

发送后,您可能应该关闭服务器端的流,以便可以通知客户端服务器已完成发送。否则,它只会坐在那里等待更多数据。

相关内容

  • 没有找到相关文章

最新更新