Envoi des fichiers par des sockets java

public class Commun
{
    public static void transfert(InputStream in, OutputStream out, boolean closeOnExit) throws IOException
    {
        byte buf[] = new byte[1024];
        
        int n;
        while((n=in.read(buf))!=-1)
            out.write(buf,0,n);
        
        if (closeOnExit)
        {
            in.close();
            out.close();
        }
    }
}

public class Client
{
    public static void main(String...args) throws IOException 
    { 
        Socket sock = new Socket(InetAddress.getLocalHost(),9001);
    
        Commun.transfert(
                new FileInputStream("D:\\test.jpg"),
                sock.getOutputStream(),
                true);
        
        sock.close();
    } 
}

public class Serveur
{
    public static void main(String...args) throws IOException 
    { 
        Socket sock = new ServerSocket(9001).accept();
        
        Commun.transfert(
                sock.getInputStream(),
                new FileOutputStream("D:\\test2.jpg"),
                true);
        
        sock.close(); 
    } 
}

public static void transfert(InputStream in, OutputStream out, boolean closeOnExit) throws IOException {
        byte buf[] = new byte[1024];
        
        int n;
        while((n=in.read(buf))==1024){
            out.write(buf,0,n);
        }
        //et la on ajoute les bytes plus petits que 1024 ) la fin
        out.write(buf,0,n);
        if (closeOnExit) {
            in.close();
            out.close();
        }
    }

Bonjour...
Bien que ce sujet doive être enterré... pour ceux qui cherchaient (comme moi) à transférer un fichier d'un client au serveur, qui le retransmettait à un client, sans fermer des sockets, je me suis contenté d'un code comme ça:

Client envoyeur:

import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.io.PrintWriter;

public class Transfert {
    public static void transfert(InputStream in, OutputStream out) throws IOException {
        byte buf[] = new byte[1024];
        
        int n;
        while((n=in.read(buf))!=-1){
            out.write(buf,0,n);
        }
        PrintWriter outp = new PrintWriter(out);
  outp.println("!§#%%123{#done#}123%%#§!");
  outp.flush();
    }
}

Serveur:

import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.io.PrintWriter;

public class Transfert {
 
    public static void transfert(InputStream in, OutputStream out){
        byte buf[] = new byte[1024];
        
        int n;
        try {
         boolean cont = true;
   while(cont){
    n = in.read(buf);
       out.write(buf,0,n);
       if(isEndReached(buf)){
        cont = false;
       }
   }
   PrintWriter outp = new PrintWriter(out);
   outp.println("!§#%%123{#done#}123%%#§!");
   outp.flush();
  } catch (IOException e) {
   e.printStackTrace();
  }
    }
    
    private static String GetString(byte[] bytes){
        return new String(bytes);
    }
    
    private static boolean isEndReached(byte[] buf){
     if(GetString(buf).contains("!§#%%123{#done#}123%%#§!")){
      return true;
     }
     return false;
    }
    
}

Le client recepteur:

import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;

public class Transfert {
 
    public static void transfert(InputStream in, OutputStream out){
        byte buf[] = new byte[1024];
        
        int n;
        try {
         boolean cont = true;
   while(cont){
    n = in.read(buf);
       out.write(buf,0,n);
       if(isEndReached(buf)){
        cont = false;
       }
   }
  } catch (IOException e) {
   e.printStackTrace();
  }
    }
    
    static String GetString(byte[] bytes){
        return new String(bytes);
    }
    
    public static boolean isEndReached(byte[] buf){
     if(GetString(buf).contains("!§#%%123{#done#}123%%#§!")){
      return true;
     }
     return false;
    }
    
}

Beaucoup trouverons à redire de ce code, mais il remplit parfaitement sa fonction :)