通过rx我们到底需要了解什么并且编码习惯有什么

2020-03-05 01:15 来源:未知

这一节并不讲解什么rx的技术只是一个学渣学习一段时间的概括!

上一篇中简单介绍了mvp的概念和retrofit的基本使用,本篇主要是将rxjava和retrofit结合起来使用,并搭建mvp rxajva retrofit的demo;没有rxjava和retrofit基础的,建议先去看上一篇:
Android 搭建MVP Retrofit RxJava网络请求框架(一)

我刚又回过头来看了下上周的内容,上周是用自带的jdbctemplate 而且关键是还要在xml中进行配置各种dao我主要嫌这个麻烦,而且貌似里面的各种增删改查得自己写sql就比较麻烦。而这周的采用注解的方式可以自动建表,而且通过配置对其进行了封装,简化了很多操作。那么我又想到了最新的jpa是个啥玩意呢,该怎么用呢,还有是不是应该有模板什么的能一键生成增删改查呢?这个留到后面再说 我已经完成了后台,并新增了一个登录接口和注册接口目前自测OK。


以下纯属个人观点。只是借鉴作用。如果对您有帮助,那么就是我对大家一点的贡献。学习么,仁者见仁智者见智。

下面我们来看一下RxJava和retrofit的结合使用,为了使Rxjava与retrofit结合,我们需要在Retrofit对象建立的时候添加一句代码:

那么现在开始客户端。先前就说了会采用mvp retrofit rxjava的方式。那么我先来回顾下以前我遇到的项目中数据流怎么操作的

=====

RXjava从1到2 如果你听说过 了解过。那么你就会知道这个确实是一个و✧,但是我相信真正在自己项目中用到的可能真的没有那么多。这是为什么?“”习惯“”。

addCallAdapterFactory(RxJava2CallAdapterFactory.create())

1.我最早的项目是用httpclient封装后 继承统一接口回调的方式来实现的,通过每个activity里面写回调

1.RX依赖 

      compile 'io.reactivex.rxjava2:rxandroid:2.0.1'

      compile 'io.reactivex.rxjava2:rxjava:2.1.0'

      Github上的源码:

       rxjava地址:

      rxandroid github 地址:

大家新入门也好。工作几年也罢。相信大家都有一个这么过程。一开始大家接触的都是小的不大的app,那么这就不涉及到太复杂的结构设计。mvc完全可以。甚至会更加简单。在activity中就进行自己的操作。需要封装就自己封装一个calss,需要的时候在自己使用。这个其实是致命的相信大家都会遇到过这种情形。自己做的OK了。现在突然产品设计更改了。以前的好多没用了,需要从写。大量代码的更改。注释。等。很繁琐。并且一个地方可能涉及到多个地方的更改。大家现在想想这个是为什么?为什么会出现这种情况,能不能更改 “”有“”

当然你还需要在build.gradle文件中添加如下依赖:

2.通过传入handler配合intentservice或者线程等

2.RX基本概念

mvp等很多种应运而生。你要知道知道为什么会出现mvp? "解耦"(通俗来讲 我改动一个地方就只是改动这个地方,不用涉及到太多的地方。方便我的更改,有点跑题了。前期有一个好的习惯很重要)

compile 'com.squareup.retrofit2:adapter-rxjava2:2.2.0'

3.eventbus(优点 任意地方 随时调用 缺点管理麻烦)

2.1.观察者:Observer,

       监视着被观察者的行为,当被观察者某个状态改变的时候会通知观察者,观察者会执行对应的操作;

咱们回到正轨。RX 这是一种怎么样的改变? 请让我给大家举一个例子

本篇中所用的是rxjava2,完整的代码如下:

4.就是今天我想着重介绍的这种模式。

2.2.被观察者:Observable

        被监视的对象,当某个状态改变的时候会通知观察者;

大家都知道咖啡 1 我自己磨咖啡豆 自己 去煮 全程我都要参与 并且时刻要观察变化

Retrofit retrofit = new Retrofit.Builder()
        .baseUrl("https://api.douban.com/v2/")
        .addConverterFactory(GsonConverterFactory.create(new 
         GsonBuilder().create()))
        .addCallAdapterFactory(RxJava2CallAdapterFactory.create())//支持RxJava
        .build();

上面几种的传统方式 代码量少 但逻辑复杂起来也是挺复杂的,虽然我以前也会把公共方法抽出来,但有的时候写写还是挺乱的。而且有很多操作是在view里面 然后调其他公共类里面的方法去操控数据库啊 做处理啊 最后展示的这种方式。其实就是传统的MVC,即Model控制view 当数据Model发生变化 回给activity来让其改变 activity即是view 而view中又能控制control即我们各个处理数据的逻辑,control又能控制model的改变的这样一个过程。

2.3.订阅.subscribe()

        将观察者和被观察者建立联系。

2 懒人的做法 我用咖啡机。我按一下按钮 我就干别的就好了。 当完成的时候 “提示音就会想起”

然后我们还需要修改RetrofitService 中的代码:

那MVP呢简而言之 就是view和model做了分离 统一来由Presenter来进行双向控制

2.4.举例

         其实在android中也有类似的例子:  textview.setOnClick(new OnClickListener()) ,在上述的例子中textview就是被观察者,OnClickListener就是观察者,setOnClick()就是把两者关联起来的桥梁,同理subscribe()就是如同setOnClick()的角色

上面的例子 大家能够想到点什么吗?“”设计模式~观察者模式“”

public interface RetrofitService {
    @GET("book/search")
    Observable<Book> getSearchBook(@Query("q") String name,
                                    @Query("tag") String tag, @Query("start") int start,
                                    @Query("count") int count);

图片 1

2.5.代码介绍

图片 2

       观察者中的

      onError():事件队列异常。在事件处理过程中出异常时,onError()会被触发,同时队列自动终止,不允许再有事件发出。

      onNext():表示处理观察到的事件

      onCompleted():事件队列完结

      onSubscribe(Disposable d ):表示当观察者被订阅时的回调一般进行一些预处理,最开始被调用的地方,如果要截断发送事件只用调用d.dispose(),观察者就不会接收到事件了!

当我作为观察者和咖啡机形成一种关系~订阅(我想和咖啡我按下按钮之后)我们的关系就已经形成了,剩下的我不需要去花时间去照看。当咖啡好了。我会受到提示,咖啡机坏了 我也会受到提示 相比于第一种 我们无疑要省下很多时间。对app来说 也就是内存

可以看到,在原来的RetrofitService 中我们把getSearchBook方法返回的类型Call改为了Observable,也就是被观察者。其他都没变。然后就是创建RetrofitService 实体类:

那么究竟是如何做到的呢?Presenter以下简称P 常用做法是往其中注入model 再暴露接口给view继承以便通知view即activity对应做出更改。简单来说就是这么简单的啊,没有任何其他的复杂难度,但是为什么还要用一个中间组件contact来进行关联呢?这么做的好处是什么呢?官方写的是:使用契约类来统一管理view与presenter的所有的接口,这种方式使得view与presenter中有哪些功能,一目了然,维护起来也很方便。可这么做的缺点就是对应任意一个类 复用好像就很困难了,不管是采用设置多个presenter还是或者采用接口继承的方式 两个页面 除非用接口的方式可插拔 不然我觉得还是挺困难的。

3.RX简写

    有时候我们只关注观察者中OnNext()方法,并不关心其他方法。Subscribe()重载了多个方法,可以让我们只关注其中的onNext方法。被观察者要调用观察者的onNext()方法:如下面的代码

图片 3

      用ObservableEmitter对象来调用onNext方法,但是我们可以简写成:

      同时我们可以将被观察者封装成List数组,用fromIterable(list)来发送事件

RX的这个订阅的过程也就是观察者模式,并且 还是一种流的形式你想进行的任何操作都可以在这个流上面进行。这个也就是操作符的作用。

RetrofitService service = retrofit.create(RetrofitService.class);
和上面一样,创建完RetrofitService ,就可以调用里面的方法了:

目前大部分都市采用抽象类 写base 然后继承。我看了一些封装,目前使用的是android fire 开源的这种。分析了其中的流程如下,如有不对的可以提醒我。传统做法presenter在onresume里面 attach 在ondestroy中detach 可以防止内存泄露。这里面他是这么封装的

4.RX常用数据操作符

当你真的用到时候 你就会发现 方便,思路易于理解。是他最大的优点

Observable<Book> observable = service.getSearchBook("人间失格", null, 0, 1);
其实这一步,就是创建了一个rxjava中observable,即被观察者,有了被观察者,就需要一个观察者,且订阅它:

图片 4

4.1.Filter

         顾名思义就是对发送过来的数据源进行过滤,筛选出符合条件的。

图片 5

observable.subscribeOn(Schedulers.io())//请求数据的事件发生在io线程
          .observeOn(AndroidSchedulers.mainThread())//请求完成后在主线程更显UI
          .subscribe(new DisposableObserver<Book>() {//订阅
              @Override
              public void onComplete() {
                  //所有事件都完成,可以做些操作。。。
              }
              @Override
              public void onError(Throwable e) {
                  e.printStackTrace(); //请求过程中发生错误
              }
              @Override
              public void onNext(Book book) {//这里的book就是我们请求接口返回的实体类    
              }
           }

图片 6

4.2.Map 

图片 7

从上面的例子我们可以看出这个map()操作符是可以对数据进行转化

在上面中我们可以看到,事件的消费在Android主线程,所以我们还要在build.gradle中添加如下依赖:

图片 8

4.3.flatMap

将被观察者的事件重新解析转化成新的被观察者对象数组,但是并不保证发送的顺序

如果想要保证发送的顺序,需要用concatMap()操作符来保证!

应用场景:找到这个部门下所有警员的名字

compile 'io.reactivex.rxjava2:rxandroid:2.0.1'

他这么封装 是可以兼容传统app和mvp的 如果你不想使用mvp模式 直接继承base后面不带泛型自然tutils取不到对应参数就不会给P赋值context,给P赋值context我想也是为了更方便的操纵view吧。那么究竟申明了activity中的p和model后他们是怎么关联的,我们往下看。

5.RX线程切换

subscribeOn()发送事件产生的线程

observeOn()指定事件消耗的线程

Schedulers.newThread():产生一个新的线程,效率低于Schedulers.io

Schedulers.io():代表io操作的线程,通常用于网络,读写文件等io密集型的操作

AndroidSchedulers.mainThread():主线程,即UI线程

Schedulers.computation():代表CPU计算密集型的操作,例如需要大量计算的操作

同时observeOn(),subscribeOn()可以多次调用,意味着可以多次切换线程

这样我们就引入了RxAndroid,RxAndroid其实就是对RxJava的扩展。比如上面这个Android主线程在RxJava中就没有,因此要使用的话就必须得引用RxAndroid。

通过initpresenter方法,mPresenter.setVM(this,mModel);我们给P设置了这两个变量。那view以及数据的变化呢,难道设了这两个他们就关联了?这个时候RxJava隆重登场。

6.解决RxJava引起的内存泄露

如果工作线程没有执行结束就退出fragment或者activity,就无法释放线程中持有的资源,比如context等,引起内存泄露。所以需要用Rxlifecycle框架来解决这个问题。需要依赖的编译:

compile 'com.trello:rxlifecycle:1.0'

compile 'com.trello:rxlifecycle-components:1.0'

Github 例子:https://github.com/trello/RxLifecycle

以上的例子是用rxlifecycle-compose

实践

Rxjava其实就是个观察者模式。里面obsever为观察者,obervaral为被观察者,由被观察者注册观察者,然后当被观察者有变化就可以发送onnext或者自定义事件来通知观察者来进行改变。

7.与Retrofit共同使用

现在主流的网络框架是Retrofit,而且Retrofit提供了RxJava完美入口。Rxjava2.x需要额外依赖

compile 'com.jakewharton.retrofit:retrofit2-rxjava2-adapter:1.0.0'

图片 9

平时如果activity退出的时候我们要在onDestroy()方法中写入call.cancel();防止子线程回到主线程更新UI,这时候会引起app崩溃

但是Retrofit和RxJava结合的时候,我们要保存Disposable对象,在onDestroy时候调用dispose()方法,如果有多个Disposble(多次的网络请求),用容器CompositeDisposable.add();

取消的时候CompositeDisposable.clear();

图片 10

图片 11

欢迎大家继续封装

8.背压介绍

在rxjava中会经常遇到一种情况就是被观察者发送消息太快以至于它的操作符或者订阅者不能及时处理相关的消息。那么随之而来的就是如何处理这些未处理的消息

最后,为了大家更好的理解backpressure概念,这里补充说一下Flowable。

Observable在RxJava2.0中新的实现叫做Flowable, 同时旧的Observable也保留了。因为在 RxJava1.x 中,有很多事件不被能正确的背压,从而抛出MissingBackpressureException。

举个简单的例子,在RxJava1.x 中的 observeOn, 因为是切换了消费者的线程,因此内部实现用队列存储事件。在Android中默认的 buffersize 大小是16,因此当消费比生产慢时, 队列中的数目积累到超过16个,就会抛出MissingBackpressureException, 初学者很难明白为什么会这样,使得学习曲线异常得陡峭。

而在2.0 中,Observable 不再支持背压,而Flowable 支持非阻塞式的背压。Flowable是RxJava2.0中专门用于应对背压(Backpressure)问题。所谓背压,即生产者的速度大于消费者的速度带来的问题,比如在Android中常见的点击事件,点击过快则经常会造成点击两次的效果。其中,Flowable默认队列大小为128。并且规范要求,所有的操作符强制支持背压。幸运的是, Flowable 中的操作符大多与旧有的 Observable 类似。

背压产生原因,请参考某位大神的博客:http://blog.csdn.net/jdsjlzx/article/details/52717636

接下来我们就看看,在一个项目中上面三者是如何配合的。我们打开Android Studio,新建一个项目取名为MVPSample。这个demo的功能也很简单,就是点击按钮调用上面的那个测试接口,将请求下来书的信息显示在屏幕上。首先我们来看一下这个工程的目录结构:

这个里面谁是被观察者,谁是观察者呢?自然数据model是被观察者,Presenter是观察者,那么如何把model变成obervable把Presenter变成obersver呢,contact的作用就来了!

图片 12

图片 13

项目结构图.png

contact直接给你强制说了 model的返回是啥  view即activity中需要复写的方法是啥 以及P中要对应操作是啥。但是还是没有看到啥时候关联二者的 继续往下看具体实现。

我们可以看到,在项目的包名下,我们建了主要的文件夹:bean、data、presenter,ui;分别对应不同的功能。其中app文件夹中可以建一个Application类,用于设置应用全局的一些属性,这里为了使项目更加简单就没有添加;然后,我们再来看看ui文件夹下,这个文件夹下主要放一些关于界面的东西。在里面我们又建了三个文件夹:activity、adapter、fragment,我想看名字你就清楚里面要放什么了。RetrofitHelper和APiService。RetrofitHelper主要用于Retrofit的初始化:

图片 14

public class RetrofitHelper {

    private Context mCntext;

    OkHttpClient client = new OkHttpClient();
    GsonConverterFactory factory = GsonConverterFactory.create(new GsonBuilder().create());
    private static RetrofitHelper instance = null;
    private Retrofit mRetrofit = null;
    public static RetrofitHelper getInstance(Context context){
        if (instance == null){
            instance = new RetrofitHelper(context);
        }
        return instance;
    }
    private RetrofitHelper(Context mContext){
        mCntext = mContext;
        init();
    }

    private void init() {
        resetApp();
    }

    private void resetApp() {
        mRetrofit = new Retrofit.Builder()
                .baseUrl(ApiService.BASE_URL)
                .client(client)
                .addConverterFactory(factory)
                .addCallAdapterFactory(RxJava2CallAdapterFactory.create())
                .build();
    }
    public ApiService getServer(){
        return mRetrofit.create(ApiService.class);
    }
}

图片 15

代码并不复杂,其中resetApp方法,就是前面介绍的Retrofit的创建,getServer方法就是为了获取ApiService接口类的实例化。然后定义了一个静态方法getInstance用于获取自身RetrofitHelper的实例化,并且只会实例化一次。

这一下是否明白了呢,原来P中在实现各种操作的时候就用rxjava对2者进行了关联 只要数据发生了变化,就可以在回调中调用view即对应activity中的view发生变化 ,刚好retrofit可以直接将返回的结果自动转换成oberservble被观察者。

在正式的项目中model,view,presenter都需要根据需求创建对应的BaseView,BaseModel,BasePresenter;当前demo中只是简单创建,后再后续封装中继续完善框架。
先创建一个BookInfoContract

Rxjava还有个好处就是比如回给你的是个字符串你可以转化为对象 通过map或者转化城任意你需要的东西,而flatmap则可以一个Observral变为另一个oberserval 总之给人的感觉就是方便,框架介绍完了,本周的学习内容到此结束。

public interface BookInfoContract {
    interface IView extends BaseView {

        void showResult(String  msg);

//        void onRequestPermissionSuccess();
//
//        void onRequestPermissionSError();
    }

     interface IBookModel {

        Observable<Book> getBookMsg(String name,String tag,int start,int count);

    }

}

这是采用google官方demo的写法,将相关的view和model接口写到一个协议接口类中。方便查找和管理,每一个view,model,presenter都有对应的接口类相对应,这种写法虽然类增加了,但是便于解耦,改动和维护方便;
具体实现步骤如下:

  1. 创建BookInfoModel,实现接口,并重写获取数据的方法
public class BookInfoModel implements BookInfoContract.IBookModel {

    private ApiService mApiService;

    public BookInfoModel(ApiService mApiService) {
        this.mApiService = mApiService;
    }

    @Override
    public Observable<Book> getBookMsg(String name, String tag, int start, int count) {
        return mApiService.getSearchBooks(name, tag, start, count);
    }
}

2.创建presenter,通过构造传入需要关联的view,并初始化model;在getMsg()方法中,通过model中
getBookMsg()方法返回的被观察者进入线程切换和事件订阅;在订阅回调中,调用view的方法对请求的结果进行处理;一般presenter持有view的引用,增加了耦合性,后面会进行优化处理

public class BookPresenter {

    private BookInfoContract.IView mView;
    private BookInfoModel bookInfoModel;
    private Book mBook;

    public BookPresenter(BookInfoContract.IView mView) {
        this.mView = mView;
        bookInfoModel = new BookInfoModel(RetrofitHelper.getInstance((Context) mView).getServer());
    }

    //获取数据
    public void getMsg(String name, String tag, int start, int count) {
        bookInfoModel.getBookMsg(name, tag, start, count)
                .subscribeOn(Schedulers.io())
                .observeOn(AndroidSchedulers.mainThread())
                .subscribe(new Observer<Book>() {
                    @Override
                    public void onSubscribe(Disposable d) {

                    }

                    @Override
                    public void onNext(Book value) {
                        mBook = value;
                    }

                    @Override
                    public void onError(Throwable e) {
                        e.printStackTrace();
                        mView.showError("请求失败");
                    }

                    @Override
                    public void onComplete() {
                        if (mView != null) {
                            mView.showResult(mBook.toString());
                        }
                    }
                });

    }
}

3.在mainActivity中实现接口 BookInfoContract.IView;通过注解初始化控件(在onDestroy中进行接触注解)并获取初始化presenter,在控件监听事件中。调用presenter的方法获取数据;

经过以上几步基本完成了mvp rxjava retrofit的框架搭建
项目地址:https://github.com/cruiseliang/MvpSample

TAG标签:
版权声明:本文由美高梅网投平台发布于美高梅网投网址,转载请注明出处:通过rx我们到底需要了解什么并且编码习惯有什么