X-Git-Url: https://git.piment-noir.org/?p=TD_SR.git;a=blobdiff_plain;f=TD2%2Fserver%2FEchoServerThreadService.java;h=257f15c4d654dd587b82720d9d59189fb5ef4a1b;hp=e04d18f3c52bb2bdb06cd97c93ecfe6af31bc308;hb=b1bd144dcdf623152885186e165a39ddd65afd88;hpb=ef258436b31ba460b5038c5b7b62a06ea8968b2d diff --git a/TD2/server/EchoServerThreadService.java b/TD2/server/EchoServerThreadService.java index e04d18f..257f15c 100644 --- a/TD2/server/EchoServerThreadService.java +++ b/TD2/server/EchoServerThreadService.java @@ -1,58 +1,58 @@ -import java.net.*; -import java.io.*; -import java.util.*; - -public class EchoServerThreadService implements Runnable { - - private Socket clientSocket; - private ArrayList listWriter; - - EchoServerThreadService(Socket clientSocket) { - System.out.println("Creation d'un thread pour repondre a un client, port " + clientSocket.getPort()); - this.clientSocket = clientSocket; - } - - public void run() { - try { - doService(clientSocket); - clientSocket.close(); - } catch (IOException e) { - System.err.println("IOException : " + e); - e.printStackTrace(); - } - finally { - try { - if (this.clientSocket != null) - this.clientSocket.close(); - } catch (IOException e) { - System.err.println("IOException : " + e); - e.printStackTrace(); - } - } - } - - public void doService(Socket clientSocket) throws IOException { - BufferedReader in; - PrintStream out; - in = new BufferedReader(new InputStreamReader(clientSocket.getInputStream())); - out = new PrintStream(clientSocket.getOutputStream()); - //listWriter.add(new PrintWriter(clientSocket.getOutputStream())); - boolean end = false; - while (!end) { - String theLine = in.readLine(); - if (theLine.equals(".")) - end = true; // le thread de service doit terminer - out.println(theLine); - } - System.out.println("Fin du thread repondant au client, port " - + clientSocket.getPort()); - } - - public void broadcastMsg(String msg) { - for (int i = 0; i < listWriter.size(); i++) { - listWriter.get(i); - } - - } - -} +import java.net.*; +import java.io.*; +import java.util.*; + +public class EchoServerThreadService implements Runnable { + + private Socket clientSocket; + private ArrayList listWriter; + + EchoServerThreadService(Socket clientSocket) { + System.out.println("Creation d'un thread pour repondre a un client, port " + clientSocket.getPort()); + this.clientSocket = clientSocket; + } + + public void run() { + try { + doService(clientSocket); + clientSocket.close(); + } catch (IOException e) { + System.err.println("IOException : " + e); + e.printStackTrace(); + } + finally { + try { + if (this.clientSocket != null) + this.clientSocket.close(); + } catch (IOException e) { + System.err.println("IOException : " + e); + e.printStackTrace(); + } + } + } + + public void doService(Socket clientSocket) throws IOException { + BufferedReader in; + PrintStream out; + in = new BufferedReader(new InputStreamReader(clientSocket.getInputStream())); + out = new PrintStream(clientSocket.getOutputStream()); + //listWriter.add(new PrintWriter(clientSocket.getOutputStream())); + boolean end = false; + while (!end) { + String theLine = in.readLine(); + if (theLine.equals(".")) + end = true; // le thread de service doit terminer + out.println(theLine); + } + System.out.println("Fin du thread repondant au client, port " + + clientSocket.getPort()); + } + + public void broadcastMsg(String msg) { + for (int i = 0; i < listWriter.size(); i++) { + listWriter.get(i); + } + + } + +}