Java Firebase认证失败无异常且写入任务无超时挂起问题求助

我来帮你搞定这个头疼的问题——之前我也碰到过类似的情况，核心原因是Firebase Realtime Database SDK在**认证永久失效（比如密钥被删除）**时，会一直无限重试请求，既不触发错误回调，也不抛出超时异常，导致你的等待逻辑彻底卡住。下面给你几个具体的解决方案：

1. 给SDK配置重试上限与超时 #

Firebase SDK其实允许你自定义重试策略，通过设置最大重试次数和请求超时，让SDK在多次失败后主动放弃，触发错误回调：

FirebaseDatabase firebaseDatabase = FirebaseDatabase.getInstance();
DatabaseConfig config = firebaseDatabase.getConfig();
// 设置最多重试3次，避免无限循环
config.setMaxRetryAttempts(3);
// 单次请求超时10秒，适配网络波动
config.setConnectionTimeout(10000);
// 应用配置
firebaseDatabase.setConfig(config);

这样当密钥失效导致认证连续失败3次后，SDK就会调用CompletionListener的onComplete方法并传入错误信息，或者让setValueAsync的Future抛出异常，你的程序就能正常处理错误，不会一直阻塞。

2. 在应用层添加手动超时保障 #

就算配置了SDK的重试策略，也建议在应用代码里加上超时逻辑，防止极端情况：

针对CompletionListener的方式 #

用CountDownLatch替代死循环，带超时等待：

final CountDownLatch latch = new CountDownLatch(1);

usersRef.setValue(users, new DatabaseReference.CompletionListener(){
    public void onComplete(DatabaseError error, DatabaseReference ref) {
        if (error != null){
            System.err.println("Error " + error.getMessage());
        }else {
            System.out.println("Completed");
        }
        latch.countDown();
    }
});

// 最多等待30秒，超时就主动终止
try {
    if (!latch.await(30, TimeUnit.SECONDS)) {
        System.err.println("Write operation timed out");
        // 主动取消未完成的请求
        usersRef.cancel();
    }
} catch (InterruptedException e) {
    Thread.currentThread().interrupt();
    System.err.println("Wait interrupted");
}

针对setValueAsync的方式 #

直接用带超时的get方法：

ApiFuture<Void> apiFuture = usersRef.setValueAsync(users);
try {
    // 等待30秒，超时抛出异常
    apiFuture.get(30, TimeUnit.SECONDS);
    System.out.println("Write completed successfully");
} catch (TimeoutException e) {
    System.err.println("Write operation timed out");
    apiFuture.cancel(true);
} catch (ExecutionException | InterruptedException e) {
    System.err.println("Write failed: " + e.getMessage());
    Thread.currentThread().interrupt();
}

3. 提前验证凭证有效性 #

在初始化Firebase之前，先主动验证密钥是否有效，避免无效的写入尝试：

InputStream serviceAccount = Appl.class.getClassLoader().getResourceAsStream("testing-fcf995d2ab6f.json");
GoogleCredentials credentials = GoogleCredentials.fromStream(serviceAccount);
try {
    // 主动刷新令牌，验证凭证是否可用
    credentials.refreshIfExpired();
} catch (IOException e) {
    System.err.println("Invalid credentials: " + e.getMessage());
    // 直接终止程序，避免后续无效操作
    System.exit(1);
}

// 再初始化FirebaseApp
FirebaseOptions firebaseOptions = new FirebaseOptions.Builder()
        .setCredentials(credentials)
        .setDatabaseUrl("https://golden-attic-93815.firebaseio.com/")
        .build();
FirebaseApp.initializeApp(firebaseOptions);

这样如果密钥已经被删除，在初始化阶段就能立刻捕获错误，不用等到写入时才卡住。

为什么会出现这种情况？ #

Firebase SDK的设计初衷是尽可能保证数据写入成功，所以遇到临时网络问题或凭证过期时会自动重试。但对于密钥被删除这种永久失效的情况，SDK无法区分是临时错误还是永久错误，就会一直重试下去，导致没有任何回调触发。通过上面的配置，就能让SDK在合理次数的重试后放弃，把控制权交还给你的应用。

内容的提问来源于stack exchange，提问作者Ben Cheng