Blocage des flux, réseau

Blocage des flux, réseau - Java - Programmation

Marsh Posté le 08-06-2004 à 10:31:00    

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

Reply

Marsh Posté le 08-06-2004 à 10:31:00   

Reply

Marsh Posté le 08-06-2004 à 10:33:53    

c'est quoi "une sorte de plantage" ?
 
t'as un message d'erreur à nous donner ?


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

Marsh Posté le 08-06-2004 à 10:39:50    

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

Reply

Marsh Posté le 08-06-2004 à 10:41:41    

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.

Reply

Marsh Posté le 08-06-2004 à 10:43:23    

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


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

Marsh Posté le 08-06-2004 à 10:48:17    

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

Reply

Marsh Posté le 08-06-2004 à 10:58:11    

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
Reply

Marsh Posté le 08-06-2004 à 10:59:13    

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.

Reply

Marsh Posté le 08-06-2004 à 11:00:35    

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.

Reply

Marsh Posté le 08-06-2004 à 11:02:39    

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.

Reply

Marsh Posté le 08-06-2004 à 11:02:39   

Reply

Marsh Posté le 08-06-2004 à 11:04:30    

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


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

Marsh Posté le 08-06-2004 à 11:08:19    

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

Reply

Marsh Posté le 08-06-2004 à 11:10:24    

Code :
  1. while((size = comModel.getNextSize()) != -1)
  2.   {
  4.  //   System.out.println("\nSize "+size);
  6.    vecChar = new byte[size];
  7.    int nbMessage = 0;
  8.    start = System.currentTimeMillis();
  10.    while((iteration = comModel.getNextIteration()) != 0)
  12.    {
  14. //      System.out.println("\nIteration "+iteration);
  16.     nbMessage++;
  18.     long send = System.currentTimeMillis()-chrno;
  20.     if(logFile != null)
  21.     {
  22.      logFile.write("" );
  23.      logFile.write("Message sent at "+send);
  24.     }
  25. //    System.out.println("\nle client va envoyer "+vecChar.length);
  26.     out.write(vecChar);
  27. //    System.out.println("\nle client envoie "+size);
  29.     int nLeft = size ;
  30.     while(nLeft > 0)
  31.     {
  32. //  System.out.println("\tle client qttend " );
  33.      int nRead = in.read(vecChar);
  34. //     System.out.println("\tle client recoi "+nRead);
  35.      nLeft -= nRead;
  36.     }
  37. //    System.out.println(" le client a reçu "+size);
  39.     if(logFile != null)
  40.     {
  41.      send = System.currentTimeMillis()-chrno;
  42.      logFile.write("\tMessage received at " + send);
  43.     }
  44.     out.flush();
  45.    }
  46.    comModel.resetIteration();
  47.    long end = System.currentTimeMillis();
  48.    resultCli.addValues((double)size, ((double)(end-start))/(2.0 * nbMessage));
  49.   }

Reply

Marsh Posté le 08-06-2004 à 11:12:20    

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

Code :
  1. byte []data = new byte [sock.getReceiveBufferSize()];
  3.   sock.setSendBufferSize(5000000);
  4. //  System.out.println(sock.getSendBufferSize() + "Send buffer clien" );
  5.   sock.setReceiveBufferSize(5000000);
  6. //  System.out.println(sock.getReceiveBufferSize() + "Receive buffer clien" );
  8.   while(true)
  9.   {
  10. //       while(in.available() <= 0);
  11. //    data = new byte [in.available()];
  12. //   System.out.println("serveur recoi " );
  14.    int nRead = in.read(data);
  16.    if(nRead==-1)
  17.     break;
  19. //   System.out.println("a recu "+nRead);
  21.       long send = System.currentTimeMillis() - chrno;
  22.    if(logFile != null)
  23.    {
  24.     logFile.write("" );
  25.     logFile.write("Message received at "+send);
  26.    }
  27. //   System.out.println("serveur envoie-> "+data.length);
  28.    out.write(data);
  29.    if(logFile != null)
  30.    {
  31.     send = System.currentTimeMillis() - chrno;
  32.     logFile.write("\tMessage resent at " + send);
  33.    }
  34.    out.flush();
  35.   }


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.

Reply

Marsh Posté le 08-06-2004 à 11:20:25    

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


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

Marsh Posté le 08-06-2004 à 11:42:17    

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.

Reply

Marsh Posté le 08-06-2004 à 11:57:54    

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
Reply

Marsh Posté le 08-06-2004 à 12:02:21    

bon je le remets simplifier ;-)

Reply

Marsh Posté le 08-06-2004 à 12:07:51    

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

Reply

Marsh Posté le 08-06-2004 à 12:39:14    

Code :
  1. //Dans ce code client, il n'y a que ce qui nous interesse
  2. vecChar = new byte[comModel.getMaxSize()];
  3. while((size = comModel.getNextSize()) != -1)
  4. {
  5. while((iteration = comModel.getNextIteration()) != 0)
  6. {
  8.  out.write(vecChar, 0, size);
  10.  int nRead = in.read(vecChar);
  12.  if(nRead==-1)
  13.   break;
  15.  out.flush();
  16. }
  17. }

Reply

Marsh Posté le 08-06-2004 à 13:25:15    

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

Code :
  1. import java.io.*;
  2. import java.net.*;
  5. public class Client extends Thread
  6. {
  8. public void run()
  9. {
  10.  try
  11.  {
  12.   //Changer la taille sizeMax si vous le souhaitez
  13.   int sizeMax = 1000000;
  14.   //Changer le nombre d'iteration également ;-)
  15.   int Iteration = 100;
  17.   int nbIteration = Iteration;
  18.   int portServ = 9876;
  19.   int size = 1;
  20.   Socket maSocket;
  22.   InetAddress adrServ = InetAddress.getLocalHost();
  24.   maSocket= new Socket(adrServ, portServ);
  26.   //Ici faites varier la variable plus
  27.   int plus = 1;
  29.   maSocket.setReceiveBufferSize(sizeMax * (Iteration+plus));
  30.   maSocket.setSendBufferSize(sizeMax * (Iteration+plus));
  32.   System.out.println("receive buffer --> "+maSocket.getReceiveBufferSize());
  33.   System.out.println("send buffer --> "+maSocket.getSendBufferSize());
  35.   InputStream in = maSocket.getInputStream();
  36.   OutputStream out = maSocket.getOutputStream();
  38.   while((size *= 2) < sizeMax)
  39.   {
  40.    byte []vecChar = new byte[size];
  41.    while(nbIteration-- != 0)
  42.    {
  43.     out.write(vecChar);
  44.     System.out.println("le client envoie "+vecChar.length);
  46.     System.out.println("\tle client attend " );
  47.     int nRead = in.read(vecChar);
  48.     System.out.println("\tle client recoi "+nRead);
  50.     if(nRead==-1)
  51.      break;
  52.   /*  int nLeft = size ;
  53.     while(nLeft > 0)
  54.     {
  55.      System.out.println("\tle client attend " );
  56.      int nRead = in.read(vecChar);
  57.      System.out.println("\tle client recoi "+nRead);
  58.      nLeft -= nRead;
  59.     }*/
  60.     System.out.println((Iteration-nbIteration)+" le client a recu "+size);
  62.     out.flush();
  63.    }
  64.    nbIteration = Iteration;
  65.   }
  66.   System.out.println("les donnees ont bien ete envoyees" );
  67.  }
  68.  catch(UnknownHostException uhe)
  69.  {
  70.   System.out.println("machine inconnue "+uhe);
  71.     }
  72.  catch(IOException ioe)
  73.  {
  74.   System.out.println("erreur d'entree sortie "+ioe);
  75.     }
  76.  catch(NullPointerException npe)
  77.  {
  78.   System.out.println("Fin du service " );
  79.     }
  80. }
  82. public static void main(String [] args)
  83. {
  84.  Serveur serveur = new Serveur();
  85.  serveur.connect();
  86.  serveur.start();
  87.  Client client = new Client();
  88.  client.start();
  89. }
  90. }
  98. import java.io.*;
  99. import java.net.*;
  102. public class Serveur extends Thread
  103. {
  104. protected ServerSocket s;
  105. public void connect()
  106. {
  107.     int numPort=9876;
  108.     try
  109.     {
  110.      s = new ServerSocket(numPort);
  111.      System.out.println("serveur en ecoute sur le port "+numPort);
  112.  }
  113.  catch(IOException i)
  114.     {
  115.   System.err.println("probleme d'execution" + i);
  116.     }
  117. }
  119. public void run()
  120. {
  121.  while(true)
  122.   try
  123.   {
  124.       executer(s.accept());
  125.      }
  126.      catch(IOException ioe)
  127.      {
  128.       System.out.println("ioe --> "+ioe);
  129.      }
  130. }
  132. static void executer(Socket sock) throws IOException
  133.     {
  134.  InputStream in = sock.getInputStream();
  135.  OutputStream out = sock.getOutputStream();
  137.  byte []data = new byte [sock.getReceiveBufferSize()];
  139.  while(true)
  140.  {
  141.   int nRead = in.read(data);
  143.   if(nRead==-1)
  144.    break;
  146.   out.write(data);
  147.   out.flush();
  148.  }
  149. }
  150. }


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

Reply

Marsh Posté le 08-06-2004 à 16:50:43    

uplaaaaaaaaaaaaaaa

Reply

Marsh Posté le    

Reply

Sujets relatifs:

Leave a Replay

Make sure you enter the(*)required information where indicate.HTML code is not allowed