X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=TD2%2Fclient%2FSocketClient.java;h=b038475de13bedc2abdd6109610cc9a7459d83d9;hb=f8c647b503f84d4a8fc9ff0564f8bcfa989f3020;hp=3c6d021c605f3a22a7d9537d8f1bf830a28854f7;hpb=da31e6daf7553c6b38ca83c428dd02a3aa8af853;p=TD_SR.git diff --git a/TD2/client/SocketClient.java b/TD2/client/SocketClient.java index 3c6d021..b038475 100644 --- a/TD2/client/SocketClient.java +++ b/TD2/client/SocketClient.java @@ -18,6 +18,21 @@ public class SocketClient { } catch (IOException e) { System.err.println("IOException: " + e); + e.printStackTrace(); + closeRWIO(); + } + } + + public SocketClient(boolean withoStream) { + // établie une connexion au serveur par un appel + // à connexionServeur() + attributesInit(); + try { + connexionServeur("localhost", 5000, withoStream); + } + catch (IOException e) { + System.err.println("IOException: " + e); + e.printStackTrace(); closeRWIO(); } } @@ -31,11 +46,12 @@ public class SocketClient { } catch (IOException e) { System.err.println("IOException: " + e); + e.printStackTrace(); closeRWIO(); } } - private void connexionServeur(String adresseIPServeur, int portServeur) throws IOException { + private void connexionServeur(String adresseIPServeur, int portServeur, boolean hasoStream) throws IOException { // créer un objet socket lié au socket serveur et l'affecte à sock // puis établie les chaînages de flot nécessaires // pour l'envoi et la reception de messages @@ -43,12 +59,21 @@ public class SocketClient { OutputStream OStream = sock.getOutputStream(); ecriture = new PrintWriter(OStream); - oEcriture = new ObjectOutputStream(OStream); + if (hasoStream) + oEcriture = new ObjectOutputStream(OStream); InputStream IStream = sock.getInputStream(); InputStreamReader IMesg = new InputStreamReader(IStream); lecture = new BufferedReader(IMesg); - oLecture = new ObjectInputStream(IStream); + if (hasoStream) + oLecture = new ObjectInputStream(IStream); + } + + private void connexionServeur(String adresseIPServeur, int portServeur) throws IOException { + // créer un objet socket lié au socket serveur et l'affecte à sock + // puis établie les chaînages de flot nécessaires + // pour l'envoi et la reception de messages + connexionServeur(adresseIPServeur, portServeur, false); } private void attributesInit() { @@ -70,7 +95,7 @@ public class SocketClient { /** * Send an object message on the opened client socket - * @param msg a string containing the message to send + * @param oMsg an object containing the message to send */ public void sendoMsg(Message oMsg) throws IOException { oEcriture.writeObject(oMsg); @@ -90,7 +115,7 @@ public class SocketClient { /** * Receive an object message sent on the opened client socket - * @return a string containing the received message + * @return a object containing the received message */ public Message receiveoMsg() throws IOException, ClassNotFoundException { return (Message)oLecture.readObject(); @@ -115,6 +140,7 @@ public class SocketClient { } catch (IOException e) { System.err.println("IOException: " + e); + e.printStackTrace(); } }