java实现udp发送端和接收端

 发送端：

package demo02;

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

/*
 * 实现UDP协议的发送端：
 *     实现封装数据的类 java.net.DatagramPacket 将你的数据包装    
 *     实现数据传输类    java.net.DatagramSocket 将数据包发出去
 *    
 *    实现步骤：
 *        1.创建DatagramPacket对象，封装数据，接收的地址和端口
 *        2.创建DatagramSocket对象，
 *        3.调用DatagramSocket类的方法send，发送数据包
 *        4.关闭资源
 *
 *    DatagramPacket构造方法：
 *        DatagramPacket(byte[] buf,int length,InetAddress address,int port)
 *        
 *    DatagramSocket构造方法：
 *        DatagramSocket()空参数
 *        方法：send(DatagramPacket d)
 *
 *
 */
public class UDPSend {
    public static void main(String[] args) throws IOException {
        //创建数据包对象，封装要发送的数据，接受端IP,端口
        byte[] data="你好UDP".getBytes();
        //创建InetAddress对象，封装自己的IP地址
        InetAddress inet=InetAddress.getByName("127.0.0.1");
        DatagramPacket dp=new DatagramPacket(data,data.length,inet,6000);
        //创建DatagramSocket对象，数据包的发送和接受对象
        DatagramSocket ds=new DatagramSocket();
        //调用ds对象的方法send，发送数据包
        ds.send(dp);
        ds.close();
                                
    }
}

 接收端

package demo01;

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

/*
 *     实现UDP接收端
 *         实现封装数据包java.net.DatagramPacket 将数据接收
 *         实现输出传输    java.net.DatagramSocket 接受数据包
 *         
 *     实现步骤：
 *         1.创建DatagramSocket对象，绑定端口号
 *               要和发送数据端口号一致
 *         2.创建字节数组，接受发来的数组
 *         3.创建数据包对象DatagramPacket
 *         4.调用DatagramSocket对象方法 receive(DatagramPacket dp)
 *               接受数据，数据放在数据包中
 *         5.拆包
 *                 发送的IP地址
 *                  数据包对象DatagramPacket()方法getAddress()获取的是发送端的IP地址对象
 *                 接受到的字节个数
 *                  数据包对象DatagramPacket()方法getLength()
 *                 发送方的端口号
 *              数据包对象DatagramPacket()方法getPort()
 *         6.关闭资源
 */
public class UDPReceive {
    public static void main(String[] args) throws IOException {
        //创建数据包传输对象DatagramSocket 绑定端口号
        DatagramSocket ds=new DatagramSocket(6000);
        //创建字节数组
        byte[] data=new byte[1024];
        //创建数据包对象，传递字节数组
        DatagramPacket dp=new DatagramPacket(data, data.length);
        //调用ds对象的方法receive传递数据包
        ds.receive(dp);
        
        //获取发送端的IP地址对象
        String ip=dp.getAddress().getHostAddress();
        
        //获取发送的端口号
        int port=dp.getPort();
        
        //获取接收到的字节数
        int length=dp.getLength();    
        System.out.println(new String(data,0,length)+"...."+ip+":"+port);
        ds.close();
                
    }
}