Communication entre threads [Résolu & Code Source Final]

Communication entre threads [Résolu & Code Source Final] - Java - Programmation

Marsh Posté le 20-01-2005 à 18:22:51    

Bonjour, je suis en train de faire une sorte de logiciel de communication entre plusieurs pc. J'ai donc créé la classe Server qui ecoute sur un port et créer des threads dès qu'un client se connecte. Pour l'instant ca va, le serveur affiche les messages reçu dans la fenetre de log. Le problème, c'est comment faire pour l'envoyer à tous les autres clients? car je ne vois pas comment passer un élément du thread au programme serveur (celui qui a créer la thread)... Si quelqu'un a la solution ou une idée algo pour m'aider, ca serait sympa :)
 
merci , loiklo


Message édité par loiklo le 21-01-2005 à 08:26:12
Reply

Marsh Posté le 20-01-2005 à 18:22:51   

Reply

Marsh Posté le 20-01-2005 à 19:34:27    

J'ai eu le meme souci:
http://forum.hardware.fr/hardwaref [...] 3146-1.htm
 
Je parle pas java, mais l'idée doit être la même.


---------------
©2008 Bleuarff Corp.
Reply

Marsh Posté le 20-01-2005 à 19:44:17    

hum, nan, ca m'aide pas trop, en faite si on compare au processus UNIX, j'aimerais parler au père... Voiçi le code si ca peut vous aider à comprendre.
 
 
Voici le serveur:
 

Code :
  1. Voir plus bas dans le message, le code corigé


 
La connexion se passe par l'envoi d'instance de la classe String avec le message à l'interieur (je pense passer une classe perso plus tard avec un pseudo et le message, enfin bon...)
En faite, quand un thread recçois une instance de la classe String, il doit l'envoyer au père, et le père doit l'envoyer à tous ses threads. (Pour l'envoi, je sais comment faire, un vecteur de thread et hop c'est bon) mais pour passer cette String au père je vois pas du tout comment faire...


Message édité par loiklo le 21-01-2005 à 08:27:21
Reply

Marsh Posté le 20-01-2005 à 19:50:25    

il faut que tu enregistres tes ListenThread dans une collection au niveau du serveur et que tu passes une référence du serveur lors de la construction di listenthread.
=> quand depuis le ListenThread tu veux balacner un message au serveur, tu appelles une méthode sur le serveur qui feras une boucle sur tous les clients pour envoyer le message.
 
(attention à la synchronisation de la collection)


---------------
ma vie, mon oeuvre - HomePlayer
Reply

Marsh Posté le 20-01-2005 à 19:50:34    

Reply

Marsh Posté le 20-01-2005 à 19:59:38    

J'avais lu l'autre topic déjà. Il faut que je passe par référence, mais il me semblait qu'il n'y avait pas de pointeur en java?! Avec mes (faibles) connaissances, je comprends qu'il faudrait que je fasse par exemple:
 
new ListenThread(connection, this);
 
et que ListenThread attende un ServerSocket en paramètre a l'instanciation et ensuite je crée un méthode qui 'for each' ListenThread execute la methode d'envoi du message?
 
ai-je bien compris ?

Reply

Marsh Posté le 20-01-2005 à 20:09:09    

tout à fait.
 
et c'est pas qu'il n'y a pas de pointeur en java, c'est que tu ne les manipules pas directement. En fait, toutes les variables d'objetsont des pointeurs...


---------------
ma vie, mon oeuvre - HomePlayer
Reply

Marsh Posté le 20-01-2005 à 20:11:57    

hum oki! j'aurais appris quelquechose today :)
 
et bien je te remercie grandement car je ne voyais pas du tout comment faire :)

Reply

Marsh Posté le 21-01-2005 à 08:23:54    

Le problème étant résolu, voilà mon résultat, il y a plein de problème mais la connection/déconnection fonctionne correctement.
Le code de l'interface a été généré avec NetBeans donc pas forcement optimisé. Un autre problème est quand on ferme le serveur, il se cache uniquement et reste dans la liste des processus. Il faut aussi mettre les bon import car la j'ai mis * pour pas avoir à m'y soucier.
 
(Je ne demande pas de solution aux problème, c'est juste si ca peut servir de base à certain)
 
//--------------------------------------------
//ListenServer.java
//--------------------------------------------

Code :
  1. import java.net.ServerSocket;
  2. import java.net.Socket;
  3. import java.io.IOException;
  4. import java.util.Vector;
  6. class ListenServer{
  8.     ServerSocket listenSocket;
  9.     int port;
  10.     Socket connection;
  11.     Vector vecThread;
  13.     ListenServer(int p){
  14.         super();
  15.         port = p;
  16.         vecThread = new Vector();
  17.     }
  19.     public void run(){
  20.         try{
  21.             listenSocket = new ServerSocket(port);
  22.             while(true){
  23.                 Socket connection = listenSocket.accept();
  24.                 vecThread.add(new ListenThread(connection, this));
  25.             }
  26.         }catch(IOException e){
  27.             System.out.println("ListenSocket IOException: " );
  28.             e.printStackTrace();
  29.         }
  30.     }
  31.    
  32.     public boolean sendMessage(String message){
  33.         ListenThread tmp;
  34.         for (int i=0; i<vecThread.size(); i++){
  35.             tmp = (ListenThread)vecThread.elementAt(i);
  36.             tmp.send(message);
  37.         }
  38.         return true;
  39.     }
  40.    
  41.     public void clientExit(ListenThread client){
  42.         int find = vecThread.indexOf(client);
  43.         vecThread.removeElementAt(find);
  44.         client.destroy();
  45.     }
  47.     public static void main(String argv[]){
  48.         ListenServer server;
  49.         if(argv.length==1) server = new ListenServer(Integer.parseInt(argv[1]));
  50.         else server = new ListenServer(6667);
  51.         server.run();
  52.     }
  53. }


 
 
 
 
//--------------------------------------------
//ListenThread.java
//--------------------------------------------

Code :
  1. import java.net.Socket;
  2. import java.io.ObjectInputStream;
  3. import java.io.ObjectOutputStream;
  4. import java.io.EOFException;
  5. import java.io.IOException;
  7. class ListenThread extends Thread{
  9.     Socket connection;
  10.     ObjectInputStream in;
  11.     ObjectOutputStream out;
  12.     String message;
  13.     ListenServer server;
  15.     ListenThread(Socket socket, ListenServer serv){
  16.         super();
  17.         connection = socket;
  18.         server = serv;
  19.         System.out.println("Thread creee" );
  20.         this.start();
  21.     }
  22.    
  23.     public void send(String message){
  24.         try{
  25.             out.writeObject(message);
  26.         }catch(IOException e){
  27.             System.out.println(e);
  28.         }
  29.     }
  30.    
  31.     public void destroy(){
  32.         try{
  33.             out.close();
  34.             in.close();
  35.         }catch(IOException e){System.out.println(e);}
  36.         System.out.println("Thread detruite" );
  37.     }
  39.     public void run(){
  41.         try{
  42.             out = new ObjectOutputStream(connection.getOutputStream());
  43.             in = new ObjectInputStream(connection.getInputStream());
  44.             while(true){
  45.                 try{
  46.                     message = (String) in.readObject();
  47.                 }catch(java.lang.ClassNotFoundException e){
  48.                     System.out.println(e);
  49.                 }
  50.                 System.out.println("Thread: "+message);
  51.                 server.sendMessage(message);
  52.             }
  53.         }catch(EOFException e){
  54.             try{
  55.                 connection.close();
  56.                 System.out.println("ListenThread: EOFException, client deconecte" );
  57.                 return;
  58.             }catch(IOException ee){
  59.                 System.out.println("ListenThread: IOException, client deconecte" );
  60.                 ee.printStackTrace();
  61.                 return;
  62.             }
  63.         }catch(IOException e){
  64.             System.out.println("ListenThread: IOException" );
  65.             server.clientExit(this);
  66.             e.printStackTrace();
  67.             return;
  68.         }
  69.     }
  70. }


 
 
 
 
//--------------------------------------------
//Client.java
//--------------------------------------------

Code :
  1. import java.awt.event.ActionEvent;
  2. import java.net.Socket;
  3. import java.io.*;
  5. public class Client extends javax.swing.JFrame {
  6.     Socket sok;
  7.     String message;
  8.     ObjectOutputStream out;
  9.     ObjectInputStream in;
  10.    
  11.     public Client(Socket sokk) {
  12.         initComponents();
  13.         sok = sokk;
  14.         try{
  15.             System.out.println("1" );
  16.             out = new ObjectOutputStream(sok.getOutputStream());
  17.             System.out.println("1" );
  18.             in = new ObjectInputStream(sok.getInputStream());
  19.             System.out.println("1" );
  20.         }catch(Exception e){};
  21.         System.out.println("1" );
  22.         this.setVisible(true);
  23.         System.out.println("1" );
  24.         run();
  25.     }   
  26.    
  27.     public void run(){
  28.         while(true){
  29.             try{
  30.                 message = (String) in.readObject();
  31.             }catch(IOException e){
  32.                 System.out.println(e);
  33.             }catch(ClassNotFoundException e){
  34.                 System.out.println(e);
  35.             }
  36.             affMess.setText(affMess.getText()+message);
  37.         }
  38.        
  39.     }
  40.    
  41.     /** This method is called from within the constructor to
  42.      * initialize the form.
  43.      * WARNING: Do NOT modify this code. The content of this method is
  44.      * always regenerated by the Form Editor.
  45.      */
  46.     private void initComponents() {                         
  47.         jScrollPane1 = new javax.swing.JScrollPane();
  48.         affMess = new javax.swing.JTextPane();
  49.         tfMess = new javax.swing.JTextField();
  50.         tfPseudo = new javax.swing.JTextField();
  52.         setDefaultCloseOperation(javax.swing.WindowConstants.EXIT_ON_CLOSE);
  53.         jScrollPane1.setViewportView(affMess);
  55.         getContentPane().add(jScrollPane1, java.awt.BorderLayout.CENTER);
  57.         tfMess.setText("jTextField1" );
  58.         tfMess.addActionListener(new java.awt.event.ActionListener() {
  59.             public void actionPerformed(java.awt.event.ActionEvent evt) {
  60.                 tfMessActionPerformed(evt);
  61.             }
  62.         });
  64.         getContentPane().add(tfMess, java.awt.BorderLayout.SOUTH);
  66.         tfPseudo.setText("Pseudo" );
  67.         tfPseudo.addActionListener(new java.awt.event.ActionListener() {
  68.             public void actionPerformed(java.awt.event.ActionEvent evt) {
  69.                 tfPseudoActionPerformed(evt);
  70.             }
  71.         });
  73.         getContentPane().add(tfPseudo, java.awt.BorderLayout.NORTH);
  75.         pack();
  76.     }                       
  78.     private void tfPseudoActionPerformed(java.awt.event.ActionEvent evt) {                                       
  79.         // TODO add your handling code here:
  80.     }                                       
  82.     private void tfMessActionPerformed(java.awt.event.ActionEvent evt) {                                     
  83.         str = tfMess.getText();
  84.         try{
  85.             out.writeObject(str);
  86.         }catch(IOException e){}
  87.         tfMess.setText("" );
  88.     }                                     
  89.    
  90.     public static void main(String args[]) {
  91.         Socket sokkk;
  92.        
  93.         try{
  94.             sokkk = new Socket("192.168.0.26",6667);
  95.             new Client(sokkk);
  96.         }catch(Exception e){
  97.             System.out.println(e);
  98.         }
  99.        
  100.     }
  101.    
  102.     private String str;
  103.     // Variables declaration - do not modify                     
  104.     private javax.swing.JTextPane affMess;
  105.     private javax.swing.JScrollPane jScrollPane1;
  106.     private javax.swing.JTextField tfMess;
  107.     private javax.swing.JTextField tfPseudo;
  108.     // End of variables declaration                   
  109.    
  110. }


Reply

Marsh Posté le 21-01-2005 à 08:40:17    

benou a écrit :

tout à fait.
 
et c'est pas qu'il n'y a pas de pointeur en java, c'est que tu ne les manipules pas directement. En fait, toutes les variables d'objetsont des pointeurs...


des references plutot ...

Reply

Marsh Posté le 21-01-2005 à 08:40:17   

Reply

Marsh Posté le 21-01-2005 à 11:25:35    

et c'est quoi une référence si ce n'est l'adresse mémoire où les données de l'objet sont stockées [:petrus75]


---------------
ma vie, mon oeuvre - HomePlayer
Reply

Marsh Posté le 21-01-2005 à 11:51:31    

benou a écrit :

et c'est quoi une référence si ce n'est l'adresse mémoire où les données de l'objet sont stockées [:petrus75]


une chose est sure, c'est pas un pointeur [:petrus75]

Reply

Marsh Posté le 21-01-2005 à 12:04:24    

[:popcorn]


---------------
Hey toi, tu veux acheter des minifigurines Lego, non ?
Reply

Sujets relatifs:

Leave a Replay

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