服务器端
package demo5;import java.io.IOException;import java.net.DatagramPacket;import java.net.DatagramSocket;import java.net.InetAddress;/** * 服务器端，实现基于UDP的用户登录 *@ClassName UDPServer *@Author DiYun *@Version 1.0 **/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); System.out.println("服务端已启动等待客户端发送数据**********************"); //3.接收客户端发送的数据 socket.receive(packet); //此方法在接收到数据包之前会一直阻塞 //4.读取数据 String info = new String(data, 0, packet.getLength()); System.out.println("我是服务器，客户端说：" + info); /** * 向客户端响应数据 */ InetAddress address = packet.getAddress(); int port = packet.getPort(); byte[] data2 = "欢迎您".getBytes(); //2.创建数据包，包含响应的数据信息 DatagramPacket packet2 = new DatagramPacket(data2, data2.length, address, port); //3.响应客户端 socket.send(packet2); //关闭资源 socket.close(); }}
客户端
package demo5;/** * @author ydy * Create By ydy on 2019/1/24 */import java.io.IOException;import java.net.*;/** * 基于UDP 客户端 *@ClassName UDPClient *@Description TODO *@Author DiYun *@Date 2019/1/24 20:01 *@Version 1.0 **/public class UDPClient { public static void main(String[] args) throws IOException { //1.定义服务器的地址,端口号，数据 InetAddress address = InetAddress.getByName("localhost"); int potr = 8800; byte[] data = "用户名：admin; 密码： 123".getBytes(); //2.创建数据包，包含发送的数据信息 DatagramPacket packet = new DatagramPacket(data, data.length, address, potr); //3.创建DatagramSocket对象 DatagramSocket socket = new DatagramSocket(); //4.向服务端发送数据包 socket.send(packet); /** * 接收服务器端响应的数据 */ //1.创建数据包，用于接收服务器端响应的数据 byte[] data2 = new byte[1024]; DatagramPacket packet2 = new DatagramPacket(data2, data2.length); //2.接收服务器响应的数据 socket.receive(packet2); //3.读取数据 String reply = new String(data2, 0, packet2.getLength()); System.out.println("我是客户端，服务器说: " + reply); //4.关闭资源 socket.close(); }}
注意：必须首先启动服务器，再启动客户端