root / src / peer / channels / SenderUDP.java @ 3
History | View | Annotate | Download (760 Bytes)
1 | 3 | up20150644 | package peer.channels; |
---|---|---|---|
2 | |||
3 | import java.io.IOException; |
||
4 | import java.net.DatagramPacket; |
||
5 | import java.net.DatagramSocket; |
||
6 | import java.net.InetAddress; |
||
7 | import java.net.SocketException; |
||
8 | |||
9 | /**
|
||
10 | * SenderUDP
|
||
11 | */
|
||
12 | public class SenderUDP implements Sender { |
||
13 | |||
14 | private DatagramSocket socket; |
||
15 | |||
16 | public SenderUDP() {
|
||
17 | } |
||
18 | |||
19 | @Override
|
||
20 | public void send(byte[] message) { |
||
21 | DatagramPacket packet = new DatagramPacket(message, message.length); |
||
22 | try {
|
||
23 | socket.send(packet); |
||
24 | } catch (IOException e) { |
||
25 | e.printStackTrace(); |
||
26 | } |
||
27 | } |
||
28 | |||
29 | @Override
|
||
30 | public void init(InetAddress address, int port) { |
||
31 | try {
|
||
32 | socket = new DatagramSocket(port, address); |
||
33 | } catch (SocketException e) { |
||
34 | e.printStackTrace(); |
||
35 | } |
||
36 | } |
||
37 | |||
38 | @Override
|
||
39 | public void destroy() { |
||
40 | socket.disconnect(); |
||
41 | } |
||
42 | |||
43 | |||
44 | |||
45 | 2 | up20150644 | } |