ue3/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 \r
  17 public UDP(String $saddr, int $sport)throws Exception{\r
  18   System.out.println("CLIENT UDP -> "+$saddr+":"+$sport);\r
  19   $udpSock = new DatagramSocket();\r
  20   $udpSock.setReceiveBufferSize(1024*1024);\r
  21   $server = $saddr;\r
  22   this.$sport = $sport;\r
  23   new Thread(this).start();\r
  24 }\r
  25 \r
  26 public void run(){\r
  27   while($udpSock != null){\r
  28     receive();\r
  29   }\r
  30 }\r
  31 \r
  32 public void receive(){\r
  33   try{\r
  34     DatagramPacket $packet = new DatagramPacket(new byte[1400],1400);\r
  35     $udpSock.receive($packet);\r
  36     System.out.println(new String($packet.getData()).trim());\r
  37   }catch(Exception $e){$e.printStackTrace();}\r
  38 }\r
  39 \r
  40 public void send(String $msg){\r
  41   try{\r
  42     DatagramPacket $packet = new DatagramPacket($msg.getBytes(),$msg.length(),InetAddress.getByName($server),$sport);\r
  43     $udpSock.send($packet);\r
  44   }catch(Exception $e){$e.printStackTrace();}\r
  45 }\r
  46 \r
  47 public void shutdown(){\r
  48   try{\r
  49     $udpSock.close();\r
  50   }catch(Exception $e){$e.printStackTrace();}\r
  51   $udpSock=null;\r
  52 }\r
  53 }