clientHanderBytes en cours

This commit is contained in:
trochas
2025-01-28 11:36:17 +01:00
parent 1bb3194196
commit e6635fd16b

View File

@@ -4,6 +4,7 @@ package fr.istic.pr.echo;
import java.io.InputStream; import java.io.InputStream;
import java.io.ObjectInputStream; import java.io.ObjectInputStream;
import java.io.ObjectOutputStream; import java.io.ObjectOutputStream;
import java.io.OutputStream;
import java.net.Socket; import java.net.Socket;
public class ClientHandlerBytes implements ClientHandler, Runnable { public class ClientHandlerBytes implements ClientHandler, Runnable {
@@ -18,19 +19,19 @@ public class ClientHandlerBytes implements ClientHandler, Runnable {
//Lecture du message dans un buffer de bytes //Lecture du message dans un buffer de bytes
//Envoie du buffer de bytes. //Envoie du buffer de bytes.
ObjectInputStream objInStream;
try { try {
InputStream inStream = socket.getInputStream(); InputStream inStream = socket.getInputStream();
byte[] buffer = new byte[8]; byte[] buffer = new byte[8];
String byteRead; inStream.read(buffer);
String 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) { } catch (Exception e) {
System.out.println(e); System.out.println(e);
} }
@@ -38,6 +39,8 @@ public class ClientHandlerBytes implements ClientHandler, Runnable {
@Override @Override
public void run() { public void run() {
while(!this.socket.isClosed()){
handle();
}
} }
} }