Android结合LiveData、ViewModel动态更新Firebase实时数据库查询

• 你定义的QUERY_RATINGS是static final常量，类加载时就把endAt的时间戳固定死了，后续不会随系统时间变化。
• 自定义LiveData的changeQuery方法只替换了Query引用，没有处理旧监听移除、新监听挂载的逻辑，就算传入新Query也不会生效。
• Firebase Realtime Database的Query条件在对象创建时就固定，没有自动随时间滚动更新的能力，必须定时生成新的Query对象替换旧查询，才能拿到最新时间范围内的数据。

1. 改造自定义LiveData，整合查询动态更新逻辑 #

把定时更新查询、监听切换的逻辑全部放到LiveData内部，依托LiveData自身的活跃生命周期管理任务启停，避免内存泄漏和空跑：

public class LiveData_FirebaseRating extends LiveData<DataSnapshot> {
    private static final String LOG_TAG = "LiveData_FirebaseRating";
    // 时间偏移量：只展示创建时间早于当前时间1分钟的数据，按需调整即可
    private static final long TIME_OFFSET = 60 * 1000;
    // 查询更新间隔：每30秒刷新一次查询条件，平衡实时性和性能消耗
    private static final long UPDATE_INTERVAL = 30 * 1000;

    private final DatabaseReference ratingsRef;
    private Query currentQuery;
    private final MyValueEventListener eventListener = new MyValueEventListener();
    private final Handler mainHandler = new Handler(Looper.getMainLooper());
    private final Runnable updateQueryTask = new Runnable() {
        @Override
        public void run() {
            long latestTimeThreshold = System.currentTimeMillis() - TIME_OFFSET;
            Query newQuery = ratingsRef
                    .orderByChild(DB_SQLite_Firebase_Entries.FIREBASE_RATINGDATEINMILLISECONDS)
                    .endAt(latestTimeThreshold);
            switchQuery(newQuery);
            mainHandler.postDelayed(this, UPDATE_INTERVAL);
        }
    };

    public LiveData_FirebaseRating(DatabaseReference ratingsRef) {
        this.ratingsRef = ratingsRef;
    }

    private void switchQuery(Query newQuery) {
        if (newQuery == null || newQuery == currentQuery) return;
        // 活跃状态下先移除旧查询的监听
        if (hasActiveObservers() && currentQuery != null) {
            currentQuery.removeEventListener(eventListener);
        }
        currentQuery = newQuery;
        // 活跃状态下给新查询挂载监听
        if (hasActiveObservers()) {
            currentQuery.addValueEventListener(eventListener);
        }
    }

    @Override
    protected void onActive() {
        super.onActive();
        Log.d(LOG_TAG, "onActive：启动数据监听与查询更新任务");
        // 激活时立即执行一次查询，再启动定时更新循环
        mainHandler.post(updateQueryTask);
    }

    @Override
    protected void onInactive() {
        super.onInactive();
        Log.d(LOG_TAG, "onInactive：停止监听与更新任务");
        // 无观察者时停止定时任务、移除监听，避免空跑耗资源
        mainHandler.removeCallbacks(updateQueryTask);
        if (currentQuery != null) {
            currentQuery.removeEventListener(eventListener);
        }
    }

    private class MyValueEventListener implements ValueEventListener {
        @Override
        public void onDataChange(DataSnapshot dataSnapshot) {
            setValue(dataSnapshot);
        }

        @Override
        public void onCancelled(DatabaseError databaseError) {
            Log.e(LOG_TAG, "监听查询失败：" + currentQuery, databaseError.toException());
        }
    }
}

2. 精简ViewModel代码 #

ViewModel只需要初始化对应节点的LiveData即可，不需要持有固定查询和定时任务：

public class ViewModel_MainActivity extends ViewModel {
    private final LiveData_FirebaseRating ratingsLiveData;

    public ViewModel_MainActivity() {
        DatabaseReference ratingsRef = FirebaseDatabase.getInstance(DB_SQLite_Firebase_Entries.FIREBASE_URL)
                .getReference()
                .child(DB_SQLite_Firebase_Entries.FIREBASE_NODE_RATINGS);
        ratingsLiveData = new LiveData_FirebaseRating(ratingsRef);
    }

    @NonNull
    public LiveData_FirebaseRating getRatingsLiveData() {
        return ratingsLiveData;
    }
}

3. 精简Activity中的观察逻辑 #

删掉原来手动存储DataSnapshot的冗余代码，LiveData自身会持有最新的数据，直接在回调里处理即可：

@Override
public void onCreate(Bundle savedInstanceState) {
    super.onCreate(savedInstanceState);
    binding = ActivityMainBinding.inflate(getLayoutInflater());
    setContentView(binding.getRoot());

    // 初始化ViewModel并观察数据
    viewModel = new ViewModelProvider(this).get(ViewModel_MainActivity.class);
    viewModel.getRatingsLiveData().observe(this, dataSnapshot -> {
        if (dataSnapshot != null && dataSnapshot.exists()) {
            // 直接在这里处理符合时间条件的评分数据即可
            // 需要拿最新数据时直接调用viewModel.getRatingsLiveData().getValue()就行，不需要额外手动存储Snapshot
        }
    });
}

• 原代码中时间计算存在偏差：1 * 60 * 60 * 1000是1小时的毫秒数，如果需求是“数据创建时间距当前至少满1分钟”，偏移量设置为1 * 60 * 1000即可，根据业务实际调整。
• 记得在Firebase数据库规则中给FIREBASE_RATINGDATEINMILLISECONDS字段添加索引，避免数据量增大后查询变慢。

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