Petit client / serveur

Version imprimable

Salut, pour tester les fonctionnalités réseau j'essaye de créer un petit "chat" qui fait serveur client en même temps donc..

Je crée une Thread qui permet au serveur du programme de regarder les connections entrantes et mon programme principale envoi des lignes sur ce même serveur (c'est pour tester) => donc je crée un serveur sur localhost et dans le programme principal j'envoi aussi sur localhost.

Le problème est que le serveur reçoit bien la connection lors de l'envoi (ne bloque pas sur accept()) mais impossible de lire la ligne avec readline()

Je précise que quand je remplace readline par un simple texte, à chaque envoi le serveur affiche bien le texte statique.

Voici le code :

classe principal :

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
 
import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
 
 
public class Main {
 
	/**
         * @param args
         * @throws IOException 
         */
	public static void main(String[] args) {
		// TODO Auto-generated method stub
		BufferedReader input = new BufferedReader(new InputStreamReader(System.in));
		String ip,line;
		int port;
 
		System.out.println("Entrez l'adresse ip :");
		try {
			ip = input.readLine();
 
			System.out.println("Entrez le port :");
			port = Integer.parseInt(input.readLine());
 
			ChatServer chat = new ChatServer("localhost",port);//System.out.println("ok");
			chat.start();
			//chat.send("envoi");
 
			while((line = input.readLine()) != null) {
				chat.send("localhost",line);
			}
 
			chat.interrupt();
		} catch (IOException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
	}
 
}

classe ChatServer :

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
58
 
import java.io.*;
import java.net.*;
 
public class ChatServer extends Thread {
	String ip;
	int port;
 
	ChatServer(String ip,int port) {
		this.port = port;
		this.ip = ip;
	}
 
	public void run() {
			try {
				ServerSocket servSoc = new ServerSocket(this.port);
				//servSoc.setSoTimeout(5000);//System.out.println(ip);
				while(!isInterrupted()) {
					Socket soc = servSoc.accept();
					InputStream flux = soc.getInputStream();
					BufferedReader input = new BufferedReader(new InputStreamReader(flux));
					//System.out.println("aff"+input.readLine());
 
					//listen(input.readLine());
					String msg = input.readLine();
					System.out.println(msg);
				}
				System.out.println("END");
			} catch (IOException e) {
				// TODO Auto-generated catch block
				e.printStackTrace();
			}
	}
 
	public void send(String ip, String line) {
		Socket soc;
		try {
			soc = new Socket(ip,this.port);
 
			BufferedWriter output = new BufferedWriter(new OutputStreamWriter(soc.getOutputStream()));
 
			output.write(line);
			output.flush();
			System.out.println("envoyer");
		}
		catch (UnknownHostException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		} catch (IOException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
	}
 
	private void listen(String line) {
		System.out.println("Reçu : " + line);
	}
}

Merci

20/03/2009, 14h28
tchize_

ta partie client n'envoie pas de \n ni ne fait de close de sa socket. Le serveur n'as donc aucun moyen, de son coté de savoir que la ligne est terminée car il n'y a ni marqueur de fin de ligne, ni coupure du flux. Il faut au moins un des deux.
20/03/2009, 14h45
Oprichnik

Merci ! ça marche nikel !

le probleme vient du fait que tu faire un readline, alors que la chaine ecrite dans le socket ne contient pas de marque de fin de ligne.

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
58
59
60
61
62
/*
 * To change this template, choose Tools | Templates
 * and open the template in the editor.
 */

package javaapplication2;

import java.io.*;
import java.net.*;

public class ChatServer extends Thread {
	String ip;
	int port;

	ChatServer(String ip,int port) {
		this.port = port;
		this.ip = ip;
	}

    @Override
	public void run() {
			try {
				ServerSocket servSoc = new ServerSocket(this.port);
				//servSoc.setSoTimeout(5000);//System.out.println(ip);
				while(!isInterrupted()) {
                   
					Socket soc = servSoc.accept();                    
			    	InputStream flux = soc.getInputStream();                    
					BufferedReader input = new BufferedReader(new InputStreamReader(flux));					
					String msg = input.readLine();
					System.out.println("msg : "+msg);           
				}
				System.out.println("END");
			} catch (IOException e) {
				// TODO Auto-generated catch block
				e.printStackTrace();
			}
	}

	public void send(String ip, String line) {
		Socket soc;
		try {
			soc = new Socket(ip,this.port);
			BufferedWriter output = new BufferedWriter(new OutputStreamWriter(soc.getOutputStream()));
		output.write(line+"\n");
            System.out.println("envoyer...");
			output.flush();			
		}
		catch (UnknownHostException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		} catch (IOException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
	}

	private void listen(String line) {
		System.out.println("Reçu : " + line);
	}
}

21/03/2009, 11h37
Oprichnik

J'ai une autre petite question liée à ce code :

Comment faire pour stopper la Thread proprement lorsqu'elle se trouve sur readline() ?

Citation:

Envoyé par Oprichnik

J'ai une autre petite question liée à ce code :

Comment faire pour stopper la Thread proprement lorsqu'elle se trouve sur readline() ?

java doc dit :

Code:

1
2
3
4
5
6
7
8
9
10
11
12
 
java.net.Socket
public synchronized void close() throws IOException
Closes this socket.
Any thread currently blocked in an I/O operation upon this socket will throw a SocketException.
Once a socket has been closed, it is not available for further networking use (i.e. can't be reconnected or rebound). A new socket needs to be created.
Closing this socket will also close the socket's InputStream and OutputStream.
If this socket has an associated channel then the channel is closed as well.
Throws:
IOException - if an I/O error occurs when closing this socket. 
See Also:
Socket.isClosed

La methode close est là pour ça je crois.

21/03/2009, 13h48
Oprichnik

Merci

Bonjour,
je vois que tu as resolu ton problème mais ceci

Code:

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
    * un petit exemple vite fait pour un serveur :
    *
    * public class PouetServeur implements ServeurListener {
    * public static void main(String[] args){
    * Serveur serv = new Serveur(port, type , maxConnection) ;
    * serv .addServeurListener(this);
    * }
    *
    * public void connexionRecue(Socket s){
    * //une connexion recue !
    * }
    * }
    *
    *
    * Meme principe pour le client.

peut t'interesser au cas où tu veux faire un client/serveur avec les listener.
bon travail