模块化解耦框架RxFluxArchitecture2-基本功能实

相关系列文章

模块化解耦框架RxFluxArchitecture1-框架简介

模块化解耦框架RxFluxArchitecture2-基本功能实现

模块化解耦框架RxFluxArchitecture3-订阅管理绑定生命周期

模块化解耦框架RxFluxArchitecture4-依赖库与依赖注入

模块化解耦框架RxFluxArchitecture5-Application多模块共存

架构图

架构图.jpg

功能实现

1. 操作结果通知RxAction和UI响应通知RxChange

1.1 View 调用

在LoginFragment点击登录按钮，调用LoginActionCreator中的方法login(String,String)。

    @OnClick(R2.id.btn_login)
    public void login() {
        mActionCreator.login(username, password);
    }

1.2 ActionCreator 操作并发送

在LoginActionCreator的方法login(String,String)中postHttpAction(RxAction, Observable<T>)方法会调用WanApi接口方法进行登录操作，登录完成后发送封装接口返回结果的RxAction（包含TagLoginAction.LOGIN）。

    @Override
    public void login(String username, String password) {
        RxAction rxAction = newRxAction(LoginAction.LOGIN);
        postHttpAction(rxAction, mWanApi.login(username, password).flatMap(verifyResponse()));
    }

1.3 Store 接收并发送

在LoginStore中接收 Tag 为LoginAction.LOGIN，数据类型为RxAction的通知。取出RxAction中封装的接口返回数据，然后使用方法postChange(RxChange)通知 View 进行 UI 响应操作。

    @Subscribe(tags = {LoginAction.LOGIN})
    public void onLogin(RxAction rxAction) {
        mUser = rxAction.getResponse();
        postChange(RxChange.newInstance(rxAction.getTag()));
    }

1.4 View 接收

在LoginActivity中接收Tag为LoginAction.LOGIN，数据类型为RxChange的通知，跳转其他页面。

    @Subscribe(tags = {LoginAction.LOGIN}, sticky = true)
    public void onLogin(RxChange rxChange) {
        startActivity(new Intent(this, ArticleActivity.class));
        finish();
    }

2. 操作进度通知RxLoading

2.1 ActionCreator 操作并发送

在LoginActionCreator中使用postHttpLoadingAction(RxAction, Observable<T>)方法。
操作开始时，发送进度开始通知RxLoading；
操作完成，发送封装接口返回结果的RxAction（包含TagLoginAction.LOGIN）；
操作结束后，发送进度结束通知RxLoading。

    @Override
    public void login(String username, String password) {
        RxAction rxAction = newRxAction(LOGIN);
        postHttpLoadingAction(rxAction, mWanApi.login(username, password).flatMap(verifyResponse()));
    }

2.2 View 接收

在BaseActivity中全局响应RxLoading

    @Subscribe(sticky = true)
    public void onRxLoading(@NonNull RxLoading rxLoading) {
        if (rxLoading.isLoading()) {
            //显示进度框
        } else {
            //隐藏进度框
        }
    }

或者在特定 View LoginActivity中重写onRxLoading(RxLoading)方法，单独响应Tag为LoginAction.LOGIN的RxLoading。

    @Override
    @Subscribe(sticky = true)
    public void onRxLoading(@NonNull RxLoading rxLoading) {
        if (TextUtils.equals(rxLoading.getTag(), LoginAction.LOGIN)) {
            if (rxLoading.isLoading()) {
                //显示进度框
            } else {
                //隐藏进度框
            }
        }
    }

3. 操作异常通知RxError

3.1 ActionCreator 操作并发送

在RxActionCretor 中postHttpAction(RxAction, Observable<T>)和postHttpLoadingAction(RxAction, Observable<T>)方法，如果有异常，会发送操作异常通知RxError。

3.2 View 接收

在BaseActivity中全局响应RxError

    @Subscribe(sticky = true)
    public void onRxError(@NonNull RxError rxError) {
        Throwable throwable = rxError.getThrowable();
        if (throwable instanceof CommonException) {
            Toast.makeText(this, ((CommonException) throwable).message(), Toast.LENGTH_SHORT).show();
        } else if (throwable instanceof retrofit2.HttpException) {
            Toast.makeText(this, ((retrofit2.HttpException) throwable).code() + ":服务器问题", Toast.LENGTH_SHORT).show();
        } else if (throwable instanceof SocketException) {
            Toast.makeText(this, "网络异常!", Toast.LENGTH_SHORT).show();
        } else if (throwable instanceof UnknownHostException) {
            Toast.makeText(this, "网络异常!", Toast.LENGTH_SHORT).show();
        } else if (throwable instanceof SocketTimeoutException) {
            Toast.makeText(this, "连接超时!", Toast.LENGTH_SHORT).show();
        } else {
            Toast.makeText(this, throwable.toString(), Toast.LENGTH_SHORT).show();
        }
    }

或者在特定 View LoginActivity中重写onRxError(RxError)方法，单独响应Tag为LoginAction.LOGIN的RxError。

    @Override
    @Subscribe(sticky = true)
    public void onRxError(@NonNull RxError rxError) {
        if (TextUtils.equals(rxError.getTag(), LoginAction.LOGIN)) {
           //单独处理操作异常...
        }
    }

4. 操作异常重试通知RxRtry

4.1 ActionCreator 操作并发送

在FriendActionCreator中使用postHttpRetryAction(RxAction, Observable<T>)方法，如果操作有异常，会发送异常重试通知RxRetry

    @Override
    public void getFriendList() {
        RxAction rxAction = newRxAction(FriendAction.GET_FRIEND_LIST);
        postHttpRetryAction(rxAction, mWanApi.getFriendList());
    }

4.2 View 接收

在BaseActivity中全局响应RxRetry，可以使用RxActionCreator中的postRetryAction(RxRetry)方法重试。

    @Subscribe(sticky = true)
    public void onRxRetry(@NonNull RxRetry rxRetry) {
        CoordinatorLayout coordinatorLayout = findViewById(R.id.cdl_content);
        if (coordinatorLayout == null) {
            return;
        }
        Snackbar snackbar = Snackbar.make(coordinatorLayout, rxRetry.getTag(), Snackbar.LENGTH_INDEFINITE);
        snackbar.setAction("Retry", v -> mCommonActionCreatorLazy.get().postRetryAction(rxRetry)).show();
    }

或者在特定 View 中重写onRxRetry(RxRetry)方法，单独响应特定Tag的RxRetry。

    @Override
    @Subscribe(sticky = true)
    public void onRxRetry (@NonNull RxRetry rxRetry) {
        if (TextUtils.equals(rxRetry.getTag(), FriendAction.GET_FRIEND_LIST)) {
            //单独处理异常重试...
        }
    }

源码

开源模块化解耦框架RxFluxArchitecture，欢迎大家点赞Fork，更欢迎点评指导。