Discussion :

[abdelhak_z]

Bonsoir à tous,
j'ai décidé de me lancer dans la programmation Sockets en JAVA. Je me suis donc lancer dans la réalisation d'un pgme de deux clients et un serveur, chaque client envoi au serveur un tableau d'entiers[1,2,3....,10] et un nmbre X, le serveur fait la multiplication de ce tableau par ce nombre X et renvoi le nouveau tableau.
client1 envoi [1,2,3....,10],2 le serveur renvoi au client1 : [2,4,6,8,10,....,20]
et la meme chose pour client 2.
SVP quelqu’un peut m'aider et me donnée une demarche pour le resoudre,
meerciiiii

[tchize_]

tu coince sur quoi exactement?

[abdelhak_z]

je savai pas ou je met mn prgrm, puisque je doit travailler avec des thread, et est ce que je fait pour chaque client une classe et un code precis ou quoi? merci de me donnez des exemples

[tchize_]

Commence par faire deux programme séparés: le client et le serveur. Soit en faisant deux projet séparés dans ton ide, soit en créant deux classes main dans le même projet.

[abdelhak_z]

voila ce que j'ai fait:
j'ai fait pour un seul client mais y a un erreur, je c pas pour quoi
aidez moi svp

Code Java :

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
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
public class Serveur1 {
  public static void main(String args[]) throws IOException {
    char[] tabc = null;
    int[] tab = null;
    int port = 1000;
 
    ServerSocket sersoc1 = new ServerSocket(port);
 
    System.out.println("serveur active sur port " + port);
    Socket soc = sersoc1.accept();
    System.out.println("Nouvelle connexion : " + soc);
    Thread t1 = new Thread(new ReceptionServeur(soc));
    t1.start();
 
    System.out.println("serveur active sur port " + port);
    while (true) {
      soc = sersoc1.accept();
      System.out.println("Nouvelle connexion : " + soc);
      t1 = new Thread();
      InputStream flux = soc.getInputStream();
      BufferedReader entree = new BufferedReader(new InputStreamReader(flux));
      String message = entree.readLine();
 
      tab = Mult.multiplication(message);
      System.out.println("message reçu sur le serveur" + tab[0]);
      OutputStream flux1 = soc.getOutputStream();
 
      OutputStreamWriter sortie = new OutputStreamWriter(flux1);
      sortie.write((java.util.Arrays.toString(tab)));
 
      sortie.flush(); // pour forcer l'envoi de la ligne
      soc.close();
 
    }
  }
}
 
public class ReceptionServeur implements Runnable {
  Socket soc;
 
  ReceptionServeur(Socket s) {
    this.soc = s;
  }
 
  @Override
  public void run() {
    int port = 1000;
    ServerSocket sersoc1;
    try {
      InputStream flux = soc.getInputStream();
      BufferedReader entree = new BufferedReader(new InputStreamReader(flux));
      String message = entree.readLine();
      Thread t4 = new Thread(new EmissionServeur(message));
      t4.start();
    } catch (IOException e) {
      // TODO Auto-generated catch block
      e.printStackTrace();
    }
  }
}
 
public class EmissionServeur implements Runnable {
  private static PrintWriter out = null;
  private static int tab[];
  static String message;
 
  public EmissionServeur(String message) {
    this.message = message;
  }
 
  @Override
  public void run() {
    Socket soc = null;
    tab = Mult.multiplication(message);
    try {
      BufferedReader in = new BufferedReader(new InputStreamReader(soc.getInputStream()));
      message = in.readLine();
      System.out.println(message);
 
      out = new PrintWriter(soc.getOutputStream());
 
      out.println(tab);
      out.flush();
 
      OutputStream flux1 = null;
      OutputStreamWriter sortie = new OutputStreamWriter(flux1);
      sortie.write((java.util.Arrays.toString(tab)));
 
      sortie.flush(); // pour forcer l'envoi de la ligne
      soc.close();
    } catch (IOException e) {
      // TODO Auto-generated catch block
      e.printStackTrace();
    }
  }
}
 
public class Client1 {
  public static void main(String args[]) throws IOException {
    char[] tabc2 = { '1', '2', '3', '4', '5', '6', '7', '8', '9', '2' };
    String charString = new String(tabc2);
    String hote = "localhost";
    int port = 1000;
    Socket soc = new Socket(hote, port);
    OutputStream flux = soc.getOutputStream();
    OutputStreamWriter sortie = new OutputStreamWriter(flux);
    sortie.write(charString + "\n");
    sortie.flush(); // pour forcer l'envoi de la ligne
    soc.close();
  }
}

[Logan Mauzaize]

j'ai fait pour un seul client mais y a un erreur, je c pas pour quoi

Qu'as-tu comme erreur. Nous ne pouvons t'aider qu'à la condition que tu détailles les problèmes que tu rencontres.

Autrement,

• les classes "ReceptionServeur" et "EmissionServeur" ne sont pas utilisées,
• Quand tu utilises les OutputStream[Writ|Read]*er, tu devrais utiliser un encoding spécifique.