如何用Java实现简单Socket通信 Java客户端服务器通信示例

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

public class SimpleServer {
    public static void main(String[] args) {
        int port = 8080; // 服务器监听的端口

        try (ServerSocket serverSocket = new ServerSocket(port)) {
            System.out.println("服务器已启动，正在监听端口 " + port + "...");

            // 服务器会一直等待客户端连接
            while (true) {
                Socket clientSocket = serverSocket.accept(); // 阻塞，直到有客户端连接
                System.out.println("客户端已连接: " + clientSocket.getInetAddress().getHostAddress());

                // 为每个客户端连接创建一个新的线程处理，避免阻塞其他连接
                new Thread(() -> {
                    try (
                        // 获取输入流，用于读取客户端发送的数据
                        BufferedReader in = new BufferedReader(new InputStreamReader(clientSocket.getInputStream()));
                        // 获取输出流，用于向客户端发送数据
                        PrintWriter out = new PrintWriter(clientSocket.getOutputStream(), true) // true表示自动刷新
                    ) {
                        String inputLine;
                        while ((inputLine = in.readLine()) != null) { // 阻塞，直到客户端发送一行数据
                            System.out.println("收到客户端消息: " + inputLine);
                            out.println("服务器收到你的消息: " + inputLine); // 回复客户端
                            if ("bye".equalsIgnoreCase(inputLine)) {
                                break; // 如果客户端发送"bye"，则结束当前连接
                            }
                        }
                    } catch (IOException e) {
                        System.err.println("处理客户端连接时发生错误: " + e.getMessage());
                    } finally {
                        try {
                            clientSocket.close(); // 关闭客户端连接
                            System.out.println("客户端连接已关闭: " + clientSocket.getInetAddress().getHostAddress());
                        } catch (IOException e) {
                            System.err.println("关闭客户端Socket时发生错误: " + e.getMessage());
                        }
                    }
                }).start();
            }
        } catch (IOException e) {
            System.err.println("服务器启动或运行失败: " + e.getMessage());
        }
    }
}

import java.io.*;
import java.net.*;
import java.util.Scanner;

public class SimpleClient {
    public static void main(String[] args) {
        String serverAddress = "127.0.0.1"; // 服务器地址，这里是本机
        int port = 8080; // 服务器端口

        try (
            Socket socket = new Socket(serverAddress, port); // 尝试连接服务器
            PrintWriter out = new PrintWriter(socket.getOutputStream(), true); // 输出流
            BufferedReader in = new BufferedReader(new InputStreamReader(socket.getInputStream())); // 输入流
            Scanner scanner = new Scanner(System.in) // 用于读取用户输入
        ) {
            System.out.println("已连接到服务器: " + serverAddress + ":" + port);
            String userInput;
            String serverResponse;

            while (true) {
                System.out.print("请输入消息 (输入'bye'退出): ");
                userInput = scanner.nextLine(); // 读取用户输入

                out.println(userInput); // 发送消息给服务器

                if ("bye".equalsIgnoreCase(userInput)) {
                    break; // 如果用户输入"bye"，则退出
                }

                serverResponse = in.readLine(); // 阻塞，直到收到服务器回复
                System.out.println("服务器回复: " + serverResponse);
            }
        } catch (UnknownHostException e) {
            System.err.println("无法找到服务器: " + serverAddress);
        } catch (IOException e) {
            System.err.println("连接服务器或通信时发生错误: " + e.getMessage());
        } finally {
            System.out.println("客户端已退出。");
        }
    }
}