diff --git a/src/main/java/fr/istic/pr/echo/ClientHandlerBytes.java b/src/main/java/fr/istic/pr/echo/ClientHandlerBytes.java index 7464896..87d2aef 100644 --- a/src/main/java/fr/istic/pr/echo/ClientHandlerBytes.java +++ b/src/main/java/fr/istic/pr/echo/ClientHandlerBytes.java @@ -4,6 +4,7 @@ package fr.istic.pr.echo; import java.io.InputStream; import java.io.ObjectInputStream; import java.io.ObjectOutputStream; +import java.io.OutputStream; import java.net.Socket; public class ClientHandlerBytes implements ClientHandler, Runnable { @@ -18,19 +19,19 @@ public class ClientHandlerBytes implements ClientHandler, Runnable { //Lecture du message dans un buffer de bytes //Envoie du buffer de bytes. - ObjectInputStream objInStream; try { - InputStream inStream = socket.getInputStream(); - + InputStream inStream = socket.getInputStream(); + byte[] buffer = new byte[8]; - String byteRead; - String + inStream.read(buffer); + String message = new String(buffer); + System.out.println("client reçu : " + message); + + OutputStream outStream = socket.getOutputStream(); + + outStream.write(buffer); + System.out.println("client envoie : " + message); - objInStream = new ObjectInputStream(this.socket.getInputStream()); - String message = (String) objInStream.readObject(); - System.out.println(message); - byte[] tab8byte = new byte[8]; - byte[] messageByte = message.getBytes(); } catch (Exception e) { System.out.println(e); } @@ -38,6 +39,8 @@ public class ClientHandlerBytes implements ClientHandler, Runnable { @Override public void run() { - + while(!this.socket.isClosed()){ + handle(); + } } }