Java学习之路（六十一）| TDP网络编程

各自努力，最高处见！加油！

• 一、UDP通信的简介
• 二、基本流程
• 三、UDP编程

1. 类DatagramSocket和DatagramPacket（数据包/数据报）实现了基于UDP协议网络程序。
2. UDP数据报通过数据报套接字DatagramSocket发送和接收，系统不保证UDP数据报一定能够安全送到目的地，也不能确定什么时候可以抵达。
3. DatagramPacket对象封装了UDP数据报，在数据报中包含了发送端IP地址和端口号以及接收端的IP地址和端口号。
4. UDP协议中每个数据报都给出类完整的信息地址，因此无需建立发送方和接收方的链接。

1. 核心的两个类/对象DatagramSocket与DatagramPacket
2. DatagramSocket建立发送端、接收端
3. 发送数据前，建立数据包
4. 调用DatagramPacket的发送、接收方法
5. 关闭DatagramSocket

关于UDP的一些说明

1. 没有明确的服务端和客户端，演变成数据的发送端和接收端
2. 接收数据和发送数据是通过DatagramSocket对象完成
3. 将数据封装到DatagramPacket对象/包
4. 当接收到DatagramPacket对象，需要进行拆包，取出数据
5. DatagramSocket可以指定在那个端口接收数据

A方代码

import java.io.IOException;
import java.net.DatagramPacket;
import java.net.DatagramSocket;
import java.net.InetAddress;
import java.net.SocketException;

public class UDPReceiverA {
    public static void main(String[] args) throws IOException {
        //1、创建一个DatagramSocket对象，准备在9999接收数据
        DatagramSocket socket=new DatagramSocket(9999);
        //2、构建一个DatagramPacket对象，准备接收数据
        byte[] buf=new byte[64*1024];//一个UDP数据包最大为64K
        DatagramPacket packet=new DatagramPacket(buf,buf.length);

        //3、调用接收方法,，将通过网络传输的DatagramPacket对象填充到packet对象
        //当有数据报发送到本机的9999端口时，就会接收到数据，否则就会阻塞等待。
        socket.receive(packet);

        //把packet进行拆包，取出数据报，并显示
        int length=packet.getLength();
        byte[] data = packet.getData();
        String s=new String(data,0,length);
        System.out.println(s);

        byte[] dataSend="A端：好的，明天见".getBytes();
        DatagramPacket packet1 = new DatagramPacket(dataSend, dataSend.length, InetAddress.getByName("192.168.244.1"), 9998);
        socket.send(packet1);
        System.out.println("A端回复已发送！");

        socket.close();
    }
}

B方代码：

import java.io.IOException;
import java.net.*;
import java.security.spec.RSAOtherPrimeInfo;

public class UDPSenderB {
    public static void main(String[] args) throws IOException {
        //1、创建一个DatagramSocket对象，准备在9998上发送数据
        DatagramSocket socket = new DatagramSocket(9998);//在9998上发送数据

        //2、将需要发送的数据封装到DatagramPacket对象
        byte[] data="hello 明天吃火锅".getBytes();
        DatagramPacket packet = new DatagramPacket(data, data.length,
                InetAddress.getByName("192.168.244.1"), 9999);
        //3、发送
        socket.send(packet);
        System.out.println("B端：数据发送完毕");

        //接收A端发送的信息
        byte[] dataRecever=new byte[64*1024];
        DatagramPacket packet1 = new DatagramPacket(dataRecever, dataRecever.length);
        socket.receive(packet1);
        int length=packet1.getLength();
        byte[] data1 = packet1.getData();
        String s = new String(data1, 0, length);
        System.out.println(s);
        System.out.println("信息接收完毕，关闭B程序！");

        socket.close();

    }
}