[JAVA] Socket UDP et InputStream, probleme de read

Socket UDP et InputStream, probleme de read [JAVA] - Java - Programmation

Marsh Posté le 02-05-2003 à 12:15:29    

Salut,
quelqu'un peut-il me dire pourquoi ce code marche :

Code :
  1. InputStream input = socket.getInputStream();
  2. for ( int i = 0; i < data.length; ++i )
  3. {
  4.     data[ i ] = input.read();
  5. }


et celui-ci non (le read reste bloqué) :

Code :
  1. InputStream input = socket.getInputStream();
  2. input.read( data );
  3. // ou bien input.read( data, 0, data.length );


C'est censé lire exactement la meme quantite de byte émis. Sauf que ca reste bloqué au read. Meme un flush ou un close apres l'émission  sur le OutputStream ne change rien.
Une idée ?


---------------
FAQ fclc++ - FAQ C++ - C++ FAQ Lite
Reply

Marsh Posté le 02-05-2003 à 12:15:29   

Reply

Marsh Posté le 02-05-2003 à 18:02:12    

:cry:


---------------
FAQ fclc++ - FAQ C++ - C++ FAQ Lite
Reply

Marsh Posté le 02-05-2003 à 20:08:48    

que vaut data?


---------------
Just because you feel good does not make you right
Reply

Marsh Posté le 05-05-2003 à 10:22:11    

tien ça ça marche au moin... et c propre!

Citation :

  /**
   * class recepteur réseau du chat udp
 * @author TROLAT_REYNIER_2a_isi_2j
 */
   
   import java.io.*;
   import java.net.*;
   import fr.iutvalence.isi2.chat.*;
 
 
    class ChatReceiver extends Thread  
   {
   
      public static String IP;
      public ChatGUI gui;
      public static String PORT;
      public  String pseudo;
   
   
   /*le constructeur*/
       public ChatReceiver(String pseu,ChatGUI g,String ip,String port)
       
      {
         super();
         IP=ip;
         PORT=port;
         gui=g;
         pseudo=pseu;
       
      }
   
   /*le corps du thread
   * suivant le principe décrit en cours
   */
       public void run()
      {
         InetAddress group=null;
       
         try
         {
            group=InetAddress.getByName(IP);
         }
             catch(UnknownHostException e)
            {
               System.out.println("pb host" );  ;
            }
       
         MulticastSocket ms=null;
       
         try
         {
            ms=new MulticastSocket(Integer.parseInt(PORT));
         }
             catch(IOException e)
            {
               System.out.println("pb io" );  
            }
       
       
         try
         {
            ms.joinGroup(group);
         }
             catch(IOException e)
            {
               ;
            }
             
         DatagramPacket p=new DatagramPacket(new byte[100],100);
         gui.display("************ bonjour vous étes sur LE chat **************\n" );
         while(true)
         {
         /*on reçoit le message*/
            try
            {
               ms.receive(p);
            }
                catch(IOException e)
               {
                  ;
               }
            String s="";
             
         /*on le récupère est on le format*/
            try
            {
               s=new String(p.getData(),"UTF-16" );
               s=s.substring(0,p.getLength()/2-1);
            }
                catch(UnsupportedEncodingException e)
               {
                  ;
               }
           
          /*on l'affiche*/
           
            gui.display("reçu : "+s+"\n" );
         
         
            try
            {
               Thread.sleep(2000) ;
            }
                catch(InterruptedException e)
               {
                  ;
               }
         }
      }
   }

Reply

Marsh Posté le 05-05-2003 à 10:23:29    

ici c du multicast mais c encore moin compliqué en unicast!

Reply

Marsh Posté le 18-05-2003 à 15:46:05    

Désolé pour le retard.
Il s'agissait d'un projet, qui est rendu maintenant. Mais j'aimerais bien comprendre.
Pour échanger des chaines de caracteres ca marche tres bien.
Mais pour envoyer un gros paquet de données (data est un byte [], qui vaut plusieurs centaines de Ko, voire plusieurs Mo) ca fouarre.
Voila une partie de la classe TCPConnexion, qui est utilisée par le serveur et le client pour les échanges.
Ca merdouille au niveau de ReceiveBytes( byte [] Data ) (a la fin)

Code :
  1. public class tcpConnexion
  2. {
  3.     // serveur
  4.     tcpConnexion( int Port )
  5.     {
  6.      try
  7.      {
  8.             TcpSrvSocket = new ServerSocket( Port );
  9.             IsServer = true;
  10.             IsConnected = false;
  11.         }
  12.         catch ( BindException e )
  13.         {
  14.          System.err.println( "Erreur : le port " + Port + " est déjà utilisé." );
  15.          System.exit( -1 );
  16.         }
  17.         catch ( IOException e )
  18.         {
  19.          System.err.println( e );
  20.          System.exit( -1 );
  21.     }
  22.     }
  24.     // client
  25.     tcpConnexion( String Host, int Port )
  26.     {
  27.      try
  28.         {
  29.          IsServer = false;
  30.          TcpSocket = new Socket( Host, Port );
  31.          IsConnected = true;
  32.       TcpInput = new BufferedReader( new InputStreamReader( TcpSocket.getInputStream() ) );
  33.       TcpOutput = new PrintWriter( TcpSocket.getOutputStream(), true );
  34.      }
  35.      catch ( UnknownHostException e )
  36.         {
  37.          System.err.println( "Erreur : serveur " + Host + " introuvable." );
  38.          System.exit( -1 );
  39.     }
  40.     catch ( ConnectException e )
  41.     {
  42.          System.err.println( "Erreur : la connexion a échoué sur " + Host + ":" + Port );
  43.          System.exit( -1 );
  44.     }
  45.         catch ( IOException e )
  46.         {
  47.          System.err.println( e );
  48.          System.exit( -1 );
  49.     }
  50.     }
  52.     void Close()
  53.     {
  54.      try
  55.      {
  56.       // pour le serveur, le 1° appel met fin à l'accep précédent
  57.             if ( IsConnected )
  58.             {
  59.              TcpInput.close();
  60.              TcpOutput.close();
  61.              TcpSocket.close();
  62.             }
  63.             // le 2° appel consécutif met fin au serveur
  64.             else if ( IsServer )
  65.             {
  66.              TcpSrvSocket.close();
  67.             }
  68.         }
  69.         catch ( IOException e )
  70.         {
  71.          System.err.println( e );
  72.     }
  73.     }
  75.     // serveur : accepter une connexion
  76.     void Accept()
  77.     {
  78.      if ( IsServer && !IsConnected )
  79.      {
  80.       try
  81.       {
  82.                 TcpSocket = TcpSrvSocket.accept();
  83.           TcpInput = new BufferedReader( new InputStreamReader( TcpSocket.getInputStream() ) );
  84.           TcpOutput = new PrintWriter( TcpSocket.getOutputStream(), true );
  85.           IsConnected = true;
  86.             }
  87.             catch ( IOException e )
  88.             {
  89.              System.err.println( e );
  90.              System.exit( -1 );
  91.          }
  92.      }
  93.     }
  95.     // envoyer un tableau de byte
  96.     boolean SendBytes( byte [] Data )
  97.     {
  98.         if ( IsConnected )
  99.         {
  100.             try
  101.             {
  102.                 OutputStream output = TcpSocket.getOutputStream();
  103.                 output.write( Data );
  105.                 return true;
  106.             }
  107.             catch ( IOException e )
  108.             {
  109.              return false;
  110.          }
  111.         }
  112.         return false;
  113.     }
  115.     // recevoir un tableau de byte
  116.     boolean ReceiveBytes( byte [] Data )
  117.     {
  118.         if ( IsConnected )
  119.         {
  120.          try
  121.          {
  122.              InputStream input = TcpSocket.getInputStream();
  124.                 //ne marche pas ... ???
  125.                 //input.read( Data, 0, Data.length );
  127.                 for ( int i = 0; i < Data.length; ++i )
  128.                 {
  129.                     Data[ i ] = (byte)input.read();
  130.                 }
  132.                 return true;
  133.             }
  134.             catch ( IOException e )
  135.             {
  136.              return false;
  137.          }
  138.         }
  139.         return false;
  140.     }
  141.     // données privées
  142.     private ServerSocket TcpSrvSocket = null;  // socket serveur
  143.     private Socket TcpSocket = null;           // socket client
  144.     private BufferedReader TcpInput = null;
  145.     private PrintWriter TcpOutput = null;
  146.     private boolean IsServer;                  // vrai si on est un serveur
  147.     private boolean IsConnected;               // vrai si on est connecté
  148.                                                // (à un serveur ou un client)
  149. }


Message édité par HelloWorld le 18-05-2003 à 15:48:00

---------------
FAQ fclc++ - FAQ C++ - C++ FAQ Lite
Reply

Sujets relatifs:

Leave a Replay

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