ue1/src/Client/UDP.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 /*\r
   8 * >--UDP--<\r
   9 * Author: Someone\r
  10 */\r
  11 public class UDP implements Runnable{\r
  12   private DatagramSocket $udpSock       = null;\r
  13   private String $server = null;\r
  14   private int $sport = 0;\r
  15 \r
  16 public UDP(int $port, String $saddr, int $sport)throws Exception{\r
  17   $udpSock = new DatagramSocket($port);\r
  18   $udpSock.setReceiveBufferSize(1024*1024);\r
  19   $server = $saddr;\r
  20   this.$sport = $sport;\r
  21   new Thread(this).start();\r
  22 }\r
  23 \r
  24 public void run(){\r
  25   while($udpSock != null){\r
  26     receive();\r
  27   }\r
  28 }\r
  29 \r
  30 public void receive(){\r
  31   try{\r
  32     DatagramPacket $packet = new DatagramPacket(new byte[1400],1400);\r
  33     $udpSock.receive($packet);\r
  34     System.out.println(new String($packet.getData()).trim());\r
  35   }catch(Exception $e){$e.printStackTrace();}\r
  36 }\r
  37 \r
  38 public void send(String $msg){\r
  39   try{\r
  40     DatagramPacket $packet = new DatagramPacket($msg.getBytes(),$msg.length(),InetAddress.getByName($server),$sport);\r
  41     $udpSock.send($packet);\r
  42   }catch(Exception $e){$e.printStackTrace();}\r
  43 }\r
  44 \r
  45 public void shutdown(){\r
  46   try{\r
  47     $udpSock.close();\r
  48   }catch(Exception $e){$e.printStackTrace();}\r
  49   $udpSock=null;\r
  50 }\r
  51 }