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