📂 Java 网络编程 - UDP 通信 - 《Java》

快速入门
多发多收
广播、组播
- UDP 实现广播

UDP 是一种无连接、不可靠传输的协议。
将数据源 IP、目的地 IP 和端口以及数据封装成数据包，大小限制在64KB内，直接发送出去即可。

快速入门

DatagramPacket：数据包对象
构造器：

public DatagramPacket(byte[] buf, int length, InetAddress address, int port)：创建发送端数据包对象
- buf：要发送的内容，字节数组
- length：要发送内容的字节长度
- address：接收端的 IP 地址对象
- port：接收端的端口号
public DatagramPacket(byte[] buf, int length)：创建接收端的数据包对象
- buf：用来存储接收的内容
- length：能够接收内容的长度

DatagramSocket：发送端和接收端对象
构造器：

DatagramSocket()：创建发送端的 Socket 对象，系统会随机分配一个端口号。
DatagramSocket(int port)：创建接收端的 Socket 对象并指定端口号

方法：

void send(DatagramPacket dp)：发送数据包

void receive(DatagramPacket p)：接收数据包

public static void main(String[] args) throws Exception {
  System.out.println("===== 服务端启动 ======");
  // 1、创建接收端对象：注册端口
  DatagramSocket socket = new DatagramSocket(8888);
  // 2、创建一个数据包对象接收数据
  byte[] buffer = new byte[1024 * 64];
  DatagramPacket packet = new DatagramPacket(buffer, buffer.length);
  // 3、等待接收数据。
  socket.receive(packet);
  // 4、取出数据即可
  // 读取多少倒出多少
  int len = packet.getLength();
  String rs = new String(buffer, 0, len);
  System.out.println("收到了：" + rs);
  // 获取发送端的ip和端口
  String ip = packet.getSocketAddress().toString();
  System.out.println("对方地址：" + ip);
  int port = packet.getPort();
  System.out.println("对方端口：" + port);
  socket.close();
}

public static void main(String[] args) throws Exception {
  System.out.println("===== 客户端启动 ======");
  // 1、创建发送端对象：发送端自带默认的端口号
  DatagramSocket socket = new DatagramSocket(6666);
  // 2、创建一个数据包对象封装数据
  /**
   * public DatagramPacket(byte buf[], int length, InetAddress address, int port)
   * 参数一：封装要发送的数据
   * 参数二：发送数据的大小
   * 参数三：服务端的主机IP地址
   * 参数四：服务端的端口
   */
  byte[] buffer = "Hello World 你好 世界".getBytes();
  DatagramPacket packet = new DatagramPacket(buffer, buffer.length,
                                             InetAddress.getLocalHost(), 8888);
  // 3、发送数据出去
  socket.send(packet);
  socket.close();
}

多发多收

public static void main(String[] args) throws Exception {
    System.out.println("===== 服务端启动 ======");
    // 1、创建接收端对象：注册端口
    DatagramSocket socket = new DatagramSocket(8888);
    // 2、创建一个数据包对象接收数据
    byte[] buffer = new byte[1024 * 64];
    DatagramPacket packet = new DatagramPacket(buffer, buffer.length);
    while (true) {
        // 3、等待接收数据。
        socket.receive(packet);
        // 4、取出数据即可
        // 读取多少倒出多少
        int len = packet.getLength();
        String rs = new String(buffer, 0, len);
        System.out.println("收到了来自：" + packet.getAddress() + ", 对方端口是" + packet.getPort() + "的消息：" + rs);
    }
}

public static void main(String[] args) throws Exception {
    System.out.println("===== 客户端启动 ======");
    // 1、创建发送端对象：发送端自带默认的端口号
    DatagramSocket socket = new DatagramSocket(7777);
    Scanner sc = new Scanner(System.in);
    while (true) {
        System.out.print("请说：");
        String msg = sc.nextLine();
        if ("exit".equals(msg)) {
            System.out.println("离线成功！");
            socket.close();
            break;
        }
        // 2、创建一个数据包对象封装数据
        byte[] buffer = msg.getBytes();
        DatagramPacket packet = new DatagramPacket(buffer, buffer.length,
                                                   InetAddress.getLocalHost(), 8888);
        // 3、发送数据出去
        socket.send(packet);
    }
}

广播、组播

单播：单台主机与单台主机之间的通信。
广播：当前主机与所在网络中的所有主机通信。
组播：当前主机与选定的一组主机的通信。

UDP 实现广播

发送端发送的数据包的目的地写的是广播地址、且指定端口。（255.255.255.255，9999）使用广播地址：255.255.255.255

本机所在网段的其他主机的程序只要注册对应端口就可以收到消息了。（9999）

public static void main(String[] args) throws Exception {
  System.out.println("===== 服务端启动 ======");
  // 1、创建接收端对象：注册端口
  DatagramSocket socket = new DatagramSocket(9999);
  // 2、创建一个数据包对象接收数据
  byte[] buffer = new byte[1024 * 64];
  DatagramPacket packet = new DatagramPacket(buffer, buffer.length);
  while (true) {
      // 3、等待接收数据。
      socket.receive(packet);
      // 4、取出数据即可
      // 读取多少倒出多少
      int len = packet.getLength();
      String rs = new String(buffer, 0, len);
      System.out.println("收到了来自：" + packet.getAddress() + ", 对方端口是" + packet.getPort() + "的消息：" + rs);
  }
}

```java public static void main(String[] args) throws Exception { System.out.println(“===== 客户端启动 ======”);

// 1、创建发送端对象：发送端自带默认的端口号 DatagramSocket socket = new DatagramSocket(7777);

Scanner sc = new Scanner(System.in);
while (true) {
    System.out.print("请说：");
    String msg = sc.nextLine();

    if ("exit".equals(msg)) {
        System.out.println("离线成功！");
        socket.close();
        break;
    }

    // 2、创建一个数据包对象封装数据
    byte[] buffer = msg.getBytes();
    DatagramPacket packet = new DatagramPacket(buffer, buffer.length,
                                               InetAddress.getByName("255.255.255.255"), 9999);

    // 3、发送数据出去
    socket.send(packet);
}

}


<a name="LS08R"></a>
### UDP 实现组播

- 发送端的数据包的目的地是组播 IP（例如：224.0.1.1,  端口：9999），组播地址：224.0.0.0 ~ 239.255.255.255
- 接收端必须绑定该组播 IP（224.0.1.1），端口还要注册发送端的目的端口 9999，这样即可接收该组播消息。
- DatagramSocket 的子类 MulticastSocket 可以在接收端绑定组播 IP。
```java
public static void main(String[] args) throws Exception {
    System.out.println("===== 服务端启动 ======");
    // 1、创建接收端对象：注册端口
    MulticastSocket socket = new MulticastSocket(9999);

    // 把当前接受端加入到一个组播组中
    // socket.joinGroup(InetAddress.getByName("224.0.0.1")); // Java 14 后过时
    socket.joinGroup(new InetSocketAddress(InetAddress.getByName("224.0.0.1"), 9999),
                     NetworkInterface.getByInetAddress(InetAddress.getLocalHost()));


    // 2、创建一个数据包对象接收数据
    byte[] buffer = new byte[1024 * 64];
    DatagramPacket packet = new DatagramPacket(buffer, buffer.length);

    while (true) {
        // 3、等待接收数据。
        socket.receive(packet);
        // 4、取出数据即可
        // 读取多少倒出多少
        int len = packet.getLength();
        String rs = new String(buffer, 0, len);
        System.out.println("收到了来自：" + packet.getAddress() + ", 对方端口是" + packet.getPort() + "的消息：" + rs);
    }
}

public static void main(String[] args) throws Exception {
    System.out.println("===== 客户端启动 ======");

    // 1、创建发送端对象：发送端自带默认的端口号
    DatagramSocket socket = new DatagramSocket(7777);


    Scanner sc = new Scanner(System.in);
    while (true) {
        System.out.print("请说：");
        String msg = sc.nextLine();

        if ("exit".equals(msg)) {
            System.out.println("离线成功！");
            socket.close();
            break;
        }

        // 2、创建一个数据包对象封装数据
        byte[] buffer = msg.getBytes();
        DatagramPacket packet = new DatagramPacket(buffer, buffer.length,
                                                   InetAddress.getByName("224.0.0.1"), 9999);

        // 3、发送数据出去
        socket.send(packet);
    }
}