SocketException在网络编程中怎么处理？套接字异常

SocketException

SocketException

SocketException

SocketException

SocketException

try-with-resources

try

import java.io.IOException;
import java.net.ConnectException;
import java.net.Socket;
import java.net.SocketTimeoutException;
import java.net.UnknownHostException;

public class SocketExceptionHandler {

    public void connectToServer(String host, int port, int timeoutMillis) {
        // 尝试使用 try-with-resources 确保 Socket 资源自动关闭
        try (Socket clientSocket = new Socket()) {
            // 设置连接超时，避免无限等待
            clientSocket.connect(new java.net.InetSocketAddress(host, port), timeoutMillis);
            System.out.println("成功连接到服务器: " + host + ":" + port);

            // 假设这里进行一些数据读写操作
            // clientSocket.getInputStream().read(...);
            // clientSocket.getOutputStream().write(...);

        } catch (ConnectException e) {
            // 针对连接被拒绝的特定处理
            System.err.println("连接被拒绝！服务器可能未启动、端口错误或防火墙阻止。详细：" + e.getMessage());
            // 这里的处理：通常不建议重试，因为服务器可能真的没开
            // 考虑通知用户或记录更高级别的日志
        } catch (SocketTimeoutException e) {
            // 针对操作超时的特定处理
            System.err.println("连接或读写操作超时！网络可能不稳定或服务器响应慢。详细：" + e.getMessage());
            // 这里的处理：可以考虑重试机制，例如指数退避
            // retryConnect(host, port, timeoutMillis);
        } catch (UnknownHostException e) {
            // 无法解析主机名
            System.err.println("无法解析主机名 '" + host + "'。请检查地址是否正确。详细：" + e.getMessage());
        } catch (IOException e) {
            // 捕获所有其他 SocketException 或更广泛的 IO 异常
            // 这通常是 ConnectionResetException, BrokenPipeException, 或其他通用网络错误
            System.err.println("发生一般网络IO错误。详细：" + e.getMessage());
            e.printStackTrace(); // 打印堆栈跟踪，便于调试
            // 这里的处理：可能需要重新建立连接，或者根据错误信息判断是否重试
        } catch (Exception e) { // 最后捕获所有其他意想不到的异常
            System.err.println("发生未知错误: " + e.getMessage());
            e.printStackTrace();
        }
    }

    // 简单模拟重试逻辑（实际应用中会更复杂）
    private void retryConnect(String host, int port, int timeoutMillis) {
        System.out.println("尝试重新连接...");
        try {
            Thread.sleep(1000); // 简单等待1秒
            connectToServer(host, port, timeoutMillis * 2); // 增加超时时间并重试
        } catch (InterruptedException ex) {
            Thread.currentThread().interrupt();
            System.err.println("重试被中断。");
        }
    }

    public static void main(String[] args) {
        SocketExceptionHandler handler = new SocketExceptionHandler();
        // 模拟连接一个不存在的服务器或端口
        handler.connectToServer("localhost", 9999, 5000);
        // 模拟连接一个可能超时的服务
        // handler.connectToServer("some.slow.server.com", 80, 2000);
    }
}

socket

try-except

with

try-with-resources

import socket
import time

def connect_to_server(host, port, timeout_seconds=5):
    try:
        # 使用 with 语句确保 socket 资源自动关闭
        with socket.socket(socket.AF_INET, socket.SOCK_STREAM) as s:
            s.settimeout(timeout_seconds) # 设置套接字操作的超时时间
            s.connect((host, port))
            print(f"成功连接到服务器: {host}:{port}")

            # 假设这里进行一些数据读写操作
            # s.sendall(b"Hello, server!")
            # data = s.recv(1024)
            # print(f"收到数据: {data.decode()}")

    except socket.timeout:
        # 针对操作超时的特定处理
        print(f"连接或操作超时 ({host}:{port})。网络可能不稳定或服务器响应慢。")
        # 这里的处理：可以考虑重试
        # retry_connect(host, port, timeout_seconds * 2)
    except ConnectionRefusedError:
        # 针对连接被拒绝的特定处理 (Python 3.x)
        print(f"连接被拒绝 ({host}:{port})！服务器可能未启动、端口错误或防火墙阻止。")
        # 不建议重试
    except socket.gaierror: # getaddrinfo error (类似 UnknownHostException)
        print(f"无法解析主机名 '{host}'。请检查地址是否正确。")
    except OSError as e:
        # 捕获所有其他与套接字相关的操作系统错误，例如 ConnectionResetError, BrokenPipeError
        print(f"发生一般套接字错误 ({host}:{port}): {e}")
        # 打印异常信息，便于调试
        # import traceback
        # traceback.print_exc()
        # 这里的处理：可能需要重新建立连接
    except Exception as e: # 最后捕获所有其他意想不到的异常
        print(f"发生未知错误: {e}")

# 简单模拟重试逻辑
def retry_connect(host, port, timeout_seconds, retries=3):
    for i in range(retries):
        print(f"尝试重新连接 ({i+1}/{retries})...")
        time.sleep(2 ** i) # 指数退避
        try:
            connect_to_server(host, port, timeout_seconds)
            return True
        except (socket.timeout, ConnectionRefusedError, OSError):
            if i == retries - 1:
                print(f"多次尝试后仍无法连接到 {host}:{port}")
                return False
    return False

if __name__ == "__main__":
    # 模拟连接一个不存在的服务器或端口
    connect_to_server("localhost", 9999, 3)
    print("-" * 30)
    # 模拟连接一个已知的主机但可能超时
    # connect_to_server("example.com", 80, 1)

SocketException

SocketException