Problème de réceptions Multicast

Problème de réceptions Multicast - Java - Programmation

Marsh Posté le 07-02-2009 à 18:24:07    

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 :
  1. public class Reseau
  2. {
  3. private static MulticastSocket groupe_sock;
  4. private static DatagramSocket udp_sock;
  5. private static InetAddress groupe_ip;
  6. private static String ip_local;
  7. private static Vector liste_ip;
  8. private static Vector liste_label;
  9. private static Panel_connecte panel_co;
  10. private static boolean marche;
  13. public Reseau()
  14. {
  15.  try
  16.  {
  17.   set_ip_local();
  19.   connexion();
  21. // Envoi de l'ip local et du pseudo du client au groupe ( code 0 )
  22.   String msg = "0"+ip_local+"/"+Panel_accueil.get_pseudo()+"/";
  23.   envoyer_groupe(msg);
  25. // Mise en écoute de la socket Multicast sur le réseau et instanciation du tableau des adresses ips du groupe
  26.   liste_ip = new Vector();
  27.   liste_label = new Vector();
  28.   Ecoute_groupe ecoute_groupe = new Ecoute_groupe();
  29.   ecoute_groupe.start();
  31. // Mise en écoute de la socket UDP
  32.   Ecoute_udp ecoute_udp = new Ecoute_udp();
  33.   ecoute_udp.start();
  35. // Changement de fenêtre
  36.   changement_fenetre();
  38.  }
  39.  catch (UnknownHostException e1)
  40.  {
  41.   e1.printStackTrace();
  42.  }
  43.  catch (IOException e2)
  44.  {
  45.   e2.printStackTrace();
  46.  }
  47. }
  49. private void connexion() throws IOException
  50. {
  51.   marche = true;
  53. // Création d'une socket multicast pour rejoindre le groupe multicast
  54.   groupe_ip = InetAddress.getByName("224.0.0.1" );
  55.   groupe_sock = new MulticastSocket(2111);
  57. //Connexion au groupe multicast
  58.   groupe_sock.joinGroup(groupe_ip);
  60. // Création d'une socket UDP
  61.   udp_sock = new DatagramSocket(2112);
  62. }
  64. // Fonction permettant d'envoyer un paquet au groupe Multicast
  65. public static void envoyer_groupe(String data)
  66. {
  67.  try
  68.  {
  69.   DatagramPacket envoi = new DatagramPacket(data.getBytes(), data.length(), groupe_ip, 2111);
  70.   groupe_sock.send(envoi);
  71.  }
  72.  catch (IOException e)
  73.  {
  74.   e.printStackTrace();
  75.  }
  76. }
  78. // Fonction permettant d'envoyer un paquet à un client ciblé  
  79. public static void envoyer_qqn(String ip_dest, String data)
  80. {
  81.  try
  82.  {
  83.   DatagramPacket envoi = new DatagramPacket(data.getBytes(), data.length(), InetAddress.getByName(ip_dest), 2112 );
  84.   udp_sock.send(envoi);
  85.  }
  86.  catch (UnknownHostException e)
  87.  {
  88.   e.printStackTrace();
  89.  }
  90.  catch (IOException e)
  91.  {
  92.   e.printStackTrace();
  93.  }
  94. }
  96. public static void deconnexion()
  97. {
  98.  if(groupe_sock!=null)
  99.  {
  100.   try
  101.   {
  102. // On stoppe les threads d'écoute
  103.    marche = false;
  105. // Envoi d'un paquet au groupe pour signaler sa déconnexion ( code 1 )
  106.    String msg = "1"+ip_local+"/";
  107.    envoyer_groupe(msg);
  109. // Déconnexion du groupe
  110.    groupe_sock.leaveGroup(groupe_ip);
  111.    groupe_sock.close();
  113. // Fermeture de la socket UDP
  114.    udp_sock.close();
  115.   }
  116.   catch (IOException e)
  117.   {
  118.    e.printStackTrace();
  119.   }
  120.  }
  121. }
  123. // Fonction renvoyant l'ip de sa propre machine
  124. private void set_ip_local()
  125. {
  126.  try
  127.  {
  128.   ip_local = InetAddress.getLocalHost().getHostAddress();
  129.  }
  130.  catch (UnknownHostException e)
  131.  {
  132.   e.printStackTrace();
  133.  }
  134. }
  136. public static boolean get_marche()
  137. {
  138.  return marche;
  139. }
  141. public static DatagramSocket get_udp_sock()
  142. {
  143.  return udp_sock;
  144. }
  146. public static MulticastSocket get_groupe_sock()
  147. {
  148.  return groupe_sock;
  149. }
  151. public static String get_ip_local()
  152. {
  153.  return ip_local;
  154. }


 

Code :
  1. public class Ecoute_groupe extends Thread
  2. {
  3. public void run()
  4. {
  5.  byte[] buffer = new byte[501];
  6.  DatagramPacket rec = new DatagramPacket(buffer, buffer.length);
  8. // Tant que le client ne souhaite pas se déconnecter, le thread boucle afin d'être prêt à recevoir un paquet  
  9. // venant du groupe
  10.  while(Reseau.get_marche())
  11.  {
  12.   try
  13.   {
  14.    Reseau.get_groupe_sock().receive(rec);
  15.                                 System.out.println(new String(rec.getData()));
  16.    Reseau.traitement(rec);
  17.   }
  18.   catch (IOException e)
  19.   {
  20.    e.printStackTrace();
  21.   }
  22.  }
  23. }
  24. }


 

Code :
  1. public class Ecoute_udp extends Thread
  2. {
  3. public void run()
  4. {
  5.  byte[] buffer = new byte[501];
  6.  DatagramPacket rec = new DatagramPacket(buffer, buffer.length);
  8. // Tant que le client ne souhaite pas se déconnecter, le thread boucle afin d'être prêt à recevoir un paquet  
  9. // venant d'un client particulier  
  10.  while(Reseau.get_marche())
  11.  {
  12.   try
  13.   {
  14.    Reseau.get_udp_sock().receive(rec);
  15.                                 System.out.println(new String(rec.getData()));
  16.    Reseau.traitement(rec);
  17.   }
  18.   catch (IOException e)
  19.   {
  20.    e.printStackTrace();
  21.   }
  22.  }
  23. }
  24. }


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

Marsh Posté le 07-02-2009 à 18:24:07   

Reply

Sujets relatifs:

Leave a Replay

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