Java 模拟基于UDP的Socket通信

效果图：

多线程服务器

客户端

单线程服务器

多线程服务器

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

public class UDPMutiThreadServer implements Runnable {
    DatagramPacket datagramPacket;  //数据报包
    byte[] data1;  //存放数据的变量
 

    public UDPMutiThreadServer(DatagramPacket datagramPacket,byte[] data1) {
        this.datagramPacket = datagramPacket;
        this.data1=data1;
    }

    public static void main(String[] args) throws SocketException {
        int count=0; //用于统计客户端数量
        DatagramSocket datagramSocket = new DatagramSocket(1234);

        System.out.println("```````服务器已经启动，等待客户端发送数据｀｀｀｀｀｀｀｀");


        while (true) {
            /**
             * 创建数据报包，用于保存收发的数据，需要定义数据包的大小和长度
             */
            byte[] data = new byte[1024];
            DatagramPacket datagramPacket = new DatagramPacket(data,data.length);
            try {
                datagramSocket.receive(datagramPacket);
            } catch (IOException e) {
                e.printStackTrace();
            }
            if (datagramPacket.getLength() > 0) {
                new Thread(new UDPMutiThreadServer(datagramPacket,data)).start();
                count++;
                System.out.println("客户端的数量为：" + count);
            }

        }
    }

    @Override
    public void run() {

//        byte[] data=new byte[1024];
        String info = new String(data1,0,datagramPacket.getLength());
        System.out.println("我是服务器，客户端发送的信息是："+ info);

        /**
         * 响应客户端数据
         *
         * 从接收的数据包中获取客户端的地址和端口
         */
        InetAddress address = datagramPacket.getAddress();
        int port = datagramPacket.getPort();
        //定义响应数据
        byte[] data2 = "服务器已经收到你的信息，谢谢！".getBytes();

        //用DatagramPacket把要发送的数据进行打包
        DatagramPacket datagramPacket1 = new DatagramPacket(data2,data2.length,address,port);

        //用datagramSocket把数据包发送给客户端
        try {
            DatagramSocket datagramSocket= new DatagramSocket();
            datagramSocket.send(datagramPacket1);
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
}

客户端

import java.io.IOException;
import java.net.*;

public class UDPClient {
    public static void main(String[] args) throws IOException {
        /**
         * 向服务器发送数据
         *
         * 定义服务器地址，端口号和数据
         */
        InetAddress address = InetAddress.getByName("localhost");
        int port=1234;
        byte[] data ="我是：admin123，密码：123456546".getBytes();
        /**
         * 定义一个DatagramPacket，把要发送的数据时行打包
         */
        DatagramPacket datagramPacket = new DatagramPacket(data,data.length,address,port);
        /**
         * 定义一个DatagramSocket，用于发送和接收数据
         */
        DatagramSocket datagramSocket = new DatagramSocket();
        datagramSocket.send(datagramPacket);

        /**
         * 接收服务器发送的数据
         */
        //定义数据包的容量
        byte[] daaa= new byte[1024];
        DatagramPacket datagramPacket1 = new DatagramPacket(daaa,daaa.length);

        //用DatagramSocket接收数据
        datagramSocket.receive(datagramPacket1);

        //读取数据包的内容
        String info = new String(daaa,0,datagramPacket1.getLength());
        System.out.println("我是客户端，你说："+info);

        datagramSocket.close();
    }
}

单线程服务器

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

public class UDPServer {
    public static void main(String[] args) throws IOException {

        /**
         * 接收客户端数据
         *
         * 创建服务器端的Socket，用于收发数据，需要指定端口
         */
        DatagramSocket datagramSocket = new DatagramSocket(1234);

        /**
         * 创建数据报包，用于保存收发的数据，需要定义数据包的大小和长度
         */
        byte[] data = new byte[1024];
        DatagramPacket datagramPacket = new DatagramPacket(data,data.length);

        System.out.println("```````服务器已经启动，等待客户端发送数据｀｀｀｀｀｀｀｀");
        /**
         * 用Socket收取从客户端发来的数据，并保存在Packet数据报包中
         */
        datagramSocket.receive(datagramPacket);
        String info = new String(data,0,datagramPacket.getLength());
        System.out.println("我是服务器，客户端发送的信息是："+ info);

        /**
         * 响应客户端数据
         *
         * 从接收的数据包中获取客户端的地址和端口
         */
        InetAddress address = datagramPacket.getAddress();
        int port = datagramPacket.getPort();
        //定义响应数据
        byte[] data2 = "服务器已经收到你的信息，谢谢！".getBytes();

        //用DatagramPacket把要发送的数据进行打包
        DatagramPacket datagramPacket1 = new DatagramPacket(data2,data2.length,address,port);

        //用datagramSocket把数据包发送给客户端
        datagramSocket.send(datagramPacket1);

    }
}