暑期JAVA学习（40.1）UDP通信——广播、组播

一、UDP的三种通信方式

●单播：单台主机与单台主机之间的通信。

●广播：当前主机与所在网络中的所有主机通信。

●组播：当前主机与选定的一组主机的通信。

二、UDP如何实现广播

●使用广播地址：255.255.255.255

●具体操作：
①发送端发送的数据包的目的地写的是广播地址、且指定端口。 （255.255.255.255 , 9999）
②本机所在网段的其他主机的程序只要注册对应端口就可以收到消息了。（9999）

/**
 发送端  多发 多收
 */
public class ClientDemo01 {
    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.println("请说：");
            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);
        }
    }
}
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31

/**
 接收端
 */
public class ServerDemo02 {
    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);
        }
    }
}
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24

三、UDP如何实现组播

●使用组播地址：224.0.0.0 ~ 239.255.255.255

●具体操作：
①发送端的数据包的目的地是组播IP (例如：224.0.1.1, 端口：9999)
②接收端必须绑定该组播IP(224.0.1.1)，端口还要注册发送端的目的端口9999 ，这样即可接收该组播消息。
③DatagramSocket的子类MulticastSocket可以在接收端绑定组播IP。

/**
 发送端  多发 多收
 */
public class ClientDemo01 {
    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.println("请说：");
            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.0") , 9999);

            // 3、发送数据出去
            socket.send(packet);
        }
    }
}
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31

/**
 接收端
 */
public class ServerDemo02 {
    public static void main(String[] args) throws Exception {
        System.out.println("=====服务端启动======");
        // 1、创建接收端对象：注册端口（人）
        MulticastSocket socket = new MulticastSocket(9999);

        //把当前接收端加入到一个组播组中去:绑定对应的组播消息的组播IP
        //socket.joinGroup(InetAddress.getByName("224.0.0.0"));//此方法过时啦
        socket.joinGroup(new InetSocketAddress(InetAddress.getByName("224.0.0.0"),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);
        }
    }
}
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29

四、总结

①如何实现广播，具体怎么操作？
发送端目的IP使用广播IP： 255.255.255.255 9999。
所在网段的其他主机对应了端口（9999）即可接收消息。

②如何实现组播，具体怎么操作？
发送端目的IP使用组播IP，且指定端口。
所在网段的其他主机注册了该组播IP和对应端口即可接收消息。