SpringBoot项目加入冲突动态监测算法的实现

// 客户端代码  
public class Client {  
    public static void main(String[] args) throws Exception {  
        Socket socket = new Socket("localhost", 8888);  
        BufferedOutputStream out = new BufferedOutputStream(socket.getOutputStream());  
        PrintWriter writer = new PrintWriter(out);  
        Random random = new Random();  
        while (true) {  
            String message = String.valueOf(random.nextInt(100));  
            writer.println("发送数据：" + message);  
            writer.flush();  
            System.out.println("客户端发送数据：" + message);  
            socket.setSoTimeout(1000);  
            BufferedReader reader = new BufferedReader(new InputStreamReader(socket.getInputStream()));  
            String response = reader.readLine();  
            if ("接收数据：" + message.trim() + "\n".equals(response)) {  
                System.out.println("服务器已接收数据：" + message);  
            } else {  
                System.out.println("发生冲突，重新发送数据：" + message);  
                writer.println("发送请求：" + message);  
                writer.flush();  
                socket.setSoTimeout(5000);  
                response = reader.readLine();  
                if ("接收请求：" + message.trim() + "\n".equals(response)) {  
                    System.out.println("服务器已接收请求：" + message);  
                } else {  
                    System.out.println("连接异常，退出程序");  
                    break;  
                }  
            }  
        }  
        writer.close();  
        out.close();  
        socket.close();  
    }  
}

// 服务器端代码  
public class Server {  
    public static void main(String[] args) throws Exception {  
        ServerSocket serverSocket = new ServerSocket(8888);  
        while (true) {  
            Socket socket = serverSocket.accept();  
            BufferedReader reader = new BufferedReader(new InputStreamReader(socket.getInputStream()));  
            String line = reader.readLine();  
            if (line.startsWith("发送数据：")) {  
                String message = line.substring(9).trim();  
                System.out.println("服务器接收数据：" + message);  
                PrintWriter writer = new PrintWriter(new BufferedOutputStream(socket.getOutputStream()));  
                writer.println("接收数据：" + message);  
                writer.flush();  
            } else if (line.startsWith("发送请求：")) {  
                String message = line.substring(9).trim();  
                System.out.println("服务器接收请求：" + message);  
                PrintWriter writer = new PrintWriter(new BufferedOutputStream(socket.getOutputStream()));  
                writer.println("接收请求：" + message);  
                writer.flush();  
            } else {  
                System.out.println("连接异常，关闭连接");  
                socket.close();  
            }  
        }  
    }  
}