UDP协议发送/接收数据实现

package upd;

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

/*
    UDP发送数据的步骤：
        1、创建发送端的Socket对象（DatagramSocket）
        2、创建数据，并把数据打包
        3、调用DatagramSocket对象的方法发送数据
        4、关闭发送端
 */
public class SendDemo {
    public static void main(String[] args) throws IOException {
        // 创建客户端socket对象
        DatagramSocket ds = new DatagramSocket();
        byte[] bys = "test up".getBytes();
        int length = bys.length;
        InetAddress address = InetAddress.getByName("192.168.31.162");
        int port = 9001;
        // 创建数据，并打包数据
        DatagramPacket dp = new DatagramPacket(bys, length, address, port);
        // 调用DatagramSocket对象方法发送数据
        ds.send(dp);
        // 关闭发送端
        ds.close();
    }
}

package upd;

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

/*
    UDP接收数据的步骤：
        1、创建接收端的Socket对象（DatagramSocket）
        2、创建一个数据包，用于接收数据
        3、调用DatagramSocket对象的方法接收数据
        4、解析数据包，并把数据在控制台显示
        5、关闭接收端
 */
public class ReceiveDemo {
    public static void main(String[] args) throws IOException {
        // 创建服务端接收socket对象
        DatagramSocket ds = new DatagramSocket(9001);
        // 创建数据包用于接收数据
        byte[] bytes = new byte[1024];
        DatagramPacket dp = new DatagramPacket(bytes, bytes.length);
        // 调用DatagramSocket对象的方法接收数据
        ds.receive(dp);
        // 解析数据包，并把数据在控制台显示
        byte[] datas = dp.getData();
        int len = dp.getLength();
        String data = new String(datas, 0, len);
        System.out.println("服务端接收到数据 " + data);
        // 关闭接收端
        ds.close();
    }
}