Android Studio中正确使用Firebase Realtime Database并避免代码冗余

一、单例类的优化 #

你的FirebaseManager单例存在成员变量静态化的问题，这可能引发不必要的上下文引用风险，优化后的单例实现如下：

public class FirebaseManager {
    private static FirebaseManager instance;
    private final FirebaseAuth mFirebaseAuth;
    private final FirebaseDatabase mFirebaseDatabase;

    private FirebaseManager() {
        mFirebaseAuth = FirebaseAuth.getInstance();
        mFirebaseDatabase = FirebaseDatabase.getInstance();
        // 可选：开启本地持久化，提升离线使用体验
        mFirebaseDatabase.setPersistenceEnabled(true);
    }

    public static synchronized FirebaseManager getInstance() {
        if (instance == null) {
            instance = new FirebaseManager();
        }
        return instance;
    }

    public FirebaseAuth getAuth() {
        return mFirebaseAuth;
    }

    public FirebaseDatabase getDatabase() {
        return mFirebaseDatabase;
    }
}

二、解决异步数据读取问题 #

Firebase Realtime Database的读写操作是异步执行的，无法直接同步返回结果，推荐以下两种解决方案：

方案1：自定义回调接口 #

先定义通用回调接口，用于传递异步操作的结果与错误信息：

public interface FirebaseCallback<T> {
    void onSuccess(T result);
    void onFailure(String errorMessage);
}

修改FirebaseManager中的分数读取方法，通过回调返回数据：

public void getQuizScores(FirebaseCallback<List<GameScore>> callback) {
    FirebaseUser currentUser = mFirebaseAuth.getCurrentUser();
    if (currentUser == null) {
        callback.onFailure("用户未登录");
        return;
    }

    DatabaseReference scoreRef = mFirebaseDatabase.getReference("Users/" + currentUser.getUid() + "/quizScoreList");
    scoreRef.addListenerForSingleValueEvent(new ValueEventListener() {
        @Override
        public void onDataChange(DataSnapshot dataSnapshot) {
            List<GameScore> scores = new ArrayList<>();
            if (dataSnapshot.exists()) {
                for (DataSnapshot snapshot : dataSnapshot.getChildren()) {
                    GameScore score = snapshot.getValue(GameScore.class);
                    if (score != null) {
                        scores.add(score);
                    }
                }
            }
            callback.onSuccess(scores);
        }

        @Override
        public void onCancelled(DatabaseError databaseError) {
            callback.onFailure(databaseError.getMessage());
        }
    });
}

调用示例：

FirebaseManager.getInstance().getQuizScores(new FirebaseCallback<List<GameScore>>() {
    @Override
    public void onSuccess(List<GameScore> result) {
        // 在此处处理获取到的分数数据，比如更新UI
        Log.d("MyTag", "获取到分数数量：" + result.size());
    }

    @Override
    public void onFailure(String errorMessage) {
        // 处理错误情况，如提示用户
        Log.e("MyTag", "获取失败：" + errorMessage);
    }
});

方案2：使用LiveData（推荐，适配Jetpack架构） #

如果项目使用Jetpack组件，用LiveData可以自动适配生命周期，避免内存泄漏：

在FirebaseManager中返回LiveData对象：

public LiveData<List<GameScore>> getQuizScoresLiveData() {
    MutableLiveData<List<GameScore>> liveData = new MutableLiveData<>();
    FirebaseUser currentUser = mFirebaseAuth.getCurrentUser();

    if (currentUser == null) {
        liveData.postValue(null);
        return liveData;
    }

    DatabaseReference scoreRef = mFirebaseDatabase.getReference("Users/" + currentUser.getUid() + "/quizScoreList");
    scoreRef.addListenerForSingleValueEvent(new ValueEventListener() {
        @Override
        public void onDataChange(DataSnapshot dataSnapshot) {
            List<GameScore> scores = new ArrayList<>();
            if (dataSnapshot.exists()) {
                for (DataSnapshot snapshot : dataSnapshot.getChildren()) {
                    GameScore score = snapshot.getValue(GameScore.class);
                    if (score != null) {
                        scores.add(score);
                    }
                }
            }
            liveData.postValue(scores);
        }

        @Override
        public void onCancelled(DatabaseError databaseError) {
            liveData.postValue(null);
            // 可选：通过额外LiveData传递错误信息
        }
    });

    return liveData;
}

在Activity/Fragment中观察LiveData：

FirebaseManager.getInstance().getQuizScoresLiveData().observe(this, gameScores -> {
    if (gameScores != null) {
        // 更新UI逻辑
    } else {
        // 处理用户未登录或数据获取失败的情况
    }
});

三、最佳实践总结 #

• 单一职责：FirebaseManager仅负责初始化和提供Firebase实例，具体业务数据操作可封装为单独的Repository类（如ScoreRepository），进一步解耦代码
• 避免静态方法：单例类中优先使用非静态方法，减少静态上下文引用风险
• 异步规范：始终通过回调、LiveData或协程（Kotlin）处理异步操作，禁止尝试同步返回异步结果
• 错误处理：每个异步操作必须处理onCancelled回调，避免静默失败或崩溃
• 离线优化：初始化时开启数据库持久化，提升离线场景下的用户体验

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