[java] serveur de messagerie instantanée

serveur de messagerie instantanée [java] - Java - Programmation

Marsh Posté le 03-03-2006 à 15:10:37    

Bonjour,
Je débute en java et en réseaux, et j'ai pour objectif de programmer un service de messagerie instantanée basique (un nombre indéterminé de clients envoient et reçoivent des messages en temps réel)
Pour l'instant les clients consistent en Telnet, qui se connecte à mon serveur et envoie les messages.
Le serveur les reçoit bien, mais j'ai un problème pour envoyer à tous les clients le message reçu :
 

Code :
  1. port java.net.*;
  2. import java.io.*;
  4. public class server
  5. {
  7. public static void main (String arg[])
  8.  {
  10.  ServerSocket ecoute=null;
  11.  try{
  12.  ecoute=new ServerSocket(69,100);
  13.  } catch (Exception e){
  14.  erreur("Erreur lors de la création de la socket d'écoute ("+e+" )",3);
  15.  }
  17.  System.out.println("Serveur lance sur le port 69" );
  19.  boolean serviceFini=false;
  20.  Socket service[]=new Socket[100];
  21.  boolean libre[]=new boolean[100];
  22.  for (int i=0;i<100;i++)
  23.   {
  24.   libre[i]=true;
  25.   }
  26. int i=0;
  28.  while (! serviceFini)
  29.   {
  32.   try{
  33.   while(libre[i]!=true)
  34.   {i++;}
  36.   service[i]=ecoute.accept();
  37.   libre[i]=false;
  39.   } catch (IOException e){
  40.   erreur("Erreur lors de l'acceptation d'une connexion ("+e+" )",4);
  41.   }
  44.   try{
  45.   System.out.println("## ["+identifie(service[i].getInetAddress())+","+service[i].getPort()+"] CONNECTE ("+i+" )" );
  46.   } catch (Exception e) {
  47.   erreur("identification liaison",1);
  48.   }
  50.   new traiteClientEcho(service,i,libre).start();
  51.   }
  52.  }
  54. }
  57. class traiteClientEcho extends Thread
  58. {
  59. private Socket[] service=new Socket[100];
  60. private BufferedReader in;
  61. private PrintWriter out;
  62. private int nb;
  63. private boolean libre[]=new boolean[100];
  65. public traiteClientEcho(Socket service[],int i,boolean libre[])
  66.  {
  67.  for(int j=0;j<100;j++)
  68.  {
  69.  this.service[j]=service[j];
  70.  this.libre[j]=libre[j];
  71.  }
  72.  nb=i;
  74.  }
  77. public void run()
  78.  {
  80.  try{
  81.  in=new BufferedReader(new InputStreamReader(service[nb].getInputStream()));
  82.  out=new PrintWriter(service[nb].getOutputStream(),true);
  83.  out.println("## READY : "+nb);
  84.  } catch (Exception e) {
  85.  erreur("Erreur de creation flux",1);
  86.  }
  89.  String demande;
  90.  String reponse;
  91.  try{
  92.  while ((demande=in.readLine())!=null)
  93.   {
  94.   reponse="["+identifie(service[nb].getInetAddress())+","+service[nb].getPort()+"] "+demande;
  96. //PARTIE QUI POSE PB : parcourir la liste des clients et envoyer le message
  98.   for(int j=0;j<3;j++)
  99.    {
  100.    if (libre[j]=false) {
  101.    out=new PrintWriter(service[j].getOutputStream(),true);
  102.    out.println(nb+"->"+j+" "+reponse);
  103.    }
  104.    }
  106.   out=new PrintWriter(service[nb].getOutputStream(),true);
  107.   System.out.println("-> ["+identifie(service[nb].getInetAddress())+","+service[nb].getPort()+"] : "+demande);
  109.   if(demande.trim().toLowerCase().equals("fin" )) {
  110.   System.out.println("## ["+identifie(service[nb].getInetAddress())+":"+service[nb].getPort()+"] DECONNECTE" );
  111.   out.println("## DECONNECTE de ["+identifie(service[nb].getInetAddress())+","+service[nb].getPort()+"]" );
  112.   libre[nb]=true;
  113.   break;}
  114.   }
  116.  } catch (IOException e){
  117.  erreur("Erreur lors des échanges client/serveur ("+e+" )",3);
  118.  }
  120.  }
  123. }


 
Voilà j'ai enlevé les classes identifie et erreur pour plus de lisibilité
Si vous aviez une piste pour me mettre sur la voie car là je ne comprend pas ce qui cloche : le dernier client connecté envoie bien les messages, et ceux ci apparaissent chez les autres clients, mais dès que les autres clients envoient qqchose, ils se figent (mais reçoivent tjrs les messages du dernier client connecté) et la console renvoie :

Exception in thread "Thread-0" java.lang.NullPointerException
        at traiteClientEcho.run(server.java:118)


 
Merci d'avance  :hello:

Reply

Marsh Posté le 03-03-2006 à 15:10:37   

Reply

Marsh Posté le 03-03-2006 à 16:11:35    

Citation :

Voilà j'ai enlevé les classes identifie et erreur pour plus de lisibilité


 
Humm j'imagine que ce sont des méthode et non des classes...
 
 

Citation :

Exception in thread "Thread-0" java.lang.NullPointerException
  at traiteClientEcho.run(server.java:118)


 
J'ai une idée folle : si tu allais voir la ligne 118 de ton fichier server.java (*) tu trouverais ton problème.
 
A priori tu lance une méthode sur un objet non initialisé (c'est ce que veut dire NullPointerException)
 
PS : (*) le nom des classes doit commencer par une majuscule


Message édité par Bidem le 03-03-2006 à 16:12:19
Reply

Marsh Posté le 04-03-2006 à 12:25:14    

En effet ce sont des méthodes :D
 
Je savais que l'erreur était a la ligne 118 mais je ne trouvais pas ce qui clochait. Mais j'ai fait un thread dédié à cette tache et ça marche :)
 
Pour les conventions sur les noms faut que je m'y mette j'y pense jamais.
 
Merci pour ta réponse :hello:

Reply

Marsh Posté le 04-03-2006 à 13:21:15    

c'est facile de faire ce que tu veux faire. Regarde les classes MulticastSocket
 
suffit de lui donné une adresse de classe D. Et tous les clients s'initialisant sur cette adresse recevront automatiquement les messages. C'est une histoire d'une dixaine de ligne grand maximum pour le serveur, et la même chose pour le client. C'est d'une simplicité.  
 
=> MulticastSocket / MulticastPacket sont les deux classes les plus importantes.  
Le choix de l'adresse de classe D, c'est toi qui la choisi, c'est comme tu veux, la seule contrainte, c'est qu'ils ont tous la même afin de recevoir tous les messages envoyés par les autres membres.  
Pour la réception des messages dans une application java, il faut avoir un thread de réception. Donc, pas besoin d'avoir un serveur pour le multicast. Tu initialise la connexion avec MulticastSocket, tu te join au groupe, et tu envoie / reçoit les messages envoyé et reçu sur cette adresse.  ;-) si tu d'autres questions concernant le multicast, n'hésite pas. ou contacte moi par email...

Reply

Marsh Posté le 02-07-2008 à 12:37:56    

bonjour
moi aussi je suis débutante en java et réseau, je passe un stage dont le sujet est de créer un service de messagerie instantanée en java (interface avec netbeans), le probleme c'est que je ne sais pas par où commencer, si vous voudriez bien me guider je vous serais reconnaissante. :jap:  
merci d'avance :hello:

Reply

Sujets relatifs:

Leave a Replay

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