Forum |  HardWare.fr | News | Articles | PC | S'identifier | S'inscrire | Shop Recherche
1624 connectés 

  FORUM HardWare.fr
  Programmation
  Java

  envoi de gros fichier par socket

 
 


 Mot :   Pseudo :  
 
Bas de page
Auteur Sujet :

envoi de gros fichier par socket

n°2073709
dumoulex
Posté le 04-05-2011 à 10:47:18  profilanswer
 


bonjour,
 
je dois faire du transfert de fichiers assez volumineux par socket, mais je bloque un peu...
 
j'utilise un tampon pour decouper mon fichier, j'arrive bien a le transferer mais le client n'arrive pas à voir quand est ce que la fin du fichier arrive..
 
voici la code coté serveur (qui envoie le fichier) :

Code :
  1. File f = new File(pathname);
  2. System.out.println("Envoi du fichier " + f.getName());
  4. long taillefichier =f.length();
  6. System.out.println("Taille : "+ taillefichier);
  8. long nbpassagesuposé=taillefichier / 8192;
  10. System.out.println("Passages supposés : "+nbpassagesuposé);
  12. InputStream in = new BufferedInputStream(new FileInputStream(f));
  13. ByteArrayOutputStream tableaubytes = new ByteArrayOutputStream();
  14. BufferedOutputStream tampon = new BufferedOutputStream(tableaubytes);
  16. int lu = in.read();
  17. int[] aecrire = new int[8192];
  18. int compteur = 0;
  19. long ouonestrendu=0;
  21. //Tant qu'on est pas à la fin fichier
  22. while(lu > -1){
  23. //On lit les données du fichier
  24. aecrire[compteur] = lu;
  25. lu = in.read();
  26. compteur++;
  28. //Quand on a rempli le tableau, on envoie un paquet de 8192 octets
  29. if(compteur == 8192){
  30.  compteur=0;
  31.  ouonestrendu++;
  32.  //On remplit le tampon
  33.  for(int x=0;x<8192;x++)
  34.  tampon.write(aecrire[x]);
  36.  //Et on l'envoie
  37.  fluxsortie.write(tableaubytes.toByteArray());
  38.  tableaubytes.reset();
  39.  System.out.println("Avancement : "+(float) ouonestrendu/nbpassagesuposé * 100+"%" );
  40. }
  41. }
  43. //On envoie le dernier paquet, qui ne fait pas forcément 4096 octets
  44. //On remplit le tampon
  45. for(int x=0;x<compteur;x++)
  46. tampon.write(aecrire[x]);
  48. //Et on l'envoie
  49. tampon.flush();
  50. fluxsortie.write(tableaubytes.toByteArray());
  51. fluxsortie.flush();
  53. System.out.println("Avancement: "+(float) ouonestrendu/nbpassagesuposé * 100+"%" );
  55. System.out.println("fini" );
  56. in.close();
  57. tampon.close();
  58. System.out.println("Passages effectués : "+ouonestrendu);


 
 
voici le client qui recoit :
 

Code :
  1. Byte[] taillefichier;
  2. int lu;
  3. long taille = 0;
  5. //Création de l'entrée
  6. InputStream inpute = socket.getInputStream();
  8. OutputStream out = new FileOutputStream("/home/ginko/" + nomVideo);
  10. //Reçoit du client
  11. BufferedInputStream inBuffer = new BufferedInputStream(inpute);
  13. //Envoi vers le fichier
  14. BufferedOutputStream outBuffer = new BufferedOutputStream(out);
  16. lu = 0;
  18. int compteur = 0;
  20. while(lu > -1){
  21. lu = inBuffer.read();
  22. outBuffer.write(lu);
  24. compteur++;
  25. }
  27. outBuffer.flush();
  28. outBuffer.close();
  29. inBuffer.close();
  31. out.flush();
  32. out.close();
  33. inpute.close();
  34. System.out.println("fini" );


 
 
j'ai bien le transfert de fichier qui s'effectue, mais il ne s'arrete pas...  
 
si quelqu'un a deja fait qqch de similaire et peut me preter main forte..  
 
merci d'avance

mood
Publicité
Posté le 04-05-2011 à 10:47:18  profilanswer
 

n°2073752
gelatine_v​elue
Posté le 04-05-2011 à 12:38:35  profilanswer
 

C'est quoi la valeur de "lu" côté client?

 

Sinon tu fermes pas ton fluxsortie par un fluxsortie.close().


Message édité par gelatine_velue le 04-05-2011 à 12:41:43
n°2073760
dumoulex
Posté le 04-05-2011 à 13:35:46  profilanswer
 

la valeur de lu ne passe jamais à -1...
 
elle ne voit pas la fin du fichier.. donc je ne peux pas l'arrêter.
 
pour ça, j'ai trouvé une solution, je créé un message avec la taille du fichier a envoyer :

Code :
  1. long taille =listeVideos.get(y).getFichierVideo().length();

 
 
puis je l'envoie via un message socket et j'ajoute ceci :
 

Code :
  1. while(lu > -1){
  2. lu = inBuffer.read();
  3. outBuffer.write(lu);
  4. compteur++;
  6. if (compteur == taille){
  7.  lu = -1;
  8. }
  9. }


 
grâce à ça, je peux arrêter la lecture du buffer et fermer mes flux.
 
mais je suis toujours pas sorti d'affaire, parce que je dois envoyer plusieurs fichiers a la suite,  
 
j'avais donc fais une procédure de ce genre :
 
- le serveur compte le nombre de fichier a envoyer et l'envoie au client
- le serveur fait une boucle de 0 a nombre de fichiers
      - envoie le nom et la taille du fichier
      - envoie le fichier
 
le client :
- le client reçoit le nombre de fichier
- le client fait une boucle de 0 a nombre de fichiers
      - reçoit le nom et la taille du fichier    
      - reçoit le fichier
 
cette procedure me semble correcte, elle marche bien pour le premier fichier, mais ca plante des le 2eme... avec un message connection reset..
 
c'est pour ca que je ne fermait pas le flux outputstream coté serveur, car je veux envoyer plusieurs fichiers..
 
 
 
Voici le code de la procedure ci dessus :
 

Code :
  1. int nbVideos = listeVideos.size();  /* nombre de videos a envoyer */
  3. reponseRequete = Proprietes.ACK + Proprietes.SEPARATOR + nbVideos;
  5. int ret = envoiMessage(reponseRequete);  /* envoi le message contenant le nombre de video */
  7. if (ret == Proprietes.ACK){                     /* l'envoi s'est bien passé */
  9. for (int y=0 ; y<nbVideos ; y++){           /* on liste toutes les videos à rapatrier  */
  11.  String nomVideo = listeVideos.get(y).getFichierVideo().getName();  /* recuperation du nom de fichier    */
  12.  long taillefichier =listeVideos.get(y).getFichierVideo().length();
  13.  String chemin = listeVideos.get(y).getFichierVideo().getAbsolutePath();
  15.  reponseRequete = Proprietes.ACK +  Proprietes.SEPARATOR + nomVideo+ Proprietes.SEPARATOR + taillefichier; /* on envoie nom et taille de la video  */
  17.  retour = envoiMessage(reponseRequete);   /* on envoie le message de la video au client  */
  19.  if (retour == Proprietes.ACK){     /* le client a bien recu le nom et la taille */
  21.   try {
  22.    retour = sendFile(chemin);  /* la fonction d'envoi deja postée */
  23.   } catch (IOException e) {
  24.    e.printStackTrace();
  25.   }
  26.  }else{
  27.   return Proprietes.ERR_UNKNOWN;
  28.  }
  29. }
  30. }


 
 
coté client :
 

Code :
  1. requete = recevoirMessage();             /* on recoit le nombre de videos */
  3. String[] stringSplit = requete.split(SEPARATOR); /* on split le nom de la video courante       */
  4. String codeRetourStr = stringSplit[0];
  5. int codeRetour = Integer.valueOf(codeRetourStr);
  7. if (codeRetour ==ACK){        /* il n'y a pas eu d'erreur detectee       */
  9. String nbVideoStr = stringSplit[1];    /* on recupere le nombre de videos sous forme de chaine   */
  10. int nbVideo = Integer.valueOf(nbVideoStr);  /* on le converti en entier          */
  12. for(int y = 0 ; y<nbVideo ; y++){    /* on boucle pour recuperer toutes les videos     */
  14.  requete = recevoirMessage();    /* recuperation de la requete du client      */
  16.  stringSplit = requete.split(SEPARATOR);  /* on split la requete          */
  17.  codeRetourStr = stringSplit[0];
  18.  codeRetour = Integer.valueOf(codeRetourStr);
  20.  String nomVideo = stringSplit[1];   /* on recupere le nom de la video sous forme de chaine  */
  21.  int nbEtapes =  Integer.valueOf(stringSplit[2]);
  23.  try {
  24.   ret = recuperationVideos(nomVideo, nbEtapes);  /* on lance la recuperation de la video, fonction deja postée tout au dessus     */
  25.  } catch (Exception e) {
  26.   e.printStackTrace();
  27.  }
  28. }
  29. }


 
l'erreur que j'obtiens
coté serveur :
java.net.SocketException: Broken pipe
 
coté client :
java.net.SocketException: Socket closed
 
 
si je vire les appels de fonctions qui envoient/recoivent les fichiers, tous les echanges fonctionnent, je dois donc fermer qqch qui bloque la connexion, puisque la ligne qui pose probleme, c'est celle contenant le writeObject(message); ou le readObject();
 
 
voila, j'espere avoir été clair.
 
 
merci pour votre aide !


Message édité par dumoulex le 04-05-2011 à 13:49:22
n°2073773
dumoulex
Posté le 04-05-2011 à 14:14:50  profilanswer
 

C'EST BON !
 
je ne comprend pas vraiment pourquoi, (j'ai pas trouvé tout seul) mais si je ferme le  
BufferedInputStream inBuffer = new BufferedInputStream(socket.getInputStream());
 
et bien ca plante...


Aller à :
Ajouter une réponse
  FORUM HardWare.fr
  Programmation
  Java

  envoi de gros fichier par socket

 

Sujets relatifs
Validation formulaire d'upload de fichier sans changer de page[Objective-C] Création d'image reçue via socket
[Shell] lecture fichier configurationlecture d'un fichier .txt et retourner un tableau et une variable P,sv
Crée un bouton qui a un fichier exeFichier index.htm tout fou !
copier un fichiercopie de cellule d'un fichier excel sans l'ouvrir VBA
comment extraire plusieurs chaine de caracteres d'un fichier ??? 
Plus de sujets relatifs à : envoi de gros fichier par socket

Forum MesDiscussions.Net, Version 2010.2
(c) 2000-2011 Doctissimo
Page générée en 0.064 secondes

Copyright © 1997-2022 Hardware.fr SARL (Signaler un contenu illicite / Données personnelles) / Groupe LDLC / Shop HFR