package thrServ;
import [Link];
import [Link];
import [Link];
import [Link];
import [Link];
import [Link];
import [Link];
public class ServeurMultiThread extends Thread {
private int Numero=0;
Socket socket = null;
InputStreamReader inpStrReader = null;
OutputStreamWriter outStrWriter =null;
BufferedReader buffReader = null;
BufferedWriter buffWriter = null;
ServerSocket servSocket =null;
public void run() {
try {
servSocket = new ServerSocket(1235);
[Link]("Ecoute sur le Port ...");
while(true) {
[Link]("En Attente de Nouveaux Clients");
socket=[Link]();
++Numero;
[Link]("Client [" +Numero+ "] Connecté");
Echange ech=new Echange(socket,Numero);
[Link]();
}
} catch (IOException e) {[Link]();}
} // RUN Serveur Multi Thread
///////////////////////////////////
public static void main(String[] args) {
ServeurMultiThread S1= new ServeurMultiThread();
[Link]();
} // Main Serveur Multi Thread
} // Class
package thrServ;
import [Link];
import [Link];
import [Link];
import [Link];
import [Link];
import [Link];
public class Echange extends Thread {
public Socket sClient;
private int numClient;
public Echange(Socket socketClient,int monNumero) {
super();
[Link]=socketClient;
[Link]=monNumero;
}
InputStreamReader inpStrReader=null;
BufferedReader buffReader=null;
OutputStreamWriter outStrWriter=null;
BufferedWriter buffWriter=null;
public void run() {
try {
inpStrReader = new InputStreamReader([Link]());
buffReader =new BufferedReader(inpStrReader);
outStrWriter = new OutputStreamWriter([Link]());
buffWriter = new BufferedWriter(outStrWriter);
String msgFromClient;
while(true) {
msgFromClient = [Link]();
[Link]("Client Numero("+numClient + ") sent : "+msgFromClient);
[Link]("Message Recu :"+msgFromClient);
[Link]();
[Link]();
if([Link]("Fin") ) {
[Link]("Fin du Client["+numClient+"]");
break; }
} // WHILE
[Link]();
[Link]();
[Link]();
[Link]();
[Link]();
} catch (IOException e) { [Link](); }
} // RUN
} // class
import [Link];
import [Link];
import [Link];
import [Link];
import [Link];
import [Link];
import [Link];
public class Client {
public static void main(String[] args) throws InterruptedException {
Socket socket = null;
InputStreamReader inpStrReader = null;
OutputStreamWriter outStrWriter =null;
BufferedReader buffReader = null;
BufferedWriter buffWriter = null;
try {
socket = new Socket("localhost",1235);
inpStrReader=new InputStreamReader([Link]());
buffReader = new BufferedReader(inpStrReader);
outStrWriter = new OutputStreamWriter([Link]());
buffWriter = new BufferedWriter(outStrWriter);
Scanner Clavier = new Scanner([Link]);
String msgToSend;
while(true) {
msgToSend=[Link]();
int nbrToSend=0;
if( ![Link]("FIN") )
{
nbrToSend= [Link](msgToSend);
for(int i=0;i<nbrToSend;i++) {
[Link](1000);
[Link]([Link](i));
[Link]();
[Link]();
[Link]("Reponse Serveur :"+ [Link]());
}
}
else { [Link](msgToSend);
[Link]();
[Link]();
[Link]();
break;}
}// WHILE TRUE
} catch(IOException e) {[Link]();}
finally {
try{
if(socket!=null) [Link]();
if(inpStrReader!=null) [Link]();
if(buffReader!=null) [Link]();
if(outStrWriter!=null) [Link]();
if(buffWriter!=null) [Link]();
} catch(IOException e) {[Link]();}
}
}// MAIN
}// Class