ViewModel中更换LiveData引用后观察者未收到通知的问题求助

兄弟，你踩了LiveData使用里一个很典型的坑：你给liveData变量重新赋值了新的LiveData实例，但之前添加的观察者是绑定在最初的那个LiveData对象上的。新实例和旧实例完全是两个独立的对象，观察者根本不知道有新的LiveData存在，自然收不到任何通知。

这里给你几个实用的方案，你可以根据自己的业务场景选：

方案1：用MutableLiveData当容器，只更新内部数据 #

别再替换整个LiveData实例了，让ViewModel里维护一个固定的MutableLiveData，每次请求到新数据后，更新它的内部值就行：

public class SwipeViewModel extends AndroidViewModel{
    // 固定一个MutableLiveData实例，对外暴露不可变的LiveData
    private final MutableLiveData<ApiResponse> internalLiveData = new MutableLiveData<>();
    private DataSource dataSource;
    
    public SwipeViewModel(@NonNull Application application) {
        super(application);
        dataSource = getDataSource();
        // 第一次加载数据
        loadNewData();
    }
    
    public void newRequest(){
        loadNewData();
    }
    
    private void loadNewData() {
        // 获取DataSource返回的新LiveData，拿到数据后更新我们的内部LiveData
        LiveData<ApiResponse> newRequestLiveData = dataSource.getLiveData();
        newRequestLiveData.observeForever(response -> {
            internalLiveData.setValue(response);
            // 记得移除观察者，避免内存泄漏
            newRequestLiveData.removeObserver(this);
        });
    }
    
    // 对外提供不可变的LiveData，防止外部随意修改
    public LiveData<ApiResponse> getLiveData() {
        return internalLiveData;
    }
}

这样观察者始终盯着同一个internalLiveData，每次请求后更新它的值，就能正常收到通知了。

方案2：改造DataSource，让它返回同一个LiveData实例 #

如果能改DataSource的代码，最好让它内部维护一个固定的LiveData，每次请求后只更新这个实例的内容，而不是返回新实例：

public class DataSource {
    private final MutableLiveData<ApiResponse> liveData = new MutableLiveData<>();
    
    public LiveData<ApiResponse> getLiveData() {
        return liveData;
    }
    
    // 新增一个方法触发请求并更新数据
    public void triggerNewRequest() {
        // 用Retrofit发起请求
        yourRetrofitApi.fetchData().enqueue(new Callback<ApiResponse>() {
            @Override
            public void onResponse(Call<ApiResponse> call, Response<ApiResponse> response) {
                if (response.isSuccessful()) {
                    liveData.postValue(response.body());
                } else {
                    // 处理错误情况
                    liveData.postValue(new ApiResponse.Error("请求失败"));
                }
            }
            
            @Override
            public void onFailure(Call<ApiResponse> call, Throwable t) {
                liveData.postValue(new ApiResponse.Error(t.getMessage()));
            }
        });
    }
}

然后ViewModel的代码就简单多了：

public class SwipeViewModel extends AndroidViewModel{
    private final LiveData<ApiResponse> liveData;
    private DataSource dataSource;
    
    public SwipeViewModel(@NonNull Application application) {
        super(application);
        dataSource = getDataSource();
        liveData = dataSource.getLiveData();
        // 第一次请求
        dataSource.triggerNewRequest();
    }
    
    public void newRequest(){
        // 只需要触发DataSource更新数据，LiveData实例不变
        dataSource.triggerNewRequest();
    }
    
    public LiveData<ApiResponse> getLiveData() {
        return liveData;
    }
}

这种方式最符合LiveData的设计初衷——它就是用来当一个可观察的数据容器，而不是每次请求都新建一个。

方案3：用Transformations.switchMap处理带参数的请求 #

如果你的请求需要动态参数（比如分页、搜索关键词），switchMap可以帮你自动管理LiveData的切换：

public class SwipeViewModel extends AndroidViewModel{
    // 用这个MutableLiveData当触发器，参数变化时自动发起新请求
    private final MutableLiveData<RequestParams> requestTrigger = new MutableLiveData<>();
    private final LiveData<ApiResponse> liveData;
    private DataSource dataSource;
    
    public SwipeViewModel(@NonNull Application application) {
        super(application);
        dataSource = getDataSource();
        // 当trigger变化时，自动切换到新的请求LiveData
        liveData = Transformations.switchMap(requestTrigger, params -> {
            return dataSource.getLiveData(params);
        });
        // 初始化第一次请求的参数
        requestTrigger.setValue(new RequestParams(1));
    }
    
    public void newRequest(int newPage){
        // 更新触发器参数，switchMap会自动订阅新的LiveData
        requestTrigger.setValue(new RequestParams(newPage));
    }
    
    public LiveData<ApiResponse> getLiveData() {
        return liveData;
    }
}

这种方式适合请求参数经常变化的场景，switchMap会帮你自动取消旧LiveData的订阅，同时订阅新的，保证观察者能拿到最新的请求结果。

核心就是别随便替换LiveData实例，要么让同一个实例更新内部数据，要么用switchMap帮你管理实例切换。这样观察者就能一直收到正确的通知啦！

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