Java 重連機制的幾種實現(xiàn)方法

更新時間：2026年02月09日 09:38:10 作者：思靜魚

本文主要介紹了Java 重連機制的幾種實現(xiàn)方法,文中通過示例代碼介紹的非常詳細,對大家的學習或者工作具有一定的參考學習價值,需要的朋友們下面隨著小編來一起學習學習吧

1.通用重連機制設計思路

檢測連接是否可用：心跳檢測（Ping/Pong）、異常捕獲（IOException、SocketTimeoutException）。
重試策略：
- 固定間隔：每隔 N 秒重試。
- 指數(shù)退避（Exponential Backoff）：1s → 2s → 4s → 8s，避免過度請求。
- 最大次數(shù)限制：比如最多重連 10 次，超過則告警/人工干預。
熔斷機制：連續(xù)失敗一定次數(shù)后，進入熔斷狀態(tài)，一段時間不再重連，防止雪崩。

2.HTTP 接口重連（以 OkHttp 為例）

import okhttp3.*;

import java.io.IOException;
import java.util.concurrent.TimeUnit;

public class HttpRetryClient {
    private final OkHttpClient client;

    public HttpRetryClient() {
        this.client = new OkHttpClient.Builder()
                .connectTimeout(5, TimeUnit.SECONDS)
                .readTimeout(5, TimeUnit.SECONDS)
                .retryOnConnectionFailure(true) // 啟用連接失敗自動重試
                .build();
    }

    public String get(String url) {
        int maxRetries = 3;
        int attempt = 0;

        while (attempt < maxRetries) {
            try {
                Request request = new Request.Builder().url(url).build();
                Response response = client.newCall(request).execute();
                if (response.isSuccessful()) {
                    return response.body().string();
                }
            } catch (IOException e) {
                System.out.println("請求失敗，正在重試: " + attempt);
            }
            attempt++;
            try {
                Thread.sleep((long) Math.pow(2, attempt) * 1000); // 指數(shù)退避
            } catch (InterruptedException ignored) {}
        }
        throw new RuntimeException("請求失敗超過最大次數(shù)");
    }

    public static void main(String[] args) {
        HttpRetryClient client = new HttpRetryClient();
        System.out.println(client.get("http://example.com"));
    }
}

3.WebSocket 重連

import okhttp3.*;

public class WebSocketReconnect {
    private OkHttpClient client = new OkHttpClient();
    private WebSocket webSocket;
    private final String url = "ws://localhost:8080/ws";
    private int retryCount = 0;

    public void connect() {
        Request request = new Request.Builder().url(url).build();
        webSocket = client.newWebSocket(request, new WebSocketListener() {
            @Override
            public void onFailure(WebSocket ws, Throwable t, Response resp) {
                System.out.println("連接失敗: " + t.getMessage());
                reconnect();
            }

            @Override
            public void onClosed(WebSocket ws, int code, String reason) {
                System.out.println("連接關閉: " + reason);
                reconnect();
            }
        });
    }

    private void reconnect() {
        if (retryCount < 5) {
            retryCount++;
            try {
                Thread.sleep(2000L * retryCount); // 逐漸延遲重連
            } catch (InterruptedException ignored) {}
            connect();
        } else {
            System.out.println("超過最大重連次數(shù)");
        }
    }

    public static void main(String[] args) {
        new WebSocketReconnect().connect();
    }
}

4.數(shù)據(jù)庫重連（以 JDBC 為例）

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.SQLException;

public class JdbcReconnect {
    private static final String URL = "jdbc:mysql://localhost:3306/test";
    private static final String USER = "root";
    private static final String PASS = "123456";

    public static Connection getConnection() {
        int retries = 0;
        while (retries < 5) {
            try {
                return DriverManager.getConnection(URL, USER, PASS);
            } catch (SQLException e) {
                retries++;
                System.out.println("數(shù)據(jù)庫連接失敗，重試中..." + retries);
                try {
                    Thread.sleep(2000 * retries);
                } catch (InterruptedException ignored) {}
            }
        }
        throw new RuntimeException("數(shù)據(jù)庫連接失敗超過最大次數(shù)");
    }

    public static void main(String[] args) {
        Connection conn = getConnection();
        System.out.println("數(shù)據(jù)庫連接成功: " + conn);
    }
}