envoi de gros fichier par socket

Marsh Posté le 04-05-2011 à 10:47:18

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 :

File f = new File(pathname);
System.out.println("Envoi du fichier " + f.getName());
long taillefichier =f.length();
System.out.println("Taille : "+ taillefichier);
long nbpassagesuposé=taillefichier / 8192;
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[8192];
int compteur = 0;
long ouonestrendu=0;
//Tant qu'on est pas à la fin 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 8192 octets
if(compteur == 8192){
compteur=0;
ouonestrendu++;
//On remplit le tampon
for(int x=0;x<8192;x++)
tampon.write(aecrire[x]);
//Et on l'envoie
fluxsortie.write(tableaubytes.toByteArray());
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<compteur;x++)
tampon.write(aecrire[x]);
//Et on l'envoie
tampon.flush();
fluxsortie.write(tableaubytes.toByteArray());
fluxsortie.flush();
System.out.println("Avancement: "+(float) ouonestrendu/nbpassagesuposé * 100+"%" );
System.out.println("fini" );
in.close();
tampon.close();
System.out.println("Passages effectués : "+ouonestrendu);

voici le client qui recoit :

Code :

Byte[] taillefichier;
int lu;
long taille = 0;
//Création de l'entrée
InputStream inpute = socket.getInputStream();
OutputStream out = new FileOutputStream("/home/ginko/" + nomVideo);
//Reçoit du client
BufferedInputStream inBuffer = new BufferedInputStream(inpute);
//Envoi vers le fichier
BufferedOutputStream outBuffer = new BufferedOutputStream(out);
lu = 0;
int compteur = 0;
while(lu > -1){
lu = inBuffer.read();
outBuffer.write(lu);
compteur++;
}
outBuffer.flush();
outBuffer.close();
inBuffer.close();
out.flush();
out.close();
inpute.close();
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

Reply

Marsh Posté le 04-05-2011 à 10:47:18

Reply

Marsh Posté le 04-05-2011 à 12:38:35

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

Reply

Marsh Posté le 04-05-2011 à 13:35:46

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 :

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

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

Code :

while(lu > -1){
lu = inBuffer.read();
outBuffer.write(lu);
compteur++;
if (compteur == taille){
lu = -1;
}
}

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 :

int nbVideos = listeVideos.size(); /* nombre de videos a envoyer */
reponseRequete = Proprietes.ACK + Proprietes.SEPARATOR + nbVideos;
int ret = envoiMessage(reponseRequete); /* envoi le message contenant le nombre de video */
if (ret == Proprietes.ACK){ /* l'envoi s'est bien passé */
for (int y=0 ; y<nbVideos ; y++){ /* on liste toutes les videos à rapatrier */
String nomVideo = listeVideos.get(y).getFichierVideo().getName(); /* recuperation du nom de fichier */
long taillefichier =listeVideos.get(y).getFichierVideo().length();
String chemin = listeVideos.get(y).getFichierVideo().getAbsolutePath();
reponseRequete = Proprietes.ACK + Proprietes.SEPARATOR + nomVideo+ Proprietes.SEPARATOR + taillefichier; /* on envoie nom et taille de la video */
retour = envoiMessage(reponseRequete); /* on envoie le message de la video au client */
if (retour == Proprietes.ACK){ /* le client a bien recu le nom et la taille */
try {
retour = sendFile(chemin); /* la fonction d'envoi deja postée */
} catch (IOException e) {
e.printStackTrace();
}
}else{
return Proprietes.ERR_UNKNOWN;
}
}
}

coté client :

Code :

requete = recevoirMessage(); /* on recoit le nombre de videos */
String[] stringSplit = requete.split(SEPARATOR); /* on split le nom de la video courante */
String codeRetourStr = stringSplit[0];
int codeRetour = Integer.valueOf(codeRetourStr);
if (codeRetour ==ACK){ /* il n'y a pas eu d'erreur detectee */
String nbVideoStr = stringSplit[1]; /* on recupere le nombre de videos sous forme de chaine */
int nbVideo = Integer.valueOf(nbVideoStr); /* on le converti en entier */
for(int y = 0 ; y<nbVideo ; y++){ /* on boucle pour recuperer toutes les videos */
requete = recevoirMessage(); /* recuperation de la requete du client */
stringSplit = requete.split(SEPARATOR); /* on split la requete */
codeRetourStr = stringSplit[0];
codeRetour = Integer.valueOf(codeRetourStr);
String nomVideo = stringSplit[1]; /* on recupere le nom de la video sous forme de chaine */
int nbEtapes = Integer.valueOf(stringSplit[2]);
try {
ret = recuperationVideos(nomVideo, nbEtapes); /* on lance la recuperation de la video, fonction deja postée tout au dessus */
} catch (Exception e) {
e.printStackTrace();
}
}
}

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

Reply

Marsh Posté le 04-05-2011 à 14:14:50

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...

Reply

envoi de gros fichier par socket

Sujets relatifs:

Leave a Replay