Discussion :

[khalil15]

Bonjour,

J'essaye de faire un client et un serveur en multithread mais le serveur ne veut pas fonctionner. J'ai l'erreur suivante :
Client

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
import java.io.*;
import java.net.*;
import java.util.Scanner;
 
 
public class Client {
 
	public static void main(String[] args) {
		try {
			Socket s = new Socket("localhost", 3030);
			InputStream is = s.getInputStream();
			OutputStream os = s.getOutputStream();
			System.out.println("Lire un nobre NB");
			Scanner clavier = new Scanner(System.in);
			int nb = clavier.nextInt();
			System.out.println("envoyer le nombre" + nb + "au serveur");
			os.write(nb);
			System.out.println("attedre la réponse du serveur:");
			int rep = is.read();
			System.out.println("La réponse est :" + rep) ;
		} catch(IOException e){
			e.printStackTrace();}
	}
 
}

Serveur

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
 
 
import java.io.*;
import java.net.ServerSocket;
import java.net.Socket;
 
 
public class MultiThreadedServer {
    public static void main(String []args){
 
        System.out.print("Serveur en ligne\n");
 
        //declare a TCP socket object and initialize it to null
        ServerSocket serverSocket=null;
        //create the port number
        int port = 3030;
 
        try {
            //create the TCP socket server
            serverSocket = new ServerSocket(3030);
 
            System.out.println("ECHO server created on port = "+port);
        } catch (IOException ex) {
            //will be executed when the server cannot be created
            System.out.println("Error: The server with port="+port+" cannot be created");
        }
 
 
        //starts an endless loop
        while(true){
            Socket clientSocket = null;
            try {
                //start listening to incoming client request (blocking function)
                System.out.println("[ECHO Server] waiting for the incoming request ...");
                clientSocket = serverSocket.accept();
            } catch (IOException e) {
                System.out.println("Error: cannot accept client request. Exit program");
                return;
            }
            try {
                //create a new thread for each incoming message
                new Thread(new Run(clientSocket, "Multithreaded Server")).start();
            } catch (Exception e) {
                //log exception and go on to next request.
            }
        }
 
    }
 
 }

Exécution :

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
 
 
import java.io.*;
import java.net.Socket;
import java.util.Scanner;
 
 
public class Run implements Runnable{
 
    protected Socket clientSocket = null;
    protected String serverText   = null;
 
    public Run(Socket clientSocket, String serverText) {
        this.clientSocket = clientSocket;
        this.serverText   = serverText;
    }
 
 
    public void run() {
 
 
        try {
            InputStream input  = clientSocket.getInputStream();
            OutputStream output = clientSocket.getOutputStream();
            InputStreamReader inputStream = new InputStreamReader(input);
 
 
            BufferedReader bufferedReader = new BufferedReader(inputStream);
            String message = null;
            message = bufferedReader.readLine();
 
            if (message != null)
            {
            	System.out.println("j'attend le nom de client");
            	Scanner sc = new Scanner(System.in);
            	String nom = sc.nextLine();
			}
            else
            {System.out.println("j'attend un nombre (1 octet)");
			int nb=input.read();
			System.out.println("j envoi la repense");
			output.write(nb*5);
			System.out.println("deconexion de client");
            output.close();
            input.close();
            }
        } catch (IOException e) {
            //report exception somewhere.
            e.printStackTrace();
        }
    }
 
}

[joel.drigo]

Salut,

Il y'a une erreur qui fait que le ServerSocket n'est pas créé. Le souci c'est que non seulement tu ne traite pas l'erreur comme une erreur, mais tu ne l'affiches même pas, donc on ne sait pas ce que c'est :

Code :

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

1
2
3
4
catch (IOException ex) {
            //will be executed when the server cannot be created
            System.out.println("Error: The server with port="+port+" cannot be created");
        }

Ici, s'il y a une erreur, tu affiches juste un message sans indiquer ce que l'exception dit, et tu continues le code, ce qui ne sert à rien, puisqu'il n'y a pas de serveur créé.

Pour afficher l'erreur, au minimum : ex.printStackTrace();, et si tu ne vois pas comment corriger le problème, montre-nous ce qui est affiché. Ensuite, ne continue pas le code, arrête le programme.

[jasonpercus]

Salut Khalil15,

Je te confirme ce qu'a dit joel.drigo: Ta ServerSocket n'est pas créée.
Maintenant je sais qu'il est particulièrement difficile de programmer un serveur TCP multi-thread.
Aussi si tu ne souhaites pas réinventer la roue je te propose la librairie Magnetar. Tu trouveras son site à l'adresse https://josephbriguet01.github.io/Magnetar/. Il te suffira juste de télécharger le projet .zip contenant toutes les sources java du serveur et du client TCP et t'inspirer de son code que tu peux également trouver à l'adresse suivante https://github.com/josephbriguet01/Magnetar. Si maintenant tu ne veux vraiment pas te casser la tête récupère dans le dossier dist la librairie "Magnetar.jar" et intègre la à ton projet java.
Et tu verras, finis les ennuis TCP . De plus la javadoc est également fournie et un exemple d'utilisation est donné sur le site. Que demander de mieux ?

Pour ma part je ne jure plus qu'avec cette librairie. Les autres trouvées sur Internet sont beaucoup trop compliquées d'utilisation.