java网络断线怎么重连

在 Java 里“网络断线重连”一般分 场景 来看：

• Socket / TCP 长连接（如自定义协议、游戏、IoT）
• HTTP / REST 接口调用
• 消息队列 / 第三方客户端（MQTT、WebSocket、Netty 等）

下面按常见情况给你讲清楚做法和示例代码。

一、Socket 长连接断线重连（最典型）

核心思路

1. 捕获 IOException / SocketException
2. 关闭旧连接
3. 延时后重连
4. 限制重连次数 / 指数退避

示例（简单版）

public class ReconnectSocket {
    private Socket socket;
    private String host;
    private int port;

    public ReconnectSocket(String host, int port) {
        this.host = host;
        this.port = port;
    }

    public void connect() {
        while (true) {
            try {
                socket = new Socket(host, port);
                System.out.println("连接成功");
                readData(socket);
                break;
            } catch (IOException e) {
                System.out.println("连接断开，5秒后重连");
                closeQuietly(socket);
                sleep(5000);
            }
        }
    }

    private void readData(Socket socket) throws IOException {
        BufferedReader in = new BufferedReader(
                new InputStreamReader(socket.getInputStream()));
        String line;
        while ((line = in.readLine()) != null) {
            System.out.println("收到：" + line);
        }
    }

    private void sleep(long ms) {
        try { Thread.sleep(ms); } catch (InterruptedException ignored) {}
    }

    private void closeQuietly(Socket s) {
        try { if (s != null) s.close(); } catch (IOException ignored) {}
    }

    public static void main(String[] args) {
        new ReconnectSocket("127.0.0.1", 9000).connect();
    }
}

✅ 优点：实现简单
❌ 缺点：阻塞线程

二、指数退避重连（推荐）

避免网络风暴：

int retry = 0;
while (true) {
    try {
        connect();
        break;
    } catch (IOException e) {
        retry++;
        long wait = Math.min(30000, (long) Math.pow(2, retry) * 1000);
        Thread.sleep(wait);
    }
}

三、HTTP 接口断线重连（RestTemplate / OkHttp）

1️⃣ 重试机制（推荐 OkHttp）

OkHttpClient client = new OkHttpClient.Builder()
        .retryOnConnectionFailure(true)
        .build();

2️⃣ 手动重试

int retry = 3;
while (retry-- > 0) {
    try {
        // 调用 HTTP
        break;
    } catch (IOException e) {
        Thread.sleep(2000);
    }
}

四、WebSocket 断线重连

webSocket.onClosed(() -> reconnect());
webSocket.onFailure((e) -> reconnect());

void reconnect() {
    scheduler.schedule(this::connect, 3, TimeUnit.SECONDS);
}

五、Netty 断线重连（最规范）

bootstrap.handler(new ChannelInitializer<SocketChannel>() {
    @Override
    protected void initChannel(SocketChannel ch) {
        ch.pipeline().addLast(new ChannelInboundHandlerAdapter() {
            @Override
            public void channelInactive(ChannelHandlerContext ctx) {
                ctx.channel().eventLoop().schedule(
                    () -> bootstrap.connect(), 5, TimeUnit.SECONDS);
            }
        });
    }
});

六、常见坑（很重要）

❌ 重连不关旧连接 → 文件句柄泄露
❌ 无限重连无上限 → 系统崩
❌ 主线程阻塞 → 用线程 / 线程池
❌ 不判断“主动断开”

七、你可以告诉我

• 用的是 Socket / HTTP / WebSocket / Netty / MQTT
• 是 客户端还是服务端
• 是否 阻塞 / 非阻塞

我可以直接给你一套可复制的完整重连方案。