UDP三种通信方式

单播（Unicast）

单播是最常见的通信方式，数据从一个发送方传输到一个特定的接收方。发送方将数据包发送到接收方的IP所在和端口号，接收方通过监听指定的端口接收数据。单播实用于一对一的通信场景。

1. import java.net.DatagramPacket;
2. import java.net.DatagramSocket;
3. import java.net.InetAddress;
5. public class UDPSender {
6.     public static void main(String[] args) {
7.         try {
8.             DatagramSocket socket = new DatagramSocket();
9.             String message = "Hello, World!";
10.             byte[] buffer = message.getBytes();
11.             InetAddress address = InetAddress.getByName("127.0.0.1");
12.             DatagramPacket packet = new DatagramPacket(buffer, buffer.length, address, 12345);
13.             socket.send(packet);
14.             socket.close();
15.         } catch (Exception e) {
16.             e.printStackTrace();
17.         }
18.     }
19. }

复制代码

接收方

1. import java.net.DatagramPacket;
2. import java.net.DatagramSocket;
4. public class UDPReceiver {
5.     public static void main(String[] args) {
6.         try {
7.             DatagramSocket socket = new DatagramSocket(12345);
8.             byte[] buffer = new byte[1024];
9.             DatagramPacket packet = new DatagramPacket(buffer, buffer.length);
10.             socket.receive(packet);
11.             String receivedMessage = new String(packet.getData(), 0, packet.getLength());
12.             System.out.println(receivedMessage);
13.             socket.close();
14.         } catch (Exception e) {
15.             e.printStackTrace();
16.         }
17.     }
18. }

复制代码

广播（Broadcast）

广播是将数据包发送到同一网络中的所有装备。发送方将数据包发送到广播所在（如255.255.255.255），所有在同一网络中的装备都能接收到该数据包。广播实用于一对多的通信场景，但会占用大量网络带宽。

1. import java.net.DatagramPacket;
2. import java.net.DatagramSocket;
3. import java.net.InetAddress;
5. public class UDPSender {
6.     public static void main(String[] args) {
7.         try {
8.             DatagramSocket socket = new DatagramSocket();
9.             socket.setBroadcast(true);
11.             String message = "Hello, Everyone!";
12.             byte[] buffer = message.getBytes();
14.             DatagramPacket packet = new DatagramPacket(buffer, buffer.length, InetAddress.getByName("255.255.255.255"), 12345);
15.             socket.send(packet);
17.             socket.close();
18.         } catch (Exception e) {
19.             e.printStackTrace();
20.         }
21.     }
22. }

复制代码

接收方代码

1. import java.net.DatagramPacket;
2. import java.net.DatagramSocket;
4. public class UDPReceiver {
5.     public static void main(String[] args) {
6.         try {
7.             DatagramSocket socket = new DatagramSocket(12345);
8.             byte[] buffer = new byte[1024];
9.             DatagramPacket packet = new DatagramPacket(buffer, buffer.length);
10.             socket.receive(packet);
11.             String receivedMessage = new String(packet.getData(), 0, packet.getLength());
12.             System.out.println(receivedMessage);
13.             socket.close();
14.         } catch (Exception e) {
15.             e.printStackTrace();
16.         }
17.     }
18. }

复制代码

组播（Multicast）

组播是将数据包发送到一组特定的装备。发送方将数据包发送到组播所在（如224.0.0.1），只有加入该组播组的装备才能接收到数据包。组播实用于一对多的通信场景，且比广播更节省网络带宽。

1. import java.net.DatagramPacket;
2. import java.net.InetAddress;
3. import java.net.MulticastSocket;
5. public class MulticastSender {
6.     public static void main(String[] args) {
7.         try {
8.             InetAddress group = InetAddress.getByName("224.0.0.1");
9.             MulticastSocket socket = new MulticastSocket();
10.             String message = "Hello, Group!";
11.             DatagramPacket packet = new DatagramPacket(message.getBytes(), message.length(), group, 12345);
12.             socket.send(packet);
13.             socket.close();
14.         } catch (Exception e) {
15.             e.printStackTrace();
16.         }
17.     }
18. }

复制代码

接收方

1. import java.net.DatagramPacket;
2. import java.net.InetAddress;
3. import java.net.MulticastSocket;
5. public class MulticastReceiver {
6.     public static void main(String[] args) {
7.         try {
8.             InetAddress group = InetAddress.getByName("224.0.0.1");
9.             MulticastSocket socket = new MulticastSocket(12345);
10.             socket.joinGroup(group);
11.             byte[] buffer = new byte[1024];
12.             DatagramPacket packet = new DatagramPacket(buffer, buffer.length);
13.             socket.receive(packet);
14.             String received = new String(packet.getData(), 0, packet.getLength());
15.             System.out.println(received);
16.             socket.leaveGroup(group);
17.             socket.close();
18.         } catch (Exception e) {
19.             e.printStackTrace();
20.         }
21.     }
22. }

复制代码

免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！更多信息从访问主页：qidao123.com:ToB企服之家，中国第一个企服评测及商务社交产业平台。