Discussion :

[Oprichnik]

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 :

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
 
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 :

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
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

[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.

[Oprichnik]

Merci ! ça marche nikel !

[darrylsite]

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 :

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

[Oprichnik]

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

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

[darrylsite]

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 :

Sélectionner tout - Visualiser dans une fenêtre à part

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.

[Oprichnik]

Merci

[EAKOM]

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

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
    * 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