diff --git a/src/main/java/fr/istic/pr/echo/ClientHandlerChar.java b/src/main/java/fr/istic/pr/echo/ClientHandlerChar.java index 6bf708f..098cce3 100644 --- a/src/main/java/fr/istic/pr/echo/ClientHandlerChar.java +++ b/src/main/java/fr/istic/pr/echo/ClientHandlerChar.java @@ -35,12 +35,12 @@ public class ClientHandlerChar implements ClientHandler { isr.close(); osw.close(); }catch (IOException e){ - System.out.println(e.getMessage()); + System.err.println(e.getMessage()); }finally { try{ socket.close(); }catch (IOException e){ - System.out.println(e.getMessage()); + System.err.println(e.getMessage()); } } } diff --git a/src/main/java/fr/istic/pr/echo/EchoServer.java b/src/main/java/fr/istic/pr/echo/EchoServer.java index e6ce623..957e6c3 100644 --- a/src/main/java/fr/istic/pr/echo/EchoServer.java +++ b/src/main/java/fr/istic/pr/echo/EchoServer.java @@ -7,25 +7,25 @@ import java.net.Socket; class echoServer { public static void main(String[] args) throws IOException{ - - //Attente sur le port 8080s int portDuServer = 8080; ServerSocket serverSocket = new ServerSocket(portDuServer); - try{ - while(true){ - /* Pour chaque client : - 1. accepter la connexion. - 2. créer un ClientHandler - 3. appeler la méthode handleBytes() sur le handler - */ + boolean marche= true; + while(marche){ + /* Pour chaque client : + 1. accepter la connexion. + 2. créer un ClientHandler + 3. appeler la méthode handleBytes() sur le handler + */ + try{ Socket socket = serverSocket.accept(); ClientHandler clientHandler= new ClientHandlerChar(socket); clientHandler.handle(); socket.close(); + }catch(Exception e){ + System.err.println(e.getMessage()); + marche=false; } - }catch(Exception e){ - System.out.println(e.getMessage()); } } } diff --git a/src/main/java/fr/istic/pr/echomt/ClientHandlerCharMT.java b/src/main/java/fr/istic/pr/echomt/ClientHandlerCharMT.java index 3c4a948..a06ca1b 100644 --- a/src/main/java/fr/istic/pr/echomt/ClientHandlerCharMT.java +++ b/src/main/java/fr/istic/pr/echomt/ClientHandlerCharMT.java @@ -39,12 +39,12 @@ public class ClientHandlerCharMT implements ClientHandlerMT, Runnable { isr.close(); osw.close(); }catch (IOException e){ - System.out.println(e.getMessage()); + System.err.println(e.getMessage()); }finally { try{ socket.close(); }catch (IOException e){ - System.out.println(e.getMessage()); + System.err.println(e.getMessage()); } } } diff --git a/src/main/java/fr/istic/pr/echomt/EchoServerMT.java b/src/main/java/fr/istic/pr/echomt/EchoServerMT.java index e1121f3..19c79b7 100644 --- a/src/main/java/fr/istic/pr/echomt/EchoServerMT.java +++ b/src/main/java/fr/istic/pr/echomt/EchoServerMT.java @@ -12,15 +12,13 @@ public class EchoServerMT { int portEcoute = 8080; try (ServerSocket serverSocket = new ServerSocket(portEcoute)) { Executor service = Executors.newFixedThreadPool(4); - while(true){ + while(!Thread.currentThread().isInterrupted()){ Socket socket = serverSocket.accept(); service.execute(new ClientHandlerCharMT(socket)); - } } catch (Exception e){ - e.printStackTrace(); + System.err.println(e.getMessage()); } } - } diff --git a/src/main/java/fr/istic/pr/serveur/ServeurHTTP.java b/src/main/java/fr/istic/pr/serveur/ServeurHTTP.java index 27e92b4..895d0bc 100644 --- a/src/main/java/fr/istic/pr/serveur/ServeurHTTP.java +++ b/src/main/java/fr/istic/pr/serveur/ServeurHTTP.java @@ -13,12 +13,12 @@ public class ServeurHTTP { try{ ServerSocket serverSocket = new ServerSocket(portDuServer); Executor service = Executors.newFixedThreadPool(4); - while(true){ + while(!Thread.currentThread().isInterrupted()){ Socket socket = serverSocket.accept(); service.execute(new HTTPHandler(socket)); } }catch(Exception e){ - System.out.println(e.getMessage()); + System.err.println(e.getMessage()); } } }