《安卓-深入浅出MVVM教程》应用篇-05 Simple Dat

简介

背景

这几年 MVP 架构在安卓界非常流行，几乎已经成为主流框架，它让业务逻辑 和 UI操作相对独立，使得代码结构更清晰。

MVVM 在前端火得一塌糊涂，而在安卓这边却基本没见到几个人在用，看到介绍 MVVM 也最多是讲 DataBinding 或 介绍思想的。偶尔看到几篇提到应用的，还是对谷歌官网的Architecture Components 文章的翻译。

相信大家看别人博客或官方文档的时候，总会碰到一些坑。要么入门教程写得太复杂（无力吐槽，前面写一堆原理，各种高大上的图，然并卵，到实践部分一笔带过，你确定真的是入门教程吗）。要么就是简单得就是一个 hello world，然后就没有下文了（看了想骂人）。

实在看不下去的我，决定插手你的人生。

目录

《安卓-深入浅出MVVM教程》大致分两部分：应用篇、原理篇。
采用循序渐进方式，内容深入浅出，符合人类学习规律，希望大家用最少时间掌握 MVVM。

应用篇：

01 Hello MVVM (快速入门)
02 Repository （数据仓库）
03 Cache （本地缓存）
04 State Lcee （加载/空/错误/内容视图）
05 Simple Data Source （简单的数据源）
06 Load More （加载更多）
07 DataBinding （数据与视图绑定）
08 RxJava2
09 Dragger2
10 Abstract （抽象）
11 Demo （例子）
12-n 待定（欢迎 github 提建议）

原理篇

01 MyLiveData（最简单的LiveData）
02-n 待定（并不是解读源码，那样太无聊了，打算带你从0撸一个 Architecture）

关于提问

本人水平和精力有限，如果有大佬发现哪里写错了或有好的建议，欢迎在本教程附带的 github仓库 提issue。
What？为什么不在博客留言？考虑到国内转载基本无视版权的情况，一般来说你都不是在源出处看到这篇文章，所以留言我也一般是看不到的。

教程附带代码

https://github.com/ittianyu/MVVM

应用篇放在 app 模块下，原理篇放在 implementation 模块下。
每一节代码采用不同包名，相互独立。

前言

上一节给数据加上了状态。但我发现数据源返回的是 LiveData<Lcee<?>>，对新项目来说，这倒是无所谓。但如果旧项目想改成 MVVM 架构，那数据源这一块就得大改了。
软件设计一般推荐增加不推荐修改，因为一改容易导致其他地方发生错误。

读者请注意，记得把上一节的程序备份好，后面有几节都是从上一节的地方开始。

简单数据源

接口

对于旧项目来说，数据源可能是这样的（用RxJava的后面有更好的方法）。

public interface UserDataSource {
    interface Result<T> {
        void onSuccess(T data);
        void onFailed(Throwable throwable);
    }

    void queryUserByUsername(String username, Result<User> result);
}

也就是说，数据源对是通过回调接口来传递数据的。

LocalUserDataSource

本地的数据源转化略为麻烦，因为需要切换线程。
当然如果你用的是其他数据库框架或 sqlite，可以直接主线程中运行，数据量小的话，对 UI 影响很小。

public class LocalUserDataSource implements UserDataSource {
    private static final LocalUserDataSource instance = new LocalUserDataSource();

    private LocalUserDataSource() {
    }

    public static LocalUserDataSource getInstance() {
        return instance;
    }


    private UserService userService = UserServiceImpl.getInstance();

    public void addUser(final User user) {
        new AsyncTask<Void, Void, Void>() {
            @Override
            protected Void doInBackground(Void... voids) {
                userService.add(user);
                return null;
            }
        }.execute();
    }

    @Override
    public void queryUserByUsername(final String username, final Result<User> result) {
        new AsyncTask<Void, Void, Object>() {

            @Override
            protected Object doInBackground(Void... voids) {
                try {
                    User user = userService.queryByUsername(username);
                    return user;
                } catch (Exception e) {
                    e.printStackTrace();
                    return e;
                }
            }

            @Override
            protected void onPostExecute(Object obj) {
                if (obj instanceof User)
                    result.onSuccess((User) obj);
                else if (obj instanceof Exception)
                    result.onFailed((Throwable) obj);
                else
                    result.onFailed(null);
            }
        }.execute();

    }
}

RemoteUserDataSource

public class RemoteUserDataSource implements UserDataSource {
    private static final RemoteUserDataSource instance = new RemoteUserDataSource();
    private RemoteUserDataSource() {
    }
    public static RemoteUserDataSource getInstance() {
        return instance;
    }


    private UserApi userApi = RetrofitFactory.getInstance().create(UserApi.class);

    @Override
    public void queryUserByUsername(String username, final Result<User> result) {
        userApi.queryUserByUsername(username)
                .enqueue(new Callback<User>() {
                    @Override
                    public void onResponse(Call<User> call, Response<User> response) {
                        User user = response.body();
                        result.onSuccess(user);
                        // update cache
                        LocalUserDataSource.getInstance().addUser(user);
                    }

                    @Override
                    public void onFailure(Call<User> call, Throwable t) {
                        t.printStackTrace();
                        result.onFailed(t);
                    }
                });
    }
}

转换为 LiveData

为了让 ViewModel 调用，需要将回调接口形式转为 LiveData

在 UserRepository 中加入这样一个方法

private LiveData<Lcee<User>> getUserFromDataSource(UserDataSource dataSource, String username) {
    final MutableLiveData<Lcee<User>> data = new MutableLiveData<>();
    data.setValue(Lcee.<User>loading());
    dataSource.queryUserByUsername(username, new UserDataSource.Result<User>() {
        @Override
        public void onSuccess(User user) {
            if (null == data)
                data.setValue(Lcee.<User>empty());
            else
                data.setValue(Lcee.content(user));
        }

        @Override
        public void onFailed(Throwable throwable) {
            data.setValue(Lcee.<User>error(throwable));
        }
    });
    return data;
}

getUser 方法就可以调用这方法来转换了

public LiveData<Lcee<User>> getUser(String username) {
    if (NetworkUtils.isConnected(context)) {
        return getUserFromRemote(username);
    } else {
        return getUserFromLocal(username);
    }
}

private LiveData<Lcee<User>> getUserFromRemote(String username) {
    return getUserFromDataSource(remoteUserDataSource, username);
}

private LiveData<Lcee<User>> getUserFromLocal(String username) {
    return getUserFromDataSource(localUserDataSource, username);
}

总结

到此为止，就已经把数据源改完了。
对比之前的数据源，你会发现，现在的数据源更接近你以前写的形式。而转换工作则放到了 UserRepository 中。

个人觉得新项目没必要这样写，转换太麻烦了，直接用 LiveData 就好。

读者：我发现如果是列表界面，会存在下拉刷新，加载更多这样的状态，这个怎么办？
博主：这...这你就问对人了。