Discussion :

[piscou51000]

Bonjour,

Après avoir effectuer des recherches sur notre ami Google toujours pas de réponse à mon problème.

Je réalise une application Lambda client-serveur et pour lancer une instance de Lambda, il me faut deux clients. Donc à un moment donné le client 1 doit être en phase d'attente jusqu'à ce qu'un deuxième client se connecte sur le serveur.

Voila mon code serveur:

Code :

Sélectionner tout - Visualiser dans une fenêtre à part

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
 
ServerSocket serveur;
InetAddress adresse_serveur;
int port_serveur;
 
serveur = new ServerSocket(8000);
adresse_serveur = InetAddress.getLocalHost();
port_serveur = serveur.getLocalPort();
 
System.out.println("Serveur Lambda démarré...");
System.out.println("L'adresse du serveur est: "+adresse_serveur.getHostAddress());
System.out.println("Le port du serveur est: "+port_serveur);
 
while (true)
{
	Socket clientSocket1, clientSocket2;
 
	clientSocket1 = serveur.accept();
	System.out.println("Connexion réussi pour 1er client");
 
	clientSocket2 = serveur.accept();
	System.out.println("Connexion réussi pour 2nd client");
 
	PartieLambda partie = new PartieLambda( clientSocket1, clientSocket2);
       System.out.println("nouvelle partie créée");
 
}

Au niveau du client, celui ci ouvre un formulaire de connexion et renseigner son nom, le serveur et le port de connexion.

Code :

Sélectionner tout - Visualiser dans une fenêtre à part

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
 
BufferedReader  fluxEntrant;
 
Socket socket = null;
int port_serveur = Integer.parseInt(port);
 
InetAddress adresse_serveur = InetAddress.getByName(serveur);
socket = new Socket( adresse_serveur, port_serveur); 
System.out.println("socket connecté : " + socket.getLocalPort());
 
f.setVisible(false); // On ferme la fênetre active (le formulaire)
attente = new FenetreAttente("Morpion"); // On ouvre une fênetre avec un sablier en gif + un texte "Attente du client n°2
 
 
fluxEntrant = new BufferedReader(new InputStreamReader( socket.getInputStream()));
System.out.print("attente signal début du serveur : ");
String signal = fluxEntrant.readLine();
System.out.println(signal);

Le soucis est que le readLine() (avant dernière ligne) est bloquant. Vous me direz c'est normal c'est un peu son rôle et d'ailleurs c'est ce que je souhaite car j'attends que le serveur me dises "Oui c'est bon, il y a deux clients". (cela se fait durant le:

Code :

Sélectionner tout - Visualiser dans une fenêtre à part

 PartieLambda partie = new PartieLambda( clientSocket1, clientSocket2);

Le problème c'est que la fenêtre client (avec le gif et le texte) est buggée, elle apparait transparente et n'affichant ni le gif ni le texte. Tout redevient normal lorsque le 2eme client est connecté et que l'on a passé le readLine()

Bilan: Comment faire pour que readLine ne soit pas bloquant au niveau de ma fênetre graphique ?

Merci de votre aide d'avance.

[tchize_]

Le problème c'est que la fenêtre client (avec le gif et le texte) est buggée, elle apparait transparente et n'affichant ni le gif ni le texte. Tout redevient normal lorsque le 2eme client est connecté et que l'on a passé le readLine()

Bilan: Comment faire pour que readLine ne soit pas bloquant au niveau de ma fênetre graphique ?

Merci de votre aide d'avance.

C'est probablement parce que tu fait ton readLine dans le Thread de l'EDT. Il ne faut pas faire d'opération longue ou bloquante dans l'EDT.


voilà une petite doc pour commencer http://gfx.developpez.com/tutoriel/j...ing-threading/

[piscou51000]

Merci de ta réponse,

Je vais étudier en profondeur le lien que tu m'as fourni et faire un mix avec celui-ci.

Je vous tiens au courant de mon avancement. Même si ça me parait compliquer tous ça comparé à mon niveau de débutant. Mais bon jamais rien n'est insurmontable.

Bonne soirée..

[piscou51000]

Je reviens vers vous plus amples informations.

Donc si je comprends bien le problème vient du fait que l'affichage de ma fenêtre et l'attente de la réponse serveur (readLine()) se passe dans le même Thread.

Toujours si je comprends bien: il faudrait donc que j'utilise la classe SwingWorker afin de pouvoir externaliser l'un des deux travaux. Vous me conseillerez d'externaliser l'affichage de ma fenêtre ou readLine().

Merci de vos réponse.

[tchize_]

avec le readline, tu bloque le thread d'affichage, donc il faut faire le readline ailleurs. On ne fait aucune mise à jour de l'interface graphique en dehors de l'EDT! donc ce n'est pas ta mise à jour de fenetre à retirer. la classe swingworker est bien expliquée ici:

http://rom.developpez.com/java-swingworker/

Principe de base du swingworker: faire du travail long dans un thread en background et, à la fin, réinvoker l'edt pour faire la mise à jour de l'affichage.

[piscou51000]

Donc voila, je vous montre ma solution. tchize_ si tu repasses par là pourrait tu me donner ton avis sur ma solution. Merci d'avance.

Alors, j'ai créer ma propre classe qui hérite de SwingWorker. Voici le code:

Code :

Sélectionner tout - Visualiser dans une fenêtre à part

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
 
// Je vous fait grâce des import 
 
class SwingWorkerEcouteur extends SwingWorker<Integer, String> {
 
	BufferedReader  fluxEntrant;
	Socket s;
	public SwingWorkerEcouteur(Socket s) {
		this.s = s;
    }
 
    @Override
    public Integer doInBackground() {
    	try {
			fluxEntrant = new BufferedReader(new InputStreamReader( this.s.getInputStream()));
		} catch (IOException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
 
    		System.out.print("attente signal début du serveur : ");
 
    		String signal = null;
			try {
				signal = fluxEntrant.readLine();
			} catch (IOException e) {
				// TODO Auto-generated catch block
				e.printStackTrace();
			}
    		System.out.println(signal);
    	return 0;
    }
 
    @Override
    protected void process(List<String> strings) {
       // Je n'ai rien à faire ici dans mon cas
    }
 
    @Override
    protected void done() {
       // Ce qu'il faut faire après le readLine()...
    }
}

J'appelle ce code grâce à:

Code :

Sélectionner tout - Visualiser dans une fenêtre à part

1
2
3
4
5
6
7
8
 
		SwingUtilities.invokeLater(new Runnable() {
            public void run() {
                /* Démarrage de l'interface graphique et du SwingWorker. */
                SwingWorkerEcouteur demo = new SwingWorkerEcouteur(socket);
                demo.execute();
            }
        });

Si ça peut aider un jour quelqu'un...

Merci en tout cas de tes réponses tchize_ qui m'ont vraiment très bien orienté.

Bonne journée..

[tchize_]

invokelater sert à demander swing de faire quelque chose plus tard. La, dans ton code, tu demande à swing de 'plus tard' exécuter un petit code dont le seul job sera de démarrer un nouveau thread pour le swingworker. Tu peux simplifier en lancant le swingworker immédiatement (la méthode execute a pour seul role de mettre en tache de fond le worker). En pratique, pour ton cas, comme ton thread n'update pas l'interface graphique tu n'aurais, théoriquement, pas besoin de swingworker, mais je le garderais quand même parce que rien ne dit que plus tard tu n'aura pas besoin de mettre à jour l'ui.

Donc pour résumer, tu garde ton worker mais tu remplace le deuxième code par, tout simplement:

Code :

Sélectionner tout - Visualiser dans une fenêtre à part

1
2
 
new SwingWorkerEcouteur(socket).execute();

[piscou51000]

Ok merci pour tes conseils.

Je met le post en Résolu.