Java

[JAVA] Socket UDP et InputStream, probleme de read

Recherche :

Mot : Pseudo : Filtrer
Bas de page
Auteur	Sujet : [JAVA] Socket UDP et InputStream, probleme de read

HelloWorld

Salut tout le monde!

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

Code :

InputStream input = socket.getInputStream();
for ( int i = 0; i < data.length; ++i )
{
data[ i ] = input.read();
}

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

Code :

InputStream input = socket.getInputStream();
input.read( data );
// 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

Publicité

HelloWorld

Salut tout le monde!

:cry:

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

darklord

You're welcome

que vaut data?

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

artemice

( - ;

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

artemice

( - ;

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

HelloWorld

Salut tout le monde!

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 :

public class tcpConnexion
{
// serveur
tcpConnexion( int Port )
{
try
{
TcpSrvSocket = new ServerSocket( Port );
IsServer = true;
IsConnected = false;
}
catch ( BindException e )
{
System.err.println( "Erreur : le port " + Port + " est déjà utilisé." );
System.exit( -1 );
}
catch ( IOException e )
{
System.err.println( e );
System.exit( -1 );
}
}
// client
tcpConnexion( String Host, int Port )
{
try
{
IsServer = false;
TcpSocket = new Socket( Host, Port );
IsConnected = true;
TcpInput = new BufferedReader( new InputStreamReader( TcpSocket.getInputStream() ) );
TcpOutput = new PrintWriter( TcpSocket.getOutputStream(), true );
}
catch ( UnknownHostException e )
{
System.err.println( "Erreur : serveur " + Host + " introuvable." );
System.exit( -1 );
}
catch ( ConnectException e )
{
System.err.println( "Erreur : la connexion a échoué sur " + Host + ":" + Port );
System.exit( -1 );
}
catch ( IOException e )
{
System.err.println( e );
System.exit( -1 );
}
}
void Close()
{
try
{
// pour le serveur, le 1° appel met fin à l'accep précédent
if ( IsConnected )
{
TcpInput.close();
TcpOutput.close();
TcpSocket.close();
}
// le 2° appel consécutif met fin au serveur
else if ( IsServer )
{
TcpSrvSocket.close();
}
}
catch ( IOException e )
{
System.err.println( e );
}
}
// serveur : accepter une connexion
void Accept()
{
if ( IsServer && !IsConnected )
{
try
{
TcpSocket = TcpSrvSocket.accept();
TcpInput = new BufferedReader( new InputStreamReader( TcpSocket.getInputStream() ) );
TcpOutput = new PrintWriter( TcpSocket.getOutputStream(), true );
IsConnected = true;
}
catch ( IOException e )
{
System.err.println( e );
System.exit( -1 );
}
}
}
// envoyer un tableau de byte
boolean SendBytes( byte [] Data )
{
if ( IsConnected )
{
try
{
OutputStream output = TcpSocket.getOutputStream();
output.write( Data );
return true;
}
catch ( IOException e )
{
return false;
}
}
return false;
}
// recevoir un tableau de byte
boolean ReceiveBytes( byte [] Data )
{
if ( IsConnected )
{
try
{
InputStream input = TcpSocket.getInputStream();
//ne marche pas ... ???
//input.read( Data, 0, Data.length );
for ( int i = 0; i < Data.length; ++i )
{
Data[ i ] = (byte)input.read();
}
return true;
}
catch ( IOException e )
{
return false;
}
}
return false;
}
// données privées
private ServerSocket TcpSrvSocket = null; // socket serveur
private Socket TcpSocket = null; // socket client
private BufferedReader TcpInput = null;
private PrintWriter TcpOutput = null;
private boolean IsServer; // vrai si on est un serveur
private boolean IsConnected; // vrai si on est connecté
// (à un serveur ou un client)
}

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

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

FORUM HardWare.fr

Programmation

Java

[JAVA] Socket UDP et InputStream, probleme de read

Sujets relatifs
Java : Envoyer un mail protocole mapi	[PHP-MYSQL] J'ai un problème que je n'arrive pas à résoudre SVP
[JAVA] L'équivalent d'un #define en java ?	Gros problème de transfert de BDD MySQL !
[C/C++] Sockets en UDP, problème d'envoi à une IP	[PHP]Probleme d'execution de script avec Easy Php
probleme avec une boucle	[ Python ] problème libftp [ resolu ]
[C] Probleme d'édition de lien
Plus de sujets relatifs à : [JAVA] Socket UDP et InputStream, probleme de read

Page générée en 0.094 secondes