下面是一个简单的UDP Socket通信的例子，使用到了多线程
UDP协议的特点:无连接、不可靠、无序，所以是有可能出现丢包的情况的。
过程如下：
服务器端
- 创建DatagramSocket,指定端口号
- 创建DatagramPacket
- 接收客户端发送的数据信息
- 读取数据
客户端
- 定义发送信息
- 创建DatagramPacket，包含将要发送的信息
- 创建DatagramSocket，发送数据
- 发送数据
服务器端
/**
* 服務器端，基于UDP的用戶登錄
* @author Jian
*
*/
public class UDPServer {
public static void main(String[] args) throws IOException {
//1.創建服務器端DatagramSocket，指定端口
DatagramSocket socket = new DatagramSocket(8800);
//2.創建數據包，用於接收客戶端發送的數據
byte[] data = new byte[1024];
DatagramPacket packet = new DatagramPacket(data, data.length);
//3.接收客戶端發送的數據
System.out.println("------服務器端已啟動，等待客戶端數據-------");
//循环监听
while(true){
socket.receive(packet);//此方法在接收到數據包之前會一直阻塞
//开启一个线程来与客户端通信
UDPServerThread thread = new UDPServerThread(data,socket, packet);
thread.start();
}
//4.關閉資源
// socket.close();
}
}测试时请先开启Server端，再开启Client端
客户端
/**
* 客戶端
* @author Jian
*
*/
public class UDPClient {
public static void main(String[] args) throws IOException {
/*
* 向服務器端發送
*/
//1.定義服務器地址，端口號，數據包
InetAddress address = InetAddress.getByName("127.0.0.1");
int port = 8800;
byte[] data = "用戶名:Jian;密碼:123".getBytes();
//2.創建數據包，包含發送的信息
DatagramPacket packet = new DatagramPacket(data, data.length, address, port);
//3.創建DatagramSocket對象
DatagramSocket socket = new DatagramSocket();
//4.向服務器端發送數據包
socket.send(packet);
System.out.println("客户端正在发送数据给服务器");
/*
* 接收服務器端數據
*/
//1.創建數據包，用於接收響應數據
byte[] data2 = new byte[1024];
DatagramPacket packet2 = new DatagramPacket(data2, data2.length);
//2.接收數據
socket.receive(packet2);
//3.讀取數據
String reply = new String(data2);
System.out.println("客户端开始接收数据");
System.out.println("客戶端收到服務器的回應"+reply);
//4.關閉資源
socket.close();
}
}与客户端交互的线程类
/**
* 相关线程类
* @author Jian
*/
public class UDPServerThread extends Thread{
DatagramSocket socket = null;
DatagramPacket packet = null;
byte[] data = null;
public UDPServerThread(byte[] data,DatagramSocket socket,DatagramPacket packet) {
this.socket = socket;
this.packet = packet;interrupt();
this.data = data;
}
//线程要执行的方法
public void run(){
//4.讀取數據
System.out.println("线程启动");
String info = new String(data);
System.out.println("服務器收到客戶端的信息："+info);
/*
* 向客戶端回應
*/
//1.定義客戶端地址、端口號、數據
InetAddress address = packet.getAddress();
int port = packet.getPort();
byte[] data2 = "Welcome！".getBytes();
//2創建數據包，包含回應信息
DatagramPacket packet2 = new DatagramPacket(data2, data2.length, address, port);
//3.响应客戶端
try {
socket.send(packet2);
System.out.println("服务器端数据发送完毕");
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}finally{
}
}
}