Client Serveur socket

Version imprimable

21/10/2010, 13h35
drake56

Client Serveur socket

Bonjour,
J'ai un problème pour réaliser une petite application client/serveur utilisant les sockets.
Pour l'instant mon client envoi un message au serveur mais le serveur ne peut pas lui répondre.
Comment pourrai-je faire une petite messagerie instantanée simple entre mon serveur et un seul client ?
Merci d'avance
21/10/2010, 13h55
tchize_

tu peux etre plus précis sur ton problème? qu'est-ce qui emêche ton serveur de répondre? Quel est ton code, quels sont tes messages d'erreur?
21/10/2010, 13h56
jabbounet

Une fois que ta connexion est établie avec une Socket par exemple tu as tout le nécéssaire pour envoyer/recevoir avec.

notamment avec les méthodes getInputStream et getOutputStream.

http://www.cui.unige.ch/java/JAVAF/SocketServer.html

En fait mon client peut envoyer un message au serveur et celui ci le reçoit bien. Mais le cas inverse ne fonctionne pas. Cependant ce code fonctionne mais que dans un sens, j'utilise 3 classes :
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
39
40
41
42
43
44
45
46
import java.io.*;
import java.net.*;
 
public class Client extends Thread
{
	Socket socket =null;
	int port=5000;
	String adresse=null;
	InetAddress ip=null;
 
	public Client(InetAddress a){ip=a;}
	public Client(String s){adresse=s;}
 
	public void run()
	{
		try
		{
			System.out.println("Client actif");
			Reader reader= new InputStreamReader(System.in);
			BufferedReader clavier=new BufferedReader(reader);
			if (ip!=null) socket = new Socket(ip, port);
			else socket = new Socket(adresse, port);
			System.out.println("SOCKET = " + socket);
			PrintWriter buffer_out = new PrintWriter(new BufferedWriter(new OutputStreamWriter(socket.getOutputStream())),true);
			String str =null;
			while (true )
			{
				str=clavier.readLine();
				buffer_out.println(str);
				if (str.equals("$")||str.equals("$$") ) break;
			}
			buffer_out.close();
			socket.close();
		}
		catch(IOException e)
		{
			System.out.println("Erreur client");
		}
	}
 
	public static void main(String[] args)
    {
		Client client=new Client("127.0.0.1");
		client.start();
    }
}

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
30
31
32
33
34
35
36
37
38
package mess;
 
import java.io.*;
import java.net.*;
 
public class Serveur extends Thread
{
	ServerSocket serveur=null;
    Socket socket=null;
    int port=5000;
    int numero=1;
 
    public void run()
    {
    	try
    	{
    		System.out.println("Serveur actif");
    		serveur = new ServerSocket(port);
    		while(true)
    		{
    			socket=serveur.accept();
    			System.out.println("Connection client "+ numero +" "+socket);
    			Service service=new Service(numero++,socket);
    			service.start();
    		}
    	}
    	catch(IOException e)
    	{
    		System.out.println("Erreur Serveur");
    	}
   }
 
   public static void main(String[] args)
    {
	   Serveur leServeur=new Serveur();
	   leServeur.start();
    }
}

Service :

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
package mess;
import java.io.*;
import java.net.*;
 
public class Service extends Thread
{
    private  Socket socket;
    private int numero;
 
    public Service(int numero,Socket socket)
    {
    	this.numero=numero;
    	this.socket=socket;
    }
 
    public void run()
    {
    	try
    	{
    		BufferedReader buffer_in = new BufferedReader(new InputStreamReader(socket.getInputStream()));
    		String str=null;
    		while (true)
    		{
    			str = buffer_in.readLine();
    			if (str.equals("$")) break;
    			System.out.println(numero+":"+str);
    		}
    		System.out.println("Deconnection client "+numero);
    		buffer_in.close();
    		socket.close();
    	}
    	catch(IOException e){}
    }
}

21/10/2010, 14h15
jabbounet

Est ce normal que ton serveur n'ait aucun writer?
21/10/2010, 14h19
drake56

C'est peut être pour ça qu'il ne peut pas répondre au client.
Il faudrait que je rajoute un writer ? Pour que le client reçoive le writer il faudrait que je fasse quoi ?
Merci

Un truc dans le style

coté service:
Code:

1 2 3 versClient = new PrintStream(socket.getOutputStream() versClient.println("Coucou !!");
ensuite coté client il faut aussi lire l'entrée de la socket pour recevoir les informations de ton serveur

En gros il faut que tu ait une symétrie entre le client et le serveur au niveaux des entrées sorties
Code:

1 2 3 4 5 6 7 Client Serveur +--------------+ +--------------+ | OutputStream |------> |InputStream | | InputStream |<------ |OutputStream | +--------------+ +--------------+

21/10/2010, 14h28
drake56

Merci je vais essayer de mettre en place ta solution.

Le versClient je l'ai placé à ce niveau dans ma classe Service :
Code:

1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 try { BufferedReader buffer_in = new BufferedReader(new InputStreamReader(socket.getInputStream())); String str=null; PrintStream versClient = new PrintStream(socket.getOutputStream()); versClient.println("Coucou"); while (true) { str = buffer_in.readLine(); if (str.equals("$")) break; System.out.println(numero+":"+str); } System.out.println("Deconnection client "+numero); buffer_in.close(); socket.close();
Mais quand je lance mon application le "Coucou" de test n'apparait pas.
Sinon il faut bien d'après ton schéma que je rajoute un OutputStream et InputStream dans ma classe Serveur puis un InputStream dans ma classe Client ?
Merci

Citation:

Sinon il faut bien d'après ton schéma que je rajoute un OutputStream et InputStream dans ma classe Serveur puis un InputStream dans ma classe Client ?

En gros oui.

Pour résumer:
Coté serveur tu dois avoir ce genre de chose:
Code:

1 2 3 4 5 6 7 socket = new ServerSocket(portNumber); ... client = socket.accept(); ... in = new BufferedReader(new InputStreamReader(client.getInputStream())); out = new PrintWriter(client.getOutputStream(), true);
Coté client cela peux ressembler à:
Code:

1 2 3 4 5 socket = new Socket(serverName, portNumber); out = new PrintWriter(socket.getOutputStream(), true); in = new BufferedReader(new inputStreamReader(socket.getInputStream())); ...
Dans les deux cas (client ou serveur), le programme lit dans "in" et tu envois dans "out".

Il faut aussi faire attention que le numéro de port soit le même sur le client et le serveur.
Que le nom du serveur lors de la création coté client correspond au nom de la machine sur laquelle tu lance le serveur.
....

Et quand c'est finis:
Code:

1 2 3 4 in.close(); out.close(); socket.close();
Tu trouvera un exemple ici:
http://www.oracle.com/technetwork/ja...et-140484.html
http://java.sun.com/developer/online...ketClient.java
http://java.sun.com/developer/online...ketServer.java

23/10/2010, 15h24
drake56

Merci pour ton aide et toutes tes explications, avec tout ça je devrais y arriver.
24/10/2010, 22h39
drake56

Ca fait 2h que je suis dessus et toujours au même stade hélas :( !
J'ai testé juste avec 2 classes Client et Serveur mais ça ne fonctionnait pas car en regardant tes dernières explications et les exemples j'ai supprimé la classe Service mais + rien ne marchait, pas de messages d'erreurs mais il ne se passait rien.
La classe Service est-elle donc toujours nécessaire en vue de tes dernières explications ou inutile ?
Merci pour ton aide en tout cas
25/10/2010, 00h43
jabbounet

Il faut aussi vérifier que le firewall autorise les communications entre ton client et ton serveur.

peux-tu montrer ton code (la dernière version?)

Citation:

La classe Service est-elle donc toujours nécessaire en vue de tes dernières explications ou inutile ?

Elle ne me semble pas obligatoire pour un simple client serveur pour se former à l'usage des socket.

Cela peux être abordé dans un second temps si tu souhaite avoir un serveur multi-threadé.

Salut,
je viens de faire quelques modifications du code que tu as donné au debut.
Avec ce code, quand je tappe hello coté client, le serveur me répond coucou.

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
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
 
 
import java.io.*;
import java.net.*;
 
public class Client extends Thread
{
    Socket socket =null;
    int port=5000;
    String adresse=null;
    InetAddress ip=null;
 
    public Client(InetAddress a){ip=a;}
    public Client(String s){adresse=s;}
 
    public void run()
    {
        try
            {
                System.out.println("Client actif");
                Reader reader= new InputStreamReader(System.in);
                BufferedReader clavier=new BufferedReader(reader);
                if (ip!=null) socket = new Socket(ip, port);
                else socket = new Socket(adresse, port);
                System.out.println("SOCKET = " + socket);
                PrintWriter buffer_out = new PrintWriter(new BufferedWriter(new OutputStreamWriter(socket.getOutputStream())),true);
                BufferedReader in = new BufferedReader(new InputStreamReader(socket.getInputStream()));
                String str =null;
                while (true )
                    {
                        str=clavier.readLine();
                        buffer_out.println(str);
                        if (str.equals("$")||str.equals("$$") ) break;
                        str=in.readLine();
                        if (str != null) {
                            System.out.println("lecture de " + str);
                        }
                    }
                in.close()
                buffer_out.close();
                socket.close();
            }
        catch(IOException e)
            {
                System.out.println("Erreur client");
            }
    }
 
    public static void main(String[] args)
    {
        Client client=new Client("127.0.0.1");
        client.start();
    }
}

Service

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
 
package mess;
import java.io.*;
import java.net.*;
 
public class Service extends Thread
{
    private  Socket socket;
    private int numero;
 
    public Service(int numero,Socket socket)
    {
    	this.numero=numero;
    	this.socket=socket;
    }
 
    public void run()
    {
    	try
            {
    		BufferedReader in = new BufferedReader(new InputStreamReader(socket.getInputStream()));
                PrintWriter out = new PrintWriter(socket.getOutputStream(), true);
 
    		String str=null;
    		while (true)
                    {
    			str = in.readLine();
    			if (str.equals("$")) break;
    			System.out.println(numero+":"+str);
                        if (str.equals("hello")) {
                            System.out.println("Envoi de coucou");
                            out.println("Couou !!!");
                        }
                    }
    		System.out.println("Deconnection client "+numero);
    		in.close();
                out.close();
    		socket.close();
            }
    	catch(IOException e){}
    }
}

Salut, je te remercie je vais tester tes modifications.
Je te laisse ma dernière version du code :

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
import java.io.*;
import java.net.*;
 
public class Client extends Thread
{
	Socket socket =null;
	int port=5000;
   	PrintWriter out = null;
   	BufferedReader in = null;
	String adresse=null;
	InetAddress ip=null;
 
	public Client(InetAddress a){ip=a;}
	public Client(String s){adresse=s;}
 
 
 
	public void run()
	{
		try
		{
			System.out.println("Client actif");
			if (ip!=null) socket = new Socket(ip, port);
			else socket = new Socket(adresse, port);
       			out = new PrintWriter(socket.getOutputStream(), true);
       			in = new BufferedReader(new InputStreamReader(socket.getInputStream()));
			String str=null;
			while(true){
				str=in.readLine();
				out.println(str);
				if (str.equals("$")||str.equals("$$") ) break;
			}
			out.close();
			socket.close();
 
 
		}
		catch(IOException e)
		{
			System.out.println("Erreur client");
		}
	}
 
	public static void main(String[] args)
    {
		Client client=new Client("127.0.0.1");
		client.start();
    }
}

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
import java.io.*;
import java.net.*;
 
public class Serveur extends Thread
{
	ServerSocket serveur = null;
    	Socket client = null;
    	int port=5000;
	BufferedReader entree = null;
	PrintWriter sortie = null;
	String texte;
 
    public void run()
    {
    	try
    	{
    		System.out.println("Serveur actif");
    		serveur = new ServerSocket(port);
		client = serveur.accept();
 
		entree = new BufferedReader(new InputStreamReader(client.getInputStream()));
      		sortie = new PrintWriter(client.getOutputStream(), true);
 
    		while(true)
    		{
	    		        texte = entree.readLine();
				//Envoyer un texte au client
        			sortie.println(texte);
 
    		}
    	}
    	catch(IOException e)
    	{
    		System.out.println("Erreur Serveur");
    	}
   }
 
	protected void fin(){
		try{
			//Nettoyer 
        		entree.close();
        		sortie.close();
        		serveur.close();
		}
		catch(IOException e) {
        		System.out.println("Erreur de lecture");
		}
	}
 
   public static void main(String[] args)
    {
	   Serveur leServeur=new Serveur();
	   leServeur.run();
    }
}

Il est possible de faire en sorte que ce soit une discussion entre le serveur et le client ? Car avec tes modifications que je vais regarder de plus près, si j'ai bien compris c'est une réponse automatique généré si le client envoie "Coucou" ?
Merci encore pour ton aide

25/10/2010, 14h10
jabbounet

Citation:

Envoyé par ced56

Il est possible de faire en sorte que ce soit une discussion entre le serveur et le client ?

D'un point de vue très simplifié, c'est le même principe qu'une communication entre deux personnes.

Dans la programmation client/serveur, Tu retrouve classiquement un client qui envois des requêtes"/questions" à un serveur, le serveur effectue une série d'action en rapport avec la requête et retourne le résultat au client sous forme de réponse.

Pour que ce modèle marche, il est nécessaire que le client et le serveur soient capable de se comprendre (même vocabulaire/grammaire).

Citation:

Envoyé par ced56

Car avec tes modifications que je vais regarder de plus près, si j'ai bien compris c'est une réponse automatique généré si le client envoie "Coucou" ?

le serveur répond "coucou" si le client envois "hello"

Ok merci, je suis en train de tester le code que tu m'as donné avec Service et j'ai un erreur de compilation de la classe Serveur au niveau de l'utilisation de la classe Service qui est pourtant bien orthographiée. D'où cela peut il venir ?
Je compile en ligne de commande avec Ubuntu, voilà l'erreur :
Code:

1 2 3 4 5 6 7 8 9 10 11 src/Serveur.java:22: cannot find symbol symbol : class Service location: class mess.Serveur Service service=new Service(numero++,socket); ^ src/Serveur.java:22: cannot find symbol symbol : class Service location: class mess.Serveur Service service=new Service(numero++,socket); ^ 2 errors

25/10/2010, 15h48
jabbounet
As-tu cette ligne dans tes import
Code:

1 2 import mess.Service;
25/10/2010, 15h52
drake56

Non je ne l'avais pas, j'ai trouvé une autre solution entre temps pour compiler toutes mes classes en même temps mais là l'exécution ne marche pas donc je rajoute cette ligne et ça devrait le faire, merci
25/10/2010, 15h58
drake56

Je viens de tester ton code avec le client j'envoie bien hello, il se passe quelque chose du côté du serveur, il met Envoi de Coucou cependant la console Client n'affiche pas Coucou :s
26/10/2010, 07h45
jabbounet

Citation:

Envoyé par ced56

Je viens de tester ton code avec le client j'envoie bien hello, il se passe quelque chose du côté du serveur, il met Envoi de Coucou cependant la console Client n'affiche pas Coucou :s

pb de firewall?

A j'allais oublier la socket telle que tu l'utilise est bloquante.

donc ton programme se bloque sur le readLine tant que tu ne fournit pas quelque chose de l'autre coté.

En reprenant le code de Service.java que je t'avais fournit plus haut et en modifiant la boucle comme suit:
Code:

1 2 3 4 5 6 7 8 9 10 11 12 while (true) { str = in.readLine(); if (str.equals("$")) break; System.out.println(numero+":"+str); if (str.equals("hello")) { System.out.println("Envoi de coucou"); out.println("Couou !!!"); } else { out.println(str); } }
ton programme ne devrais plus se coincer.

La vrai solution pour pallier au problème de blocage sur le readLine est d'utiliser des socket non bloquant.
http://humbert-florent.developpez.co...vance/#LIV-D-1

Merci je teste avec le nouveau code puis je regarde les sockets non bloquants de plus près.
Juste une dernière question qui est en fait le centre du problème, est-ce qu'il est possible de mettre en place simplement en remplaçant à ce niveau là :
Code:

1 2 3 if (str.equals("hello")) { System.out.println("Envoi de coucou"); out.println("Couou !!!");
Remplacer le hello par n'importe quelle chaîne de caractère et le Coucou envoyé par une saisie clavier ?

Merci d'avance

Edit : J'ai testé ton code ça ne marchait pas par contre j'ai démarré Service dans ma classe Client à ce niveau là :
Code:

1 2 3 4 5 6 7 8 while (true ) { str=clavier.readLine(); buffer_out.println(str); if (str.equals("$")||str.equals("$$") ) break; Service service=new Service(numero,socket); service.start(); }
Et ça fonctionne le Coucou est envoyé

26/10/2010, 14h48
jabbounet
Citation:
Envoyé par ced56

Merci je teste avec le nouveau code puis je regarde les sockets non bloquants de plus près.
Juste une dernière question qui est en fait le centre du problème, est-ce qu'il est possible de mettre en place simplement en remplaçant à ce niveau là :

Code:

1 2 3 if (str.equals("hello")) { System.out.println("Envoi de coucou"); out.println("Couou !!!");

Remplacer le hello par n'importe quelle chaîne de caractère et le Coucou envoyé par une saisie clavier ?
Oui, il suffit juste d'implémenter la saisie clavier comme tu l'as faite pour le client.

Citation:

Envoyé par ced56

Edit : J'ai testé ton code ça ne marchait pas

Il marche chez moi.
Service

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
package mess;
import java.io.*;
import java.net.*;
 
public class Service extends Thread
{
    private  Socket socket;
    private int numero;
 
    public Service(int numero,Socket socket)
    {
    	this.numero=numero;
    	this.socket=socket;
    }
 
    public void run()
    {
    	try
            {
    		BufferedReader in = new BufferedReader(new InputStreamReader(socket.getInputStream()));
                PrintWriter out = new PrintWriter(socket.getOutputStream(), true);
                String str=null;
    		while (true) {
    			str = in.readLine();
    			if (str.equals("$")) break;
    			System.out.println(numero+":"+str);
                        if (str.equals("hello")) {
                            System.out.println("Envoi de coucou");
                            out.println("Couou !!!");
                        } else {
                            out.println(str);
                        }
                    }
    		System.out.println("Deconnection client "+numero);
    		in.close();
                out.close();
    		socket.close();
            }
    	catch(IOException e){}
    }
}

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
30
31
32
33
34
35
36
37
38
package mess;
 
import java.io.*;
import java.net.*;
 
public class Serveur extends Thread
{
    ServerSocket serveur=null;
    Socket socket=null;
    int port=5000;
    int numero=1;
 
    public void run()
    {
    	try
    	{
    		System.out.println("Serveur actif");
    		serveur = new ServerSocket(port);
    		while(true)
    		{
                    socket=serveur.accept();
                    System.out.println("Connection client "+ numero +" "+socket);
                    Service service=new Service(numero++,socket);
                    service.start();
    		}
    	}
    	catch(IOException e)
    	{
    		System.out.println("Erreur Serveur");
    	}
   }
 
   public static void main(String[] args)
    {
	   Serveur leServeur=new Serveur();
	   leServeur.start();
    }
}

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
39
40
41
42
43
44
45
46
47
48
49
50
51
52
import java.io.*;
import java.net.*;
 
public class Client extends Thread
{
    Socket socket =null;
    int port=5000;
    String adresse=null;
    InetAddress ip=null;
 
    public Client(InetAddress a){ip=a;}
    public Client(String s){adresse=s;}
 
    public void run()
    {
        try
            {
                System.out.println("Client actif");
                Reader reader= new InputStreamReader(System.in);
                BufferedReader clavier=new BufferedReader(reader);
                if (ip!=null) socket = new Socket(ip, port);
                else socket = new Socket(adresse, port);
                System.out.println("SOCKET = " + socket);
                PrintWriter buffer_out = new PrintWriter(new BufferedWriter(new OutputStreamWriter(socket.getOutputStream())),true);
                BufferedReader in = new BufferedReader(new InputStreamReader(socket.getInputStream()));
                String str =null;
                while (true )
                    {
                        str=clavier.readLine();
                        buffer_out.println(str);
                        if (str.equals("$")||str.equals("$$") ) break;
                        str=in.readLine();
                        if (str != null) {
                            System.out.println("lecture de " + str);
                        }
                    }
                in.close();
                buffer_out.close();
                socket.close();
            }
        catch(IOException e)
            {
                System.out.println("Erreur client");
            }
    }
 
    public static void main(String[] args)
    {
        Client client=new Client("127.0.0.1");
        client.start();
    }
}

Citation:

Envoyé par ced56

par contre j'ai démarré Service dans ma classe Client à ce niveau là :

Code:

1
2
3
4
5
6
7
8
while (true )
			{
				str=clavier.readLine();
				buffer_out.println(str);
				if (str.equals("$")||str.equals("$$") ) break;
				Service service=new Service(numero,socket);
    			        service.start();
			}

Et ça fonctionne le Coucou est envoyé

Pourquoi, mettre le service dans le client, tu compte te connecter à plusieurs serveur en même temps, dans ce cas ou compte tu envoyer la saisie clavier?

26/10/2010, 15h18
drake56

Merci pour ta nouvelle réponse.
J'ai mis le Service dans Client car sinon j'avais une boucle infinie qui envoyait le Coucou et en agissant ainsi il n'envoyait qu'une seule fois donc une connexion à un seul serveur suffira largement.
Je vais essayé ton code et sinon pour la saisie clavier je crois voir ce qu'il faut faire

Edit : J'ai utilisé ton code et c'est fonctionnel, il me reste plus qu'à trouver un moyen de remplacer le hello par n'importe quelle String puis le Coucou par une saisie clavier (en utilisant la méthode que j'ai utilisé dans Client)
26/10/2010, 15h36
drake56

J'ai réussi à tout mettre place encore merci pour ton aide :D !
Cependant je viens de me rendre compte que ni le serveur ni le client ne peut envoyer 2 phrases à la suite car sinon il y a un décalage dans la réception des messages.
Est-ce qu'il est possible de supprimer ce décalage ?