ue1/src/Client/TCP.java

   1 package Client;\r
   2 \r
   3 import java.io.*;\r
   4 import java.util.*;\r
   5 import java.net.*;\r
   6 /*\r
   7 * >--TCP--<\r
   8 * Author: Someone\r
   9 */\r
  10 public class TCP implements Runnable{\r
  11   private Socket $sock = null;\r
  12   private InputStream $in = null;\r
  13   private OutputStream $out = null;\r
  14 \r
  15 \r
  16 public TCP(String $server, int $port)throws Exception{\r
  17   $sock = new Socket($server, $port);\r
  18   $in = $sock.getInputStream();\r
  19   $out = $sock.getOutputStream();\r
  20   new Thread(this).start();\r
  21 }\r
  22 \r
  23 public void run(){\r
  24   try{\r
  25     while($sock != null){\r
  26       receive();\r
  27     }\r
  28   }catch(Exception $e){$e.printStackTrace();}\r
  29 }\r
  30 \r
  31 public void send(String $msg){\r
  32   try{\r
  33     byte[] $len = Helper.int2ba($msg.length());\r
  34     $out.write($len);\r
  35     $out.flush();\r
  36     $out.write($msg.getBytes());\r
  37     $out.flush();\r
  38   }catch(Exception $e){$e.printStackTrace();}\r
  39 }\r
  40 \r
  41 public void receive()throws Exception{\r
  42   int $len = Helper.ba2int(Helper.readBA($in, 4));\r
  43   String $msg = new String(Helper.readBA($in, $len));\r
  44   System.out.println($msg);\r
  45 }\r
  46 \r
  47 public void shutdown(){\r
  48   try{\r
  49     send("CLIENT shutting down...");\r
  50     $out.close();\r
  51     $in.close();\r
  52     $sock.close();\r
  53     $sock = null;\r
  54   }catch(Exception $e){$e.printStackTrace();}\r
  55 }\r
  56 \r
  57 }