Messagerie instantanée en socket java

Version imprimable

03/12/2008, 10h32
nzo70

Messagerie instantanée en socket java

Bonjour je realise une application de messagerie instantanée en java en utilisant les socket.

J'arrive a conecter mes clients au serveur et a envoyer des messages.

Le probleme est que je voudrais envoyer les messages entre client; C'est a dire qu'un client envoi son message au serveur et que celui ci ne le renvoi qu'au destinataire concerné.

est ce que cela est possible? si oui comment dois-je proceder?

merci
03/12/2008, 10h34
Escoba

Je pense que tu dois mettre en place un service utilisant JMS (Java Message Service).
03/12/2008, 10h39
fr1man

Il suffit dans ton message, de spécifier le client à qui tu veux envoyer ce message.
Sur le serveur, tu identifies ce client et tu n'envoies le message qu'à lui.
03/12/2008, 10h47
nzo70

Comment je fais pour specifier le client qui doit recevoir le message?

Et comment je peux l identifier sur le serveur?
03/12/2008, 11h00
fr1man

Ca dépend comment tu construis tes messages.
Si c'est une simple chaine de caractères, il va te falloir une sorte de protocole, avec par exemple en debut de chaine, l'identifiant de client.
Si tu passes directement des objets par sérialisation, tu peux ajouter un champ correspondant à un id.
Ton serveur devra posséder cet identifiant pour raccrocher le message au bon client.
C'est plus clair ?
03/12/2008, 11h09
nzo70

Je trasmet des simples chaine de caractere. Je vois ce que tu veux dire mais je n'ai pa la moindre idée de comment mettre un identifiant en debut de chaine De plus cet identifiant devrait etre mis automatiquement il ne faut pas que l utilisateur ait a le saisir. Pourrais tu me donner la demarche a suivre ou alors un exemple ? merci
03/12/2008, 11h13
dinobogan

Ou encore, si tu as du temps et envie de t'amuser, tu peux faire en sorte que le client se connecte directement au client avec lequel il veut discuter en privé.
Le client émetteur demandera donc les infos de connexion au serveur, puis il se connectera au client récepteur. Le client récepteur doit évidemment se transformer en serveur.
Il y a donc moyen de faire des trucs rigolos ;)
03/12/2008, 11h19
nzo70

Si je comprends bien il faut que j instancie un ServerSocket pour le client qui doit recevoir le message puis conecter le client qui envoie le message a ce ServerSocket?

Mais le probleme reste le meme, comment je fais pour savoir quel est le client qui recevra le message?
03/12/2008, 11h21
billynirvana

Ben tu peux faire comme dans war3.

Si l'utilisateur tape son message comme suit:

Code:

blablabla

il sera envoyé à tout le monde

Si l'utilisateur tape son message comme suit:

Code:

/w <destinataire> blablabla

il sera envoyé qu'au destinataire.

En faite mon probleme est surtout que je ne vois pas comment faire pour identifier le destinataire (autrement dit la socket concerné).

Comment je fais cela? y a t il une methode specifique?

voici mes classes

classe 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
34
35
36
37
38
 
 
public class client  {
 
	Socket soc;
 
	public void connexion() throws IOException{
 
		try{
 
		InetAddress ip = InetAddress.getByName("192.168.1.36");
		System.out.println("Adresse ip du serveur : " + ip);
		soc = new Socket (ip, Server.port);
 
			System.out.println("Socket : " + soc);
			BufferedReader entree = new BufferedReader(
                    new InputStreamReader(
                   	     soc.getInputStream()));
 
            PrintWriter sortie = new PrintWriter(
                  new BufferedWriter(
                     new OutputStreamWriter(
                  		 soc.getOutputStream())),true);
 
            String msg = entree.readLine();
			System.out.println(msg);
 
 
		}catch (Exception e) {
 
			e.printStackTrace();
			//System.out.println(e);
 
		}
	}
 
 
}

classe server :

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
 
 
public class Server {
 
	static final int port = 8080;
 
	public static void main (String [] args){
 
 
		int num = 1;
 
		try{
 
			ServerSocket srv = new ServerSocket(port);
			System.out.println("Démarré " + srv);
			while (true){
 
				Socket conect = srv.accept();
				System.out.println("Connexion accepté : " + conect);
				new ServerThread (conect, num++).start();
 
			}
 
		}catch (Exception e){
 
			System.out.println(e);
 
		}

classe ServerThread :

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
 
 
public class ServerThread extends Thread {
 
	private Socket conect;
	private int num;
 
	public ServerThread(Socket conect , int num){
 
		this.conect=conect;
		this.num=num;
 
	}
 
	public void run (){
 
		try{
 
			BufferedReader reception = new BufferedReader(
	                new InputStreamReader(
	                 	 conect.getInputStream())
	                           );
 
	        PrintWriter envoi = new PrintWriter(
	                new BufferedWriter(
	     		        new OutputStreamWriter(
	                     	conect.getOutputStream())), true);
 
	        envoi.println("bonjour, saisir stop pour arreter");
			String msg = reception.readLine();
			while(!(msg.equals("stop"))){
 
 
				envoi.println(msg);
 
			}
			conect.close();
 
		}catch (Exception e){
 
			System.out.println(e);
 
		}
 
 
	}
 
}

Je pensait qu'avec le numero du ServerThread je pouvait le faire mais je n y arrive pas.

03/12/2008, 13h04
dingoth

Ne touche surtout pas aux numéros de Threads. Non pas que ce soit dangereux, mais simplement que la solution n'est pas du tout là.

En fait, tu dois construire un protocole de discussion. Envoyer un message à un serveur ne suffit pas : il faut également envoyer des données pour traiter le message.

Par exemple, si je prends le protocole ouvert IRC, on peut voir qu'il est géré par connexions :

Quand je parle de client ici, je parle d'application cliente, pas d'utilisateur final.

Client A se connecte à Serveur Z
Client A dit à Serveur Z : Je suis A
Serveur Z dit à Client A : Ok, ton nom n'est pas pris, je te connais en tant que A.
Serveur Z dit à tout le monde : A vient d'arriver.
Serveur Z dit à Client A : voici la liste de tous ceux qui sont connectés : C, D.
Client B se connecte à Serveur Z
Client B dit à Serveur Z : Je suis B
Serveur Z dit à Client B : Ok, ton nom n'est pas pris, je te connais en tant que B.
Serveur Z dit à tout le monde : B vient d'arriver.
Serveur Z dit à Client B : voici la liste de tous ceux qui sont connectés : A, C, D.
Client B dit à Serveur Z : Envoie le message "Salut à tous !" à tout le monde
Serveur Z dit à Clients A, C, D : B envoie le message "Salut, ça va ?".
Client A dit à Serveur Z : Envoie le message "Salut, ça va ?" à B.
Serveur Z dit à Client B : A envoie le message "Salut, ça va ?".
Client B dit à Serveur Z : Envoie le message "Oui, et toi ?" à A
Serveur Z dit à Client A : B envoie le message "Oui, et toi ?".

Pour mettre en place cette communication, tu vas devoir définir un format de messages qui serviront à faire passer toutes ces commandes. C'est un peu difficile pour comprendre au début, mais ça ira vite, tu verras !
03/12/2008, 13h52
nzo70

Cela me semble une bonne idée, par contre pour le mettre en place sa me semble tres difficile.

Je vais googelisé un peu sa et essayer de le mettre en place

Merci.
03/12/2008, 14h20
nzo70
Je pense etre sur la bonne voie mais pour eviter de m egarer je prefere poser la question.

Par exemple pour que "Client A dit à Serveur Z : Je suis A" je peux dans la classe client modifié la variable "msg" comme suit :
Code:

1 2 3 4 5 InetAddress clt = InetAddress.getLocalHost(); String msg = "envoi de " + clt; msg =msg + " " + entree.readLine();
Est ce que c'est cela qu'il faut faire?
03/12/2008, 15h56
dinobogan

Le mieux est de demander à l'utilisateur un nickname. C'est ensuite cette chaine que tu vas transmettre au serveur, plutôt que son IP.
Côté serveur, il te faut une Map qui relie un nickname et le Thread qui s'occupe du client.
03/12/2008, 16h11
Astartee
Citation:
Envoyé par nzo70

Par exemple pour que "Client A dit à Serveur Z : Je suis A" je peux dans la classe client modifié la variable "msg" comme suit :

Code:

1 2 3 InetAddress clt = InetAddress.getLocalHost(); String msg = "envoi de " + clt; msg =msg + " " + entree.readLine();

Est ce que c'est cela qu'il faut faire?
Oui, c'est à peu près ça... c'est d'ailleurs ce que te proposais fr1man :

Citation:

Envoyé par fr1man

Si c'est une simple chaine de caractères, il va te falloir une sorte de protocole, avec par exemple en debut de chaine, l'identifiant de client.

En gros :
Tu ne peux pas te contenter d'envoyer le message "Salut !" à ton serveur, sinon celui-ci n'aura aucun moyen de savoir à qui ce message est destiné. Il faut ajouter au message des métadonnées, c'est-à-dire des informations supplémentaires qui expliquent ce que contient le message (provenance, destination, type, ...)
De plus il n'y a pas que les messages de discussion qui doivent circuler, il y a aussi des messages de connexion, déconnexion, changement de pseudo, etc. Tout dépend des possibilités que tu veux offrir dans ton appli.
D'où la nécessité de définir un protocole, c'est-à-dire de définir le format des messages et l'ordre dans lequel ils doivent être échangés...

Tu peux par exemple décider que les messages de discussion auront la forme "msg;<provenance>;<destination>;<message>", les messages de changement de pseudo "chg;<pseudo>;<nouveaupseudo>"...
Si je m'appelle "bli" et que j'envoie "coucou" à "bla", puis que je décide de m'appeler "blu", puis que j'envoie "recoucou" à "bla", le serveur recevra les messages "msg;bli;bla;coucou" puis "chg;bli;blu" puis "msg;blu;bla;recoucou" et saura comment interpréter et traiter correctement chacun d'entre eux.

Si tu utilises des séparateurs (dans mon exemple, les points virgules) pour bien différencier les différents champs des messages, pense à encoder les textes ou à interdire certains caractères pour ne pas confondre les "vrais" séparateurs et les caractères tapés par un des utilisateurs...
03/12/2008, 16h21
nzo70

et je defini le protocole des message comment? si je le met que ton exemple je vais avoir une erreur de compilation non?
03/12/2008, 17h09
dinobogan

Citation:

Envoyé par nzo70

et je defini le protocole des message comment? si je le met que ton exemple je vais avoir une erreur de compilation non?

C'est toi qui définis ton propre protocole.
C'est à toi de coder, dans ton serveur, l'analyse des chaines que tu vas recevoir. Dans le serveur, il te faudra donc découper la chaine complète reçu, puis interpréter chaque morceau pour savoir quoi en faire.
Le client devra construire une chaine spécifique pour chaque action à effectuer. C'est à toi de coder la construction des chaines à envoyer.
Il te faut donc d'abord réfléchir avec un papier et un stylo aux différents types de messages que le client peut envoyer/recevoir et que le serveur peut envoyer/recevoir. C'est ça, un protocole de communication.

C'est plus clair ?
03/12/2008, 17h38
nzo70

oui c'est plus clair merci.
04/12/2008, 00h09
Grimly_old

8O

Je ferais mieux de finir mon API au plus vite, je bosse justement sur ce genre de bêtises réseaux qui font galérer pas mal de monde.

J'essaie de le faire avec les channels et selector en monothread, ça à l'avantage d'avoir un code réutilisable en grande partie quelque soit le protocole ou service.

C'est un travail d'assez longue haleine (surtout pour l'étudiant peu qualifié que je suis), surtout que les docs ne sont pas des plus simples à comprendre dans le paquet java.nio.
04/12/2008, 11h21
nouknouk

Salut,

au passage, deux messages que j'avais postés pour donner une idée d'architecture de petite lib réseau : ici.
Ca pourra peut-être te donner quelques idées.
04/12/2008, 17h47
nzo70

Bonjour j'ai encore un soucis. Comment je peux faire pour transmettre des données d un client (donc une socket) qui a son thread à l' application "generale"?
05/12/2008, 10h31
dinobogan
Citation:

Envoyé par nzo70

Bonjour j'ai encore un soucis. Comment je peux faire pour transmettre des données d un client (donc une socket) qui a son thread à l' application "generale"?

Plusieurs techniques, selon ton choix. Voici deux exemples, mais il y en a des milliers d'autres :
1. Un Thread séparé : il faut transmettre à cet objet une instance sur laquelle il va appeler une méthode :
Code:

1 2 3 4 5 6 7 8 9 10 11 12 13 class MonThread extends Thread { public MonThread( Avertir objet ) { this.objet = objet; } public void run() { ... objet.avertir( unMessage ) ... } }
2. Si tu as implémenté Runnable sur une classe :
Code:

1 2 3 4 5 6 7 8 9 10 11 12 13 14 class Client implements Runnable { ... public void run() { ... avertir( unMessage ); ... } public void avertir( Type msg ) { ... } }
Pense à synchroniser comme il faut les sections critiques.
06/12/2008, 17h10
nzo70

Je me suis mal exprimé! En fait je lance 2 ou plusieurs applications pour faire tourner mon programme. je m explique :

J'ai une application qui permet de demarrer le serveur et une (ou plusieurs) autre qui permet de lancer le client.

Comment je peux faire pour que ces 2 applications s echangent des variable?
J'ai une Map statique du coté serveur qui associe un pseudo a un thread et je voudrais que quand je lance l application client pouvoir acceder a cette map

Quelqu'un a une idée?

Si vous voulez voir mes classes demandez les et je les mettrai sur le forum.
08/12/2008, 09h57
dinobogan

Citation:

Envoyé par nzo70

je voudrais que quand je lance l application client pouvoir acceder a cette map

Mais c'est une map "pseudo" -> Thread. Or le Thread est connu uniquement sur le serveur. Donc la map sera inutilisable par le client.