Project

General

Profile

Revision 3

Update

View differences:

SenderUDP.java
1
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

  
1
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 45
}

Also available in: Unified diff