Java

Problème de réceptions Multicast

Recherche :

Mot : Pseudo : Filtrer
Bas de page
Auteur	Sujet : Problème de réceptions Multicast

kashimz

Bonjour,

Je suis en train de programmer un client de messagerie instantanée en java en utilisant une MulticastSocket, mais j'ai quelques soucis au niveau de la réception des paquets : je les reçois bien en local mais les autres clients sur le réseau ne reçoivent que ceux appelés par la fonction déconnexion,
et je ne comprends pas du tout pourquoi :??:

Code :

public class Reseau
{
private static MulticastSocket groupe_sock;
private static DatagramSocket udp_sock;
private static InetAddress groupe_ip;
private static String ip_local;
private static Vector liste_ip;
private static Vector liste_label;
private static Panel_connecte panel_co;
private static boolean marche;
public Reseau()
{
try
{
set_ip_local();
connexion();
// Envoi de l'ip local et du pseudo du client au groupe ( code 0 )
String msg = "0"+ip_local+"/"+Panel_accueil.get_pseudo()+"/";
envoyer_groupe(msg);
// Mise en écoute de la socket Multicast sur le réseau et instanciation du tableau des adresses ips du groupe
liste_ip = new Vector();
liste_label = new Vector();
Ecoute_groupe ecoute_groupe = new Ecoute_groupe();
ecoute_groupe.start();
// Mise en écoute de la socket UDP
Ecoute_udp ecoute_udp = new Ecoute_udp();
ecoute_udp.start();
// Changement de fenêtre
changement_fenetre();
}
catch (UnknownHostException e1)
{
e1.printStackTrace();
}
catch (IOException e2)
{
e2.printStackTrace();
}
}
private void connexion() throws IOException
{
marche = true;
// Création d'une socket multicast pour rejoindre le groupe multicast
groupe_ip = InetAddress.getByName("224.0.0.1" );
groupe_sock = new MulticastSocket(2111);
//Connexion au groupe multicast
groupe_sock.joinGroup(groupe_ip);
// Création d'une socket UDP
udp_sock = new DatagramSocket(2112);
}
// Fonction permettant d'envoyer un paquet au groupe Multicast
public static void envoyer_groupe(String data)
{
try
{
DatagramPacket envoi = new DatagramPacket(data.getBytes(), data.length(), groupe_ip, 2111);
groupe_sock.send(envoi);
}
catch (IOException e)
{
e.printStackTrace();
}
}
// Fonction permettant d'envoyer un paquet à un client ciblé
public static void envoyer_qqn(String ip_dest, String data)
{
try
{
DatagramPacket envoi = new DatagramPacket(data.getBytes(), data.length(), InetAddress.getByName(ip_dest), 2112 );
udp_sock.send(envoi);
}
catch (UnknownHostException e)
{
e.printStackTrace();
}
catch (IOException e)
{
e.printStackTrace();
}
}
public static void deconnexion()
{
if(groupe_sock!=null)
{
try
{
// On stoppe les threads d'écoute
marche = false;
// Envoi d'un paquet au groupe pour signaler sa déconnexion ( code 1 )
String msg = "1"+ip_local+"/";
envoyer_groupe(msg);
// Déconnexion du groupe
groupe_sock.leaveGroup(groupe_ip);
groupe_sock.close();
// Fermeture de la socket UDP
udp_sock.close();
}
catch (IOException e)
{
e.printStackTrace();
}
}
}
// Fonction renvoyant l'ip de sa propre machine
private void set_ip_local()
{
try
{
ip_local = InetAddress.getLocalHost().getHostAddress();
}
catch (UnknownHostException e)
{
e.printStackTrace();
}
}
public static boolean get_marche()
{
return marche;
}
public static DatagramSocket get_udp_sock()
{
return udp_sock;
}
public static MulticastSocket get_groupe_sock()
{
return groupe_sock;
}
public static String get_ip_local()
{
return ip_local;
}

Code :

public class Ecoute_groupe extends Thread
{
public void run()
{
byte[] buffer = new byte[501];
DatagramPacket rec = new DatagramPacket(buffer, buffer.length);
// Tant que le client ne souhaite pas se déconnecter, le thread boucle afin d'être prêt à recevoir un paquet
// venant du groupe
while(Reseau.get_marche())
{
try
{
Reseau.get_groupe_sock().receive(rec);
System.out.println(new String(rec.getData()));
Reseau.traitement(rec);
}
catch (IOException e)
{
e.printStackTrace();
}
}
}
}

Code :

public class Ecoute_udp extends Thread
{
public void run()
{
byte[] buffer = new byte[501];
DatagramPacket rec = new DatagramPacket(buffer, buffer.length);
// Tant que le client ne souhaite pas se déconnecter, le thread boucle afin d'être prêt à recevoir un paquet
// venant d'un client particulier
while(Reseau.get_marche())
{
try
{
Reseau.get_udp_sock().receive(rec);
System.out.println(new String(rec.getData()));
Reseau.traitement(rec);
}
catch (IOException e)
{
e.printStackTrace();
}
}
}
}

Message édité par kashimz le 07-02-2009 à 18:26:18

Publicité

FORUM HardWare.fr

Programmation

Java

Problème de réceptions Multicast

Sujets relatifs
Behavior problème gestion souris molette + deplacement	Problème pattern Decorateur FilterInputStream et classe de test.
probleme lors de l'envoie d'un email en php	Zip, probleme de path
problème balayage de cellule en vba	Vba else if probleme
[CSS] Probleme centrage texte	Probleme mémoire / Ogre3D
problème avec oracle	probleme mysql
Plus de sujets relatifs à : Problème de réceptions Multicast

Page générée en 0.082 secondes