Java

Blocage des flux, réseau

Recherche :

Mot : Pseudo : Filtrer
Bas de page
Auteur	Sujet : Blocage des flux, réseau

brasseldX

Bonjour à tous, je suis actuellement en stage dans une université étrangére. Dans le cadre de ce stage, je dois développer une application qui permet d'établir des statistiques sur le réseau interne, et d'autres....
Cependant, mon application est quasiment terminée mais je viens de m'apercevoir que lorsque un socket client envoie de trop gros paquets au serveur, il y une sorte de plantage.
Pour les flux, j'utilise InputStream et OutputStream.
J'ai déjà essayé de changer le buffer du socket en envoi et réception grâce aux méthodes socket.setSendBufferSize(int i)
socket.setReceiveBufferSize(int i)
Là, je ne sais plus vraiment quoi faire.
Merci d'avance pour votre précieuse aide

Publicité

nraynaud

lol

c'est quoi "une sorte de plantage" ?

t'as un message d'erreur à nous donner ?

---------------
trainoo.com, c'est fini

brasseldX

non, il ne me génére aucune exception, aucune erreur

brasseldX

en fait j'envoie des vecteur de byte, qui vont en général d'une taille 1 jusqu'à 2000000. Sur la machine locale ça marche bien mais que quand je fais de l'affichage sur la console. En fait, je fais des SoP de temps à autres et je m'aperçois qu(il n'y a plus de données qui est envoyée.

nraynaud

lol

c'est hard, là, je vois pas trop, il faudrait surveiller au niveau de l'OS.

---------------
trainoo.com, c'est fini

brasseldX

et le probléme ne vient pas de Java puisque j'ai exactement le même en C. Et je ne pense pas qu'il est nécessaire de surveiller au nivea de l'OS. Toute maniére, je n'ai pas le niveau pour faire ça (DUT info Lille). Et de plus mon tuteur ne m'aurai pas pompé ce sujet. Et ce ...., il n'a pas de solution non plus !!

nraynaud

lol

c'est sûr que si tu envoies un gros machin, forcément, c'est lent, mais il peut y avoir des stratégies pour masquer un peu la chose ou tu peux être victime d'un effet pervers (un truc à classer avec l'asphyxie de la bande montante sur les gros téléchargement en ADSL).

---------------
trainoo.com, c'est fini

brasseldX

Connaissez vous un autre moyen, plutot que le inputStream et le OutputStream, pour envoyer des paquets d'une certaine taille. Mais il faut que les flux n'influent pas sur le calcul de la bande passante car au début j'envoyais et recevais des chaînes de caractéres mais c'est beaucoup trop long. Surtout lors de comparaisons avec un programme en C.

brasseldX

oui je sais que ça doit être lent, c'est logique. Mais là, il n'y a plus rien qui est envoyé ni reçu. Alors ce n'est pas le probléme.

brasseldX

Ah oui, j'ai aussi essayé l'expérience entre deux PC via un cable croisé et j'ai toujours le même probléme. Pourtant sur une machine locale (serveur + client), il n'y a pas de problémes (enfin, de temps à autres, car ça lui arrive aussi de bloquer). Le pire, c'est que quand je fais de l'affichage sur la console de ce que je reçois et j'envoi, et bien ça marche nickel !! Mais bon forcément, ça fausse complétement mes données.

Publicité

nraynaud

lol

on peut voir le code d'envoi et de réception ? j'ai comme un doute d'un coup ...

---------------
trainoo.com, c'est fini

brasseldX

bon attend parceque c'est assez long quand même, et surtout, il n'est vraiment pas optimisé, je sais qu'il y a pas mal de modif a faire dessus !! Surtout pour l'allocation mémoire ;-)

brasseldX

Code :

while((size = comModel.getNextSize()) != -1)
{
// System.out.println("\nSize "+size);
vecChar = new byte[size];
int nbMessage = 0;
start = System.currentTimeMillis();
while((iteration = comModel.getNextIteration()) != 0)
{
// System.out.println("\nIteration "+iteration);
nbMessage++;
long send = System.currentTimeMillis()-chrno;
if(logFile != null)
{
logFile.write("" );
logFile.write("Message sent at "+send);
}
// System.out.println("\nle client va envoyer "+vecChar.length);
out.write(vecChar);
// System.out.println("\nle client envoie "+size);
int nLeft = size ;
while(nLeft > 0)
{
// System.out.println("\tle client qttend " );
int nRead = in.read(vecChar);
// System.out.println("\tle client recoi "+nRead);
nLeft -= nRead;
}
// System.out.println(" le client a reçu "+size);
if(logFile != null)
{
send = System.currentTimeMillis()-chrno;
logFile.write("\tMessage received at " + send);
}
out.flush();
}
comModel.resetIteration();
long end = System.currentTimeMillis();
resultCli.addValues((double)size, ((double)(end-start))/(2.0 * nbMessage));
}

brasseldX

le précédent c'était pour le client, voici le serveur

Code :

byte []data = new byte [sock.getReceiveBufferSize()];
sock.setSendBufferSize(5000000);
// System.out.println(sock.getSendBufferSize() + "Send buffer clien" );
sock.setReceiveBufferSize(5000000);
// System.out.println(sock.getReceiveBufferSize() + "Receive buffer clien" );
while(true)
{
// while(in.available() <= 0);
// data = new byte [in.available()];
// System.out.println("serveur recoi " );
int nRead = in.read(data);
if(nRead==-1)
break;
// System.out.println("a recu "+nRead);
long send = System.currentTimeMillis() - chrno;
if(logFile != null)
{
logFile.write("" );
logFile.write("Message received at "+send);
}
// System.out.println("serveur envoie-> "+data.length);
out.write(data);
if(logFile != null)
{
send = System.currentTimeMillis() - chrno;
logFile.write("\tMessage resent at " + send);
}
out.flush();
}

Voilà mis a part pas mal de chose à changer au niveau de l'implé, je ne vois pas ou et le probléme !! Surtout qu'à certain moment, tout fonctionne correctement.

nraynaud

lol

dans le premier, il est affecté où size ?
dans le second, c'est quoi sock.getReceiveBufferSize() ?

---------------
trainoo.com, c'est fini

brasseldX

size est affecté dans le while((size = comModel.getNextSize()), mais il n'y a aucune rreur la dedans, taille varie de 1 à x avec une progression géométrique de 2. sock.getReceiveBufferSize() retourne 8192, taille du buffer en réception par défaut.

nraynaud

lol

ben là je vois pas, mais le code est pas hyper-clair, il peut y avoir un truc pas très visible.

---------------
trainoo.com, c'est fini

brasseldX

bon je le remets simplifier ;-)

brasseldX

personne n'aurai un tit exemple d'utilisation de InputStream et OutputStream qui est Propre ??

brasseldX

Code :

//Dans ce code client, il n'y a que ce qui nous interesse
vecChar = new byte[comModel.getMaxSize()];
while((size = comModel.getNextSize()) != -1)
{
while((iteration = comModel.getNextIteration()) != 0)
{
out.write(vecChar, 0, size);
int nRead = in.read(vecChar);
if(nRead==-1)
break;
out.flush();
}
}

brasseldX

Pour ceux que ça intéresse voici deux petit programmes bidon qui aboutissent bien sur mon probléme.

Code :

import java.io.*;
import java.net.*;
public class Client extends Thread
{
public void run()
{
try
{
//Changer la taille sizeMax si vous le souhaitez
int sizeMax = 1000000;
//Changer le nombre d'iteration également ;-)
int Iteration = 100;
int nbIteration = Iteration;
int portServ = 9876;
int size = 1;
Socket maSocket;
InetAddress adrServ = InetAddress.getLocalHost();
maSocket= new Socket(adrServ, portServ);
//Ici faites varier la variable plus
int plus = 1;
maSocket.setReceiveBufferSize(sizeMax * (Iteration+plus));
maSocket.setSendBufferSize(sizeMax * (Iteration+plus));
System.out.println("receive buffer --> "+maSocket.getReceiveBufferSize());
System.out.println("send buffer --> "+maSocket.getSendBufferSize());
InputStream in = maSocket.getInputStream();
OutputStream out = maSocket.getOutputStream();
while((size *= 2) < sizeMax)
{
byte []vecChar = new byte[size];
while(nbIteration-- != 0)
{
out.write(vecChar);
System.out.println("le client envoie "+vecChar.length);
System.out.println("\tle client attend " );
int nRead = in.read(vecChar);
System.out.println("\tle client recoi "+nRead);
if(nRead==-1)
break;
/* int nLeft = size ;
while(nLeft > 0)
{
System.out.println("\tle client attend " );
int nRead = in.read(vecChar);
System.out.println("\tle client recoi "+nRead);
nLeft -= nRead;
}*/
System.out.println((Iteration-nbIteration)+" le client a recu "+size);
out.flush();
}
nbIteration = Iteration;
}
System.out.println("les donnees ont bien ete envoyees" );
}
catch(UnknownHostException uhe)
{
System.out.println("machine inconnue "+uhe);
}
catch(IOException ioe)
{
System.out.println("erreur d'entree sortie "+ioe);
}
catch(NullPointerException npe)
{
System.out.println("Fin du service " );
}
}
public static void main(String [] args)
{
Serveur serveur = new Serveur();
serveur.connect();
serveur.start();
Client client = new Client();
client.start();
}
}
import java.io.*;
import java.net.*;
public class Serveur extends Thread
{
protected ServerSocket s;
public void connect()
{
int numPort=9876;
try
{
s = new ServerSocket(numPort);
System.out.println("serveur en ecoute sur le port "+numPort);
}
catch(IOException i)
{
System.err.println("probleme d'execution" + i);
}
}
public void run()
{
while(true)
try
{
executer(s.accept());
}
catch(IOException ioe)
{
System.out.println("ioe --> "+ioe);
}
}
static void executer(Socket sock) throws IOException
{
InputStream in = sock.getInputStream();
OutputStream out = sock.getOutputStream();
byte []data = new byte [sock.getReceiveBufferSize()];
while(true)
{
int nRead = in.read(data);
if(nRead==-1)
break;
out.write(data);
out.flush();
}
}
}

Voilà amusez vous bien avec ça, j'espére que vous pourrez trouver mon p'tit probléme, ça serait vraiment cool ;-)

brasseldX

uplaaaaaaaaaaaaaaa

Publicité

FORUM HardWare.fr

Programmation

Java

Blocage des flux, réseau

Sujets relatifs
[bash/shell] Flux d'entrée	Arrêter le service réseau ?
Faire communiquer 2 SGBD +rendre la liaison robuste à la panne réseau	scanner le reseau en php
Commande pour voir si u PC du réseau est allumé	scanner un reseau en php c'est faisable
Monitorer un réseau local en java	envoit fichier reseau
Protocole réseau en C++	Python sous windows : meilleur moyen pour connecter un lecteur reseau?
Plus de sujets relatifs à : Blocage des flux, réseau

Page générée en 0.184 secondes