Forum |  HardWare.fr | News | Articles | PC | S'identifier | S'inscrire | Shop Recherche
1390 connectés 

  FORUM HardWare.fr
  Programmation
  Java

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

 
 


 Mot :   Pseudo :  
 
Bas de page
Auteur Sujet :

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

n°957718
loiklo
Posté le 20-01-2005 à 18:22:51  profilanswer
 

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
mood
Publicité
Posté le 20-01-2005 à 18:22:51  profilanswer
 

n°957747
Bleuarff
pouet
Posté le 20-01-2005 à 19:34:27  profilanswer
 

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.
n°957753
loiklo
Posté le 20-01-2005 à 19:44:17  profilanswer
 

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
n°957760
benou
Posté le 20-01-2005 à 19:50:25  profilanswer
 

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
n°957761
benou
Posté le 20-01-2005 à 19:50:34  profilanswer
 
n°957770
loiklo
Posté le 20-01-2005 à 19:59:38  profilanswer
 

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 ?

n°957778
benou
Posté le 20-01-2005 à 20:09:09  profilanswer
 

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
n°957780
loiklo
Posté le 20-01-2005 à 20:11:57  profilanswer
 

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

n°958214
loiklo
Posté le 21-01-2005 à 08:23:54  profilanswer
 

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. }


n°958218
beemer
Posté le 21-01-2005 à 08:40:17  profilanswer
 

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 ...

mood
Publicité
Posté le 21-01-2005 à 08:40:17  profilanswer
 

n°958298
benou
Posté le 21-01-2005 à 11:25:35  profilanswer
 

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
n°958316
beemer
Posté le 21-01-2005 à 11:51:31  profilanswer
 

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]

n°958338
the real m​oins moins
Posté le 21-01-2005 à 12:04:24  profilanswer
 

[:popcorn]


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

Aller à :
Ajouter une réponse
  FORUM HardWare.fr
  Programmation
  Java

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

 

Sujets relatifs
[RESOLU] Fatal error: main() [function.main] - class php5Comment faire communiquer des threads ?
[VBS][résolu] imbriquer des "do while ... loop"?supprimer un objet d'un array [resolu]
un visual basic .net en open source images de rangs.. [RESOLU]
Màj config client ($_SESSION) si màj de config serveur (BDD) [RESOLU](resolu)include(pseudo frame) merci quand meme
[résolu]pb de droit sur fichier upload via script [merci!][resolu] resize d"une image après un upload....
Plus de sujets relatifs à : Communication entre threads [Résolu & Code Source Final]

Forum MesDiscussions.Net, Version 2010.2
(c) 2000-2011 Doctissimo
Page générée en 0.110 secondes

Copyright © 1997-2022 Hardware.fr SARL (Signaler un contenu illicite / Données personnelles) / Groupe LDLC / Shop HFR