背景

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

实现

发送数据

package itheima1;

import java.io.IOException;
import java.net.*;
import java.nio.charset.StandardCharsets;

/*
    UDP发送数据的步骤：
        1、创建发送端的Socket对象（DatagramSocket）
        2、创建数据，并把数据打包
        3、调用DatagramSocket对象的方法发送数据
        4、关闭发送端
 */
public class SendDemo {
    public static void main(String[] args) throws IOException {
        //创建发送端的Socket对象（DatagramSocket）
        //DatagramSocket()构造数据报套接字并将其绑定在本地主机上的任何可用端口
        DatagramSocket ds = new DatagramSocket();

        //创建数据，并把数据打包
        //DatagramSocket(byte[] buf, int length, InetAddress address, int port) 构造一个数据包，发送长度为length的数据包到指定主机上的指定端口号
        byte[] bys = "Hello,World! Java".getBytes();
        int length  = bys.length;
        InetAddress address = InetAddress.getByName("HostNameOrIp");
        int port = 10086; //目标主机的任意端口号
        DatagramPacket dp = new DatagramPacket(bys, length, address, port);

        //调用DatagramSocket对象的方法发送数据
        ds.send(dp);

        //关闭数据端
        ds.close();
    }
}

接收数据

package itheima1;

import javax.xml.crypto.Data;
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)
        DatagramSocket ds = new DatagramSocket(10086); //对应发送数据代码块的目标端口

        //创建一个数据包，用于接收数据
        //DatagramPacket(byte[] buf, int length)构造一个DatagramPacket用于接收长度为length的数据包
        byte[] bys = new byte[1024];
        DatagramPacket dp = new DatagramPacket(bys,bys.length);

        //调用DatagramSocket对象的方法接收数据
        ds.receive(dp);

        //解析数据包，并把数据在控制台显示
        //byte[] getData() 返回数据缓冲区
        byte[] datas = dp.getData();
        //int getLength() 返回要发送的数据的长度或接收到的数据的长度，避免输出空字符
        int len = dp.getLength();
        String datastring = new String(datas, 0, len);
        System.out.println("数据是：" + datastring);

        //关闭接收端
        ds.close();
    }
}