envoi des fichiers par des sockets java Résolu/Fermé

Question

salut, pour mon projet je dois implémenter une application web qui servira à l'envoi des images et du sons, pour cela j'ai utilisé les sockets en JAVA j'ai mes codes qui marchent parfaitement coté serveur et coté client, je fais le RUN tout se passe bien et mon fichier, une fois reçue par mon serveur il est bien créé mais quand je le consulte je ne le trouve pas en totalité ( pour le son seulement quelques secondes sont jouées et parfois non executable, pour l'image, elle ne s'affiche pas il n'y a q'un croix rouge ) veuillez m'aider S.V.P et merci et voila mes codes : Côté Client: public class Client { public static void main(String[] zero) throws IOException { File f = new File("C:\Users\Douda\Downloads\musicmp4.MP4"); if(f.exists()) { System.out.println("Envoi du fichier "+f.toURI().toURL()); Socket s = new Socket(InetAddress.getLocalHost(),9001); OutputStream fluxsortie = s.getOutputStream(); long taillefichier =f.length(); System.out.println("Taille : "+ taillefichier); long nbpassagesuposé=taillefichier / 4096; System.out.println("Passages supposés : "+nbpassagesuposé); InputStream in = new BufferedInputStream(new FileInputStream(f)); ByteArrayOutputStream tableaubytes = new ByteArrayOutputStream(); BufferedOutputStream tampon = new BufferedOutputStream(tableaubytes); int lu = in.read(); int[] aecrire = new int[4096]; int compteur = 0; long ouonestrendu=0; //Tant qu'on est pas à la fin du fichier while(lu > -1) { //On lit les données du fichier aecrire[compteur] = lu; lu = in.read(); compteur++; //Quand on a rempli le tableau, on envoie un paquet de 4096 octets if(compteur == 4096) { compteur=0; ouonestrendu++; //On remplit le tampon for(int x=0;x<4096;x++) tampon.write(aecrire[x]); //Et on l'envoie byte[] b=tableaubytes.toByteArray(); tampon.write(b); tampon.flush(); tableaubytes.reset(); System.out.println("Avancement : "+(float) ouonestrendu/nbpassagesuposé * 100+"%"); } } //On envoie le dernier paquet, qui ne fait pas forcément 4096 octets //On remplit le tampon for(int x=0;x -1) { outBuffer.write(lu); lu = inBuffer.read(); compteur++; } outBuffer.write(lu); outBuffer.flush(); outBuffer.close(); inBuffer.close(); out.flush(); out.close(); inpute.close(); serviceSocket.close(); } } Windows 7 / Safari 535.1

KX · Accepted Answer

Bon j'ai regardé ton code, le moins qu'on puisse dire c'est que tu te compliques la vie !
En particulier, pourquoi as-tu besoin d'ouvrir autant de flux ?

Voici le coeur du programme, tu vas voir qu'en fait c'est très simple !

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(); 
    } 
}

Fallentree · Answer

t es sur qu il faut pas passer tes buffers en hexa ???   
Et ta boucle d'arret doit se faire avec un code d'echappement, si mes souvenirs sont bon.   
Par exemple un buffer d'une certaine taille avec des carracteres a la manque dedans ...  
tu peux aussi rajouter un correcteur d erreur sur ta trame comme une somme que tu envoies soit à la fin soit comme nouvelle trame ... 
Differents modèles de protocoles te permettent de jongler sur ces echanges ...
par exemple, renvoie de la trame si elle est fausse ou intercepté ...

Bob573 · Answer

ce sujet date, juste pour ajouter pour ceux qui cherchent:

La fonction transfert bug parfois en fonction des extensions, et la boucle ne donne jamais comme résultat -1... mieux vaut utiliser:

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();
        }
    }

azerty · Answer

et la class Commun on en fait quoi ?

Utilisateur anonyme · Answer

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 :)

pater · Answer

est il possible d'accelerer et de reduire le transfert des donnees via  UDP Socket avec Java. Si ou comment? pardon exemple concret.
Merci

Envoi des fichiers par des sockets java

6 réponses

Discussions similaires