probleme avec chat

Version imprimable

probleme avec chat

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

serveur:

Code:

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:

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:

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

10/07/2008, 22h00
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.
11/07/2008, 10h20
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.
17/07/2008, 11h05
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
17/07/2008, 11h25
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.
17/07/2008, 13h13
tchize_

Citation:

Envoyé par 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?

Ca veux dire ne pas passer par des reader ou autre qui entoureraient le stream et nécessite de bloquer en attendant un \n.
17/07/2008, 13h51
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?
17/07/2008, 14h13
dinobogan

Citation:

Envoyé par xokami35x

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

L'entrée standard, c'est "System.in".
17/07/2008, 14h49
tchize_

Citation:

Envoyé par 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?

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.
17/07/2008, 18h26
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
17/07/2008, 20h32
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 :)
18/07/2008, 10h01
xokami35x

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

Encore merci

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:

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(); }
	}
}

21/07/2008, 15h35
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.