Discussion :

[xokami35x]

Bonjour, je me suis recemment lancé dans un projet "'chat".
Je bien de commencer, mais deja un probleme apparait.
Voici les codes:

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
import java.net.*;
import java.io.*;
 
public class serveur {
 
    public static void main(String[] args) throws Exception {
        ServerSocket serveur = new ServerSocket(9334);
        String name;
        System.out.println("serveur initialisé");
        try {
            while(true) {
              Socket client = serveur.accept();
              BufferedReader reader = new BufferedReader(new InputStreamReader(client.getInputStream()));
              name = reader.readLine();
               threadServeur t = new threadServeur(client, name);
               t.start();
            }
        }catch(Exception e) { e.printStackTrace(); }
    }
 
}

thread 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
28
29
import java.net.*;
import java.io.*;
import java.util.*;
 
public class threadServeur extends Thread {
    Socket client;
    String name;
    Scanner sc = new Scanner(System.in);
 
    public threadServeur(Socket client, String name) {
        this.client = client;
        this.name = name;
    }
    public void run() {
        try {
            BufferedReader reader = new BufferedReader(new InputStreamReader(client.getInputStream()));
            BufferedWriter writer = new BufferedWriter(new OutputStreamWriter(client.getOutputStream()));
            while(client.isConnected()) {
        String message = reader.readLine();
        System.out.println("message de " + name);
        System.out.println(message);
        String messageEnvoi = sc.nextLine();
        writer.write(messageEnvoi);
        writer.flush();
            }
        }catch(Exception e) { e.printStackTrace(); }
    }
 
}

client:

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
import java.net.*;
import java.io.*;
import java.util.*;
 
public class client {
 
     public static void main(String[] args) throws Exception {
         System.out.println("client initialisé");
           int port = 9334;
           InetAddress ip = InetAddress.getLocalHost();
           Socket client = new Socket(ip, port);
           Scanner sc = new Scanner(System.in);
           String str;
           String message;
         try {
             BufferedReader reader = new BufferedReader(new InputStreamReader(client.getInputStream()));
             BufferedWriter writer = new BufferedWriter(new OutputStreamWriter(client.getOutputStream()));
             System.out.println("votre pseudo: ");
             str = sc.nextLine();
             writer.write(str);
             writer.flush();
             while(client.isConnected()) {
                 str = sc.nextLine();
                 writer.write(str);
                 writer.flush();
                message = reader.readLine();
             }
 
         }catch(Exception e) { e.printStackTrace(); }
 
     }
 
}

Comme vous pouvez le constater, je n'en sui qu'au debut, c'est normal qu'il n'y est presque rien.
Laintenant voici le probleme:
c'est dans l'envoie/recu des messages.
A chaque fois, avant de pouvoir envoyer un message, il faut attendre qu'il lise un message, vu que la methode read bloque le code.
J'aimerai donc savoir comment je peux faire pour que:
l'on puisse envoyer ders messages comme on veut tout en affichant tout ce qui est recu.

Merci d'avance pour vos reponses

[tchize_]

Ton bufferedReader bloque. Soit tu fais 2 thread: 1 de lecture, un d'écriture (coté serveur çà va vite être lourd), soit tu ne passe pas par un bufferedReader, et tu attaque ton inputStream directement, en utilisant la méthode available() qui permet de savoir si on va ou non bloquer.

[xokami35x]

ok merci beaucoup pour ta reponse, je vais essayer avec avaible();
De toute facon je ne vois pas trop comment on ferai avec 2 thread differents.

erdit: j'ai ete voir la doc sur available, le probleme c'est que si je fais un if avaible est different de nul je lit et que sinon j'ecris, la methode sc.nextLine(); bloque aussi le code.

[xokami35x]

J'ai essayé pas mal de truc et ca ne marche toujours pas, il y a toujours un truc qui bloque. Peut etre n'ai je pas compris ce que tu voulais dire par attaquer directement mon inputStream?
Serait ce vraiment genant si je faisait 2 thread?(c'est quand meme plus simple^^)

Merci

[dinobogan]

Je ne vois pas comment tu pourrais faire avec un seul Thread.
Dans le client, déclare un Thread qui va traiter ce qui est reçu par le serveur, et un second Thread qui gère l'entrée standard.

[tchize_]

J'ai essayé pas mal de truc et ca ne marche toujours pas, il y a toujours un truc qui bloque. Peut etre n'ai je pas compris ce que tu voulais dire par attaquer directement mon inputStream?

Ca veux dire ne pas passer par des reader ou autre qui entoureraient le stream et nécessite de bloquer en attendant un \n.

[xokami35x]

ok merci beaucoup de vos reponses.
dinobogan: que veux tu dire par qui gere les entrees standards?
sinon tchize, si j'ai bien compris, il faudrait que je supprime les buffer?
est ce que ca va changer quelque chose autre que je ne pourrai plus lire de ligne?

[dinobogan]

dinobogan: que veux tu dire par qui gere les entrees standards?

L'entrée standard, c'est "System.in".

[tchize_]

ok merci beaucoup de vos reponses.
dinobogan: que veux tu dire par qui gere les entrees standards?
sinon tchize, si j'ai bien compris, il faudrait que je supprime les buffer?
est ce que ca va changer quelque chose autre que je ne pourrai plus lire de ligne?

Tu dois supprimer les bufferedReader, car ils sont d'office bloquant (il attendent d'avoir un \n pour retourner) et, les StreamReader car eux non plus n'ont pas de méthode available() qui tu pourrais utiliser pour savoir si il existe quelque chose à lire.

[xokami35x]

ok merci beaucoup de votre precieuse aide.
En fait je lis caracteres par caracteres et a chaque fois je verifie si il y a quelque chose à lire?

Merci beaucoup

[tchize_]

non pas tout a fait
1) tu vérifie si il y a des trucs à lire
2) tu lit tout un bloc avec read(byte[]), çà lira le maximum que çà peut lire sans bloquer.
3) tu recommence en 1

Note, ce sont pas des caractères que tu lit mes des octets

[xokami35x]

ok merci beaucoup, je vais m'y remettre^^
Si j'ai besoin d'aide je redemande

Encore merci

[xokami35x]

j'ai commencé, je viens de finir juste le debut, c'est a dire les echanges entrre serveurs/clients. Mais malheuresement il y a un truc qui ne marche pas.
voici le code du thread serveur(je ne oste que celui ci vu que celui du client est presque identique):

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
44
45
46
47
48
49
50
51
52
53
54
55
56
57
 package projetChat;
 
import java.io.*;
import java.net.*;
import java.util.*;
 
public class threadServeur extends Thread {
 
	public static Socket client;
	public static String pseudo;
 
	public threadServeur(Socket client, String pseudo) {
		this.client = client;
		this.pseudo = pseudo;
	}
 
	public void run() {
		try{
			threadEcriture ecriture = new threadEcriture(client);
			ecriture.start();
		while(client.isConnected()) {
		if(client.getInputStream().available() != -1) {
		byte[] caracteres = new byte[64000];
		int caraLu = client.getInputStream().read(caracteres);
		String aEcrire = new String(caracteres, 0, caraLu);
		System.out.println(aEcrire);
		}
		else {	
		}
 
		}
 
	}catch(Exception e){ e.printStackTrace(); }
}
}
 
class threadEcriture extends Thread {
 
	public static Socket client;
 
	public threadEcriture(Socket client) {
		this.client = client;
	}
 
	public void run()  {
		Scanner sc = new Scanner(System.in);
		String str;
		try {
		BufferedWriter writer = new BufferedWriter(new OutputStreamWriter(client.getOutputStream()));
		while(client.isConnected()) {
			str = sc.nextLine();
			writer.write(str);
			writer.flush();
		}
		}catch(Exception e) { e.printStackTrace(); }
	}
}

[tchize_]

Juste un truc, quand tu travaille sur la socket (write ou read), met le dans un bloc synchronized, pour éviter que l'un lise pendant que l'autre écrit.
De plus ton if (client.getInputStream().available()) n'est plus nécessaire puisque tu a séparé l'écriture de la lecture. Ce n'est donc plus un problème d'avoir une lecture bloquante.