Java 基于 UDP 实现 Socket中的多客户端通信

这里原理同 TCP/IP 实现多客户端通信的原理是一样的，同样的 UDPClient.java 不变，与上一篇文章中描述的一致，无需修改

UDPServer.java

package com.learn;

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

/*
* 实现基于UDP的用户登录
*/
public class UDPServer {
public static void main(String[] args) {

try {
/*
* 接收客户端发送的数据
*/
// 1.创建服务器端 datagramsocket
DatagramSocket server = new DatagramSocket(8888);
// 2.接收客户端发送的数据
System.out.println("***服务器端已启动，等待客户端上线***");

while (true) {
UDPServerThread st = new UDPServerThread(server);
st.start();
}

} catch (SocketException e) {
// TODO Auto-generated catch block
e.printStackTrace();
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
}

UDPServerThread.java

package com.learn;

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

public class UDPServerThread extends Thread {
DatagramSocket socket;

public UDPServerThread(DatagramSocket socket) {
this.socket = socket;
}

public void run() {
// 创建数据报，用于接收客户端发送的数据
byte[] bytes = new byte[1024];
DatagramPacket packet = new DatagramPacket(bytes, bytes.length);

try {
socket.receive(packet);// 此方法会在接收到数据之前一直阻塞
// 读取数据
String info = new String(bytes, 0, packet.getLength());
System.out.println("我是服务器，客户端发来数据说：" + info);

/*
* 响应客户端发来的消息
*/

// 1.定义客户端的地址，端口号，数据
InetAddress address = packet.getAddress();
int port = packet.getPort();
byte[] data = "欢迎上线".getBytes();
// 2.创建数据报，包含响应的数据信息
packet = new DatagramPacket(data, data.length, address, port);
// 3.响应客户端，发送数据
socket.send(packet);
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}

}
}

同样，需要注意的是需要先启动 Server 端，再启动 Client 端