UDP通信

1、UDP概述

UDP(User Datagram Protocol)：用户数据报协议，是一种面向无连接的协议，在通信时发送端和接收端不用建立连接。

2、DatagramPacket

DatagramPacket用于封装数据，在接收端和发送端的DatagramPacket方法有所不同，接收端的构造方法只需要接受一个字节数组来存放接收到的数据，而发送端的构造方法不但要接受发送数据要存放的字节数组，还需要指定发送端IP地址和端口号。

接收端构造方法：

DatagramPacket(byte[] buf, int length)：构造DatagramPacket，用来接受长度为length的数据包。

发送端构造方法：

DatagramPacket(byte[] buf, int length, InteAddress address, int port)：构造数据包，用来将长度为length的包发送到指定主机上的指定端口号。

常用方法：

• InetAddress getAddress()：返回某台机器的IP地址，此数据报将要发往该机器或者是从该机器接收到的。
• int getPort()：返回某台远程主机的端口号，此数据报将要发往该主机或者是从该主机接受到的。
• getData()：返回数据缓冲区。
• int getLength()：返回将要发送或接收到的数据的长度。

3、DatagramSocket

DatagramSocket类的常用构造方法：

• DatagramSocket()：构造数据报套接字并将其绑定到本地主机上的任何可用的端口。
• DatagramSocket()：构造数据报套接字并将其绑定到本地主机上的指定端口。

常用方法：

• void receive(DatagramPacket p)：从此套接字接收数据报包。
• void send(DatagramPacket p)：从此套接字发送数据报包。

4、UDP网络程序

UDP接收端

package udp;

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

/**
 * <p>Description:UDP接收端 </p>
 * @author Administrator
 * @date 2018年11月6日下午3:17:01
 */
public class UDPReceive {

    public static void main(String[] args) throws IOException {
        // 创建DatagramSocket对象，并指定端口号
        DatagramSocket ds = new DatagramSocket(6000);
        // 创建一个空仓库
        byte[] buffer = new byte[1024];
        // 创建DatagramPacket对象
        DatagramPacket dp = new DatagramPacket(buffer, 1024);
        // 接受数据
        ds.receive(dp);
        // 获取DatagramPacket对象内容
        InetAddress ipAddress = dp.getAddress();
        String ip = ipAddress.getHostAddress();
        // 解析数据
        byte[] data = dp.getData();
        int length = dp.getLength();
        // 显示接受到的数据
        String dataStr = new String(data, 0, length);
        System.out.println("ip地址：" + ip + "数据是：" + dataStr);
        // 释放资源
        ds.close();
    }

}

UDP发送端

package udp;

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

/**
 * <p>Description:UDP发送端 </p>
 * @author Administrator
 * @date 2018年11月6日下午3:07:53
 */
public class UDPSend {

    public static void main(String[] args) throws IOException {
        // 创建DatagramSocket对象
        DatagramSocket ds = new DatagramSocket();
        // 构造数据报包，用来将长度为length的包发送到指定主机的指定端口号上
        byte[] buffer = "hello,UDP".getBytes();
        // 创建InetAddress对象，封装自己的IP地址
        InetAddress inet = InetAddress.getByName("127.0.0.1");
        // 创建DatagramPacket对象
        DatagramPacket dp = new DatagramPacket(buffer, buffer.length, inet, 6000);
        // 发送数据
        ds.send(dp);
        // 释放资源
        ds.close();
    }

}