]> git.somenet.org - pub/jan/dslab.git/blob - ue3/src/Client/UDP.java
GITOLITE.txt
[pub/jan/dslab.git] / 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 }