Java基于UDP 实现 Socket中的多客户端通信:Java基于UDP 怎么实现 Socket中的多客户端通信呢?希望下面的文章对大家有所帮助。
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(); } } }
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(); } } }