サーバからクライアントへのファイルのコピー中に "ソケットがクローズされました"例外を解決する

Question

クライアントからサーバへファイルをコピーする簡単なクライアントサーバアプリケーションをやっています。私はソケットを使っています。 Appsでは、クライアントメニューにいくつかのオプションが表示されます。1.サーバー上でコピーを作成します。2.サーバーなどからファイルコピーを取得します。

問題は最初のオプションを選択するときです。私はこの例外について読んでいますが、私はこの問題をどのように解決するか考えていません。私はあなたのアイデアを楽しみにしています。

クライアント側コードの一部があります：

public Client(String host, int port) { 
     try { 
      s = new Socket(host, port); 
      System.out.println("Witaj w programie"); 
      boolean finished = false; 
      Scanner sc = new Scanner(System.in); 
      while(!finished){ 
       System.out.println("\n\n1.Zrob kopie zapasowa pliku"); 
       System.out.println("2. Przywroc kopie"); 
       System.out.println("0.Zakoncz"); 
       char c = sc.nextLine().charAt(0); 
       switch(c){ 
       case '1': 
        this.sendMessage(1); 
        makeCopy(s); 
        //s.close(); 
        break; ... 

sendMessageメソッドコード：

public void sendMessage(int message_id) throws IOException{ 
     oos = new ObjectOutputStream(s.getOutputStream()); 
     ois = new ObjectInputStream(s.getInputStream()); 
     oos.writeInt(message_id); 
     oos.flush(); 
    } 

とmakeCopyメソッドコード：Serverコードから

private void makeCopy(Socket clientSock) throws IOException { 
     File file = new File("D:\\klient\\doKopii.bmp"); 
     DataOutputStream dos = new DataOutputStream(clientSock.getOutputStream()); 
     FileInputStream fis = new FileInputStream(file); 
     byte[] buffer = new byte[4096]; 

     while (fis.read(buffer) > 0) { 
      dos.write(buffer); 
     } 

     fis.close(); 
     dos.close(); 
    } 

ダウンロードコピー：

private void saveFile(Socket clientSock) throws IOException { 
     //DataInputStream dis = new DataInputStream(clientSock.getInputStream()); 
     FileOutputStream fos = new FileOutputStream("D:\\klient\\przywroconaKopia.bmp"); 
     File zSerwera = new File("D:\\serwer\\kopiaPliku.bmp"); 
     byte[] buffer = new byte[4096]; 

     int filesize = (int)zSerwera.length(); 
     int read = 0; 
     int totalRead = 0; 
     int remaining = filesize; 
     while((read = ois.read(buffer, 0, Math.min(buffer.length, remaining))) > 0) { 
      totalRead += read; 
      remaining -= read; 
      System.out.println("read " + totalRead + " bytes."); 
      fos.write(buffer, 0, read); 
     } 

     //fos.close(); 
     //ois.close(); 
    } 

私は、DataOutputStreamの終了によってソケットが閉じられているため、これが機能しないことに気付いています。私はこの行を削除しましたが、1つのオプションを選択してから2番目のオプションを選択すると、最初のアプリケーションが終了した時点でアプリケーションがフリーズします。

Answer 1

oos = new ObjectOutputStream(s.getOutputStream()); 
    ois = new ObjectInputStream(s.getInputStream()); 

public void sendMessage(int message_id) throws IOException{ 
     oos.writeInt(message_id); 
} 

インスタンス変数としてoosとoisを作成し、それらはただ1つの時間のためにインスタンス化されていることを確認してください。あなたが別々にデータ出力ストリームを取得する必要があり、なぜ あなたは同じObjectOutputStreamのにバイト配列を送信することができます

private void makeCopy(Socket clientSock) throws IOException { 
     File file = new File("D:\\klient\\doKopii.bmp"); 
     FileInputStream fis = new FileInputStream(file); 
     byte[] buffer = new byte[4096]; 

     while (fis.read(buffer) > 0) { 
      oos.write(buffer); 
     } 
} 

これは多分uは

Answer 2

ここにいくつかの問題があります。

• this answerに示すように、ファイルの長さをファイルよりも先に送信し、受信者でそのバイト数を正確に読み取る必要があります。
• ストリームタイプを混在させたり、新しいストリームを作成したりしないでください。両端のソケットの寿命は同じObjectInputStream/ObjectOutputStreamのペアを使用してください。