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