UDP编程

什么是UDP？

和TCP编程相比，UDP编程就简单得多，因为UDP没有创建连接，数据包也是一次收发一个，所以没有流的概念。
在Java中使用UDP编程，仍然需要使用Socket，因为应用程序在使用UDP时必须指定网络接口（IP地址）和端口号。注意：UDP端口和TCP端口虽然都使用0~65535，但他们是两套独立的端口，即一个应用程序用TCP协议占用了端口1234，不影响另一个应用程序用UDP协议占用端口1234。
 

(1)UDP服务器端

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

// 注册中心(服务器端)
public class Main {
	public static void main(String[] args) {
		// 基于UDP协议的服务器端Socket，监听6666端口
		try (DatagramSocket socket = new DatagramSocket(6666)) {
			
			// 创建一个空的数据包，用于接收数据
			DatagramPacket packet = new DatagramPacket(new byte[1024], 1024);
			
			
			// 接收客户端发送的数据包(未发送前，处于阻塞等待状态)
			socket.receive(packet);
			
			String userName = new String(packet.getData(),packet.getOffset(),packet.getLength());
			System.out.println("用户名：" + userName);
			
			// 年龄
			socket.receive(packet);
			String age = new String(packet.getData(),packet.getOffset(),packet.getLength());
			System.out.println("年龄:" + age);
			
			// 身份
			socket.receive(packet);
			String role = new String(packet.getData(),packet.getOffset(),packet.getLength());
			System.out.println("角色:" + role);
			
			// 服务器端向客户端反馈信息
			packet.setData("哎呦，不错哦，注册成功了哦!".getBytes());
			socket.send(packet);
			
		} catch (SocketException e) {
			e.printStackTrace();
		} catch (IOException e) {
			e.printStackTrace();
		}
	}
}

(2)UDP客户端

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

// 注册客户端
public class Main {
	public static void main(String[] args) {
		
		// 基于UDP协议的客户器端Socket
		try (DatagramSocket socket = new DatagramSocket()) {
			
			// 设置进行“连接”的服务器地址和端口
			socket.connect(InetAddress.getByName("192.168.254.103"), 6666);
			
			// 创建数据包
			DatagramPacket packet = new DatagramPacket(new byte[1024], 1024);
			
			// 设置数据包的数据内容(字节数组)
			packet.setData("张三丰".getBytes());
			// 发送数据包
			socket.send(packet);
			
			packet.setData("60岁".getBytes());
			socket.send(packet);
			
			packet.setData("武当派掌门".getBytes());
			socket.send(packet);
			
			// 接收来自服务器端的反馈消息
			packet = new DatagramPacket(new byte[1024], 1024);
			socket.receive(packet);
			String message = new String(packet.getData(),packet.getOffset(),packet.getLength());
			System.out.println("来自服务器端的反馈消息:" + message);
			
		} catch (SocketException e) {
			e.printStackTrace();
		} catch (UnknownHostException e) {
			e.printStackTrace();
		} catch (IOException e) {
			e.printStackTrace();
		}
		
	}
}