ue3/src/Server/UDP.java

   1 package Server;\r
   2 \r
   3 import java.io.*;\r
   4 import java.util.*;\r
   5 import java.net.*;\r
   6 \r
   7 /*\r
   8 * >--SyslogD_UDP--<\r
   9 * Author: Someone\r
  10 */\r
  11 public class UDP implements Runnable{\r
  12   private DatagramSocket $udpSock       = null;\r
  13 \r
  14 public UDP(int $port)throws Exception{\r
  15   System.out.println("SERVER UDP: "+$port);\r
  16   $udpSock = new DatagramSocket($port);\r
  17   $udpSock.setReceiveBufferSize(1024*1024);\r
  18   new Thread(this).start();\r
  19 }\r
  20 \r
  21 public void run(){\r
  22   while($udpSock != null){\r
  23     receive();\r
  24   }\r
  25 }\r
  26 \r
  27 public void receive(){\r
  28   try{\r
  29     DatagramPacket $packet = new DatagramPacket(new byte[1400],1400);\r
  30     $udpSock.receive($packet);\r
  31     new UDPW($packet,$udpSock);\r
  32   }catch(Exception $e){$e.printStackTrace();}\r
  33 }\r
  34 \r
  35 public void shutdown(){\r
  36   try{\r
  37     $udpSock.close();\r
  38   }catch(Exception $e){$e.printStackTrace();}\r
  39   $udpSock=null;\r
  40 }\r
  41 }