// 步驟1：創(chuàng)建ServerSocket，綁定端口8080
ServerSocket serverSocket = new ServerSocket(8080);
System.out.println("服務(wù)端啟動(dòng)，等待連接...");
// 步驟2：等待客戶端連接（阻塞方法，直到有客戶端連接）
Socket clientSocket = serverSocket.accept(); 
System.out.println("客戶端接入：" + clientSocket.getRemoteSocketAddress());
// 步驟3：獲取輸入流（接收客戶端數(shù)據(jù)）
InputStream input = clientSocket.getInputStream();
byte[] buffer = new byte[1024];
int len = input.read(buffer);  // 讀取數(shù)據(jù)到buffer數(shù)組
String receivedData = new String(buffer, 0, len);
System.out.println("收到消息：" + receivedData);
// 步驟4：發(fā)送響應(yīng)數(shù)據(jù)
OutputStream output = clientSocket.getOutputStream();
output.write("已收到！".getBytes());
// 步驟5：關(guān)閉連接（實(shí)際開(kāi)發(fā)中需在finally塊處理）
clientSocket.close();
serverSocket.close();

// 步驟1：連接服務(wù)端（IP+端口）
Socket socket = new Socket("127.0.0.1", 8080);
System.out.println("連接服務(wù)端成功！");
// 步驟2：發(fā)送數(shù)據(jù)
OutputStream output = socket.getOutputStream();
output.write("你好，服務(wù)端！".getBytes());
// 步驟3：接收響應(yīng)
InputStream input = socket.getInputStream();
byte[] buffer = new byte[1024];
int len = input.read(buffer);
String response = new String(buffer, 0, len);
System.out.println("服務(wù)端響應(yīng)：" + response);
// 步驟4：關(guān)閉連接
socket.close();

Socket socket = new Socket();
// 設(shè)置連接超時(shí)為5秒（單位：毫秒）
socket.connect(new InetSocketAddress("127.0.0.1", 8080), 5000);  // 

socket.setSoTimeout(3000);  // 設(shè)置讀取超時(shí)3秒 

try (Socket socket = new Socket()) {
    // 連接超時(shí)5秒
    socket.connect(new InetSocketAddress("127.0.0.1", 8080), 5000);
    // 讀取超時(shí)3秒
    socket.setSoTimeout(3000);
    InputStream input = socket.getInputStream();
    // 讀取數(shù)據(jù)...
} catch (SocketTimeoutException e) {
    System.err.println("操作超時(shí)：" + e.getMessage());
} catch (IOException e) {
    System.err.println("連接失?。? + e.getMessage());
}

Timer timer = new Timer();
timer.schedule(new TimerTask() {
    @Override
    public void run() {
        try {
            OutputStream out = socket.getOutputStream();
            out.write(0);  // 發(fā)送心跳包（內(nèi)容可為任意約定標(biāo)識(shí)）
            out.flush();
            System.out.println("心跳發(fā)送成功");
        } catch (IOException e) {
            System.err.println("心跳發(fā)送失敗，連接已斷開(kāi)");
            timer.cancel();  // 停止定時(shí)任務(wù)
        }
    }
}, 0, 30000);  // 立即啟動(dòng)，每30秒執(zhí)行一次 

socket.setSoTimeout(45000);  // 超時(shí)時(shí)間略大于心跳間隔
try {
    InputStream in = socket.getInputStream();
    while (true) {
        int data = in.read();  // 阻塞等待數(shù)據(jù)
        if (data == 0) {
            System.out.println("收到心跳包");
        }
    }
} catch (SocketTimeoutException e) {
    System.err.println("心跳超時(shí)，連接斷開(kāi)");
    socket.close();
}

public class EchoServer {
    public static void main(String[] args) throws IOException {
        ExecutorService pool = Executors.newCachedThreadPool();  // 線程池處理并發(fā)
        try (ServerSocket server = new ServerSocket(8080)) {
            System.out.println("服務(wù)端啟動(dòng)，端口8080");
            while (true) {
                Socket client = server.accept();
                client.setSoTimeout(45000);  // 設(shè)置讀取超時(shí)45秒 
                pool.submit(() -> handleClient(client));
            }
        }
    }
    private static void handleClient(Socket client) {
        try (BufferedReader in = new BufferedReader(new InputStreamReader(client.getInputStream()));
             PrintWriter out = new PrintWriter(client.getOutputStream(), true)) {
            String input;
            while ((input = in.readLine()) != null) {
                if ("HEARTBEAT".equals(input)) {  // 識(shí)別心跳包
                    System.out.println("收到心跳包");
                    continue;
                }
                out.println("Echo: " + input);  // 回顯消息
            }
        } catch (SocketTimeoutException e) {
            System.err.println("客戶端超時(shí)未響應(yīng)，連接關(guān)閉");
        } catch (IOException e) {
            e.printStackTrace();
        } finally {
            try { client.close(); } catch (IOException e) {}
        }
    }
}

public class EchoClient {
    public static void main(String[] args) {
        try (Socket socket = new Socket()) {
            // 連接超時(shí)5秒
            socket.connect(new InetSocketAddress("127.0.0.1", 8080), 5000);
            // 讀取超時(shí)3秒
            socket.setSoTimeout(3000);
            // 啟動(dòng)心跳線程（每30秒一次）
            startHeartbeat(socket.getOutputStream());
            Scanner scanner = new Scanner(System.in);
            PrintWriter out = new PrintWriter(socket.getOutputStream(), true);
            BufferedReader in = new BufferedReader(new InputStreamReader(socket.getInputStream()));
            while (true) {
                System.out.print("輸入消息：");
                String msg = scanner.nextLine();
                out.println(msg);  // 發(fā)送消息
                System.out.println("服務(wù)端響應(yīng)：" + in.readLine());
            }
        } catch (SocketTimeoutException e) {
            System.err.println("操作超時(shí)：" + e.getMessage());
        } catch (IOException e) {
            System.err.println("連接異常：" + e.getMessage());
        }
    }
    private static void startHeartbeat(OutputStream out) {
        Timer timer = new Timer();
        timer.schedule(new TimerTask() {
            @Override
            public void run() {
                try {
                    out.write("HEARTBEAT\n".getBytes());  // 發(fā)送心跳標(biāo)識(shí)
                    out.flush();
                } catch (IOException e) {
                    timer.cancel();
                }
            }
        }, 0, 30000);
    }
}