Android 教你一步步搭建MVP+Retrofit+RxJava网络请求框架

好了，添加完该库，我们再来看看如何使用，首先我们来建一个实体类Book，用于装网络请求后返回的数据。这里顺带说一下，有的人建一个实体类时可能会根据浏览器中返回中的数据一行一行敲，其实这样非常麻烦，这里教大家一个简单的方法，瞬间生成一个实体类。没错有的人可能用过，我们需要一个插件GsonFormat。它的使用也很简单，首先需要在Android Studio中下载，点击左上角菜单栏中的File,然后点击Settings，在弹窗中选择Plugins,然后点击下方的Browse repositories...

 

然后在新打开的窗口中搜索GsonFormat，点击右侧绿色按钮就可以下载安装了，安装完需要重启下studio，就可以用了。

 

它的用法也很简单，比如你先建立一个新的空类取名Book，然后在里面按Alt+insert,会有个小弹窗选择GsonFormat,之后在弹出的编辑框中拷入在浏览器中请求下来的那一坨东西，然后一直点ok就会自动生成字段，以及set和get方法，一会儿我们用Retrofit请求下来的数据都会保存在这个实体类中，还是挺方便的。最后我们里面添加一个toString()方法，用于后面显示方便。

• GET ----------查找资源（查）
• POST --------修改资源（改）
• PUT ----------上传文件（增）
• DELETE ----删除文件（删）
• HEAD--------只请求页面的首部

然后我们来看一下这个方法的返回值，它返回Call实体，一会我们要用它进行具体的网络请求，我们需要为它指定泛型为Book也就是我们数据的实体类。接下来，你会发现这个方法的入参和我们平时方法的入参还不大一样。在每个入参前还多了一个注解。比如第一个入参@Query("q") String name，Query表示把你传入的字段拼接起来，比如在测试url中我们可以看到q=金瓶梅的入参，那么Query后面的值必须是q，要和url中保持不变，然后我们定义了String类型的name，当调用这个方法是，用于传入字符串，比如可以传入“金瓶梅”。那么这个方法就会自动在q后面拼上这个字符串进行网络请求。以此类推，这个url需要几个入参你就在这个方法中定义几个入参，每个入参前都要加上Query注解。当然Retrofit除了Query这个注解外，还有其他几个比如：@QueryMap、@Path、@Body、@FormUrlEncoded/@Field、@Header/@Headers。我们来看一下他们的区别:

@Query(GET请求):

用于在url后拼接上参数，例如：

@GET("book/search")
Call<Book> getSearchBook(@Query("q") String name);//name由调用者传入

相当于：

@GET("book/search?q=name")
Call<Book> getSearchBook();

@QueryMap(GET请求):

当然如果入参比较多，就可以把它们都放在Map中，例如：

@GET("book/search")
Call<Book> getSearchBook(@QueryMap Map<String, String> options);

@Path(GET请求):

用于替换url中某个字段，例如：

@GET("group/{id}/users")
Call<Book> groupList(@Path("id") int groupId);

像这种请求接口，在group和user之间有个不确定的id值需要传入，就可以这种方法。我们把待定的值字段用{}括起来，当然 {}里的名字不一定就是id，可以任取，但需和@Path后括号里的名字一样。如果在user后面还需要传入参数的话，就可以用Query拼接上，比如：

@GET("group/{id}/users")
Call<Book> groupList(@Path("id") int groupId,@Query("sort") String sort);

当我们调用这个方法时，假设我们groupId传入1，sort传入“2”，那么它拼接成的url就是group/1/users?sort=2，当然最后请求的话还会加上前面的baseUrl。

@Body(POST请求):

可以指定一个对象作为HTTP请求体,比如：

@POST("users/new")
Call<User> createUser(@Body User user);

它会把我们传入的User实体类转换为用于传输的HTTP请求体，进行网络请求。

@Field(POST请求):

用于传送表单数据：

@FormUrlEncoded
@POST("user/edit")
Call<User> updateUser(@Field("first_name") String first, @Field("last_name") String last);

注意开头必须多加上@FormUrlEncoded这句注释，不然会报错。表单自然是有多组键值对组成，这里的first_name就是键，而具体传入的first就是值啦。

@Header/@Headers(POST请求):

用于添加请求头部：

@GET("user")
Call<User> getUser(@Header("Authorization") String authorization)

表示将头部Authorization属性设置为你传入的authorization；当然你还可以用@Headers表示,作用是一样的比如：

@Headers("Cache-Control: max-age=640000")
@GET("user")
Call<User> getUser()

当然你可以多个设置：

@Headers({
    "Accept: application/vnd.github.v3.full+json",
    "User-Agent: Retrofit-Sample-App"
})
@GET("user")
Call<User> getUser()

这样我们就把上面这个RetrofitService 接口类解释的差不多了。我觉得，Retrofit最主要的也就是这个接口类的定义了。

有了这个接口类，我们来看一下，到底如何使用这个我们定义的接口来进行网络请求。代码如下：

然后我们调用retrofit的create方法并传入上面我们定义的接口的文件名RetrofitService.class，就可以得到RetrofitService 的实体对象。有了这个对象，我们就可以调用里面之前定义好的请求方法了。比如：

Call<Book> call =  service.getSearchBook("金瓶梅", null, 0, 1);

它会返回一个Call实体类，然后就可以调用Call的enqueue方法进行异步请求，在enqueue方法中传入一个回调CallBack，重写里面的onResponse和
onFailure方法，也就是请求成功和失败的回调方法。当成功时，它会返回Response，里边封装了请求结果的所有信息，包括报头，返回码，还有主体等。比如调用它的body()方法就可获得Book对象，也就是我们需要的数据。这里我们就把返回的Book，显示屏幕上。如下图：

Book中的数据

好了，到这里我们就基本了解了Retrofit的整个工作流程。

3.RxJava

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);

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

RetrofitService service = retrofit.create(RetrofitService.class);

Observable<Book> observable =  service.getSearchBook("金瓶梅", null, 0, 1);

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

compile 'io.reactivex:rxandroid:1.2.0'

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

4.实践

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

工程目录

我们可以看到，在项目的包名下，我们建了三个主要的文件夹：app、service、ui。当然根据项目的需要你也可以添加更多其他的文件夹，比如一些工具类等。其中app文件夹中可以建一个Application类，用于设置应用全局的一些属性，这里为了使项目更加简单就没有添加；然后，我们再来看看ui文件夹下，这个文件夹下主要放一些关于界面的东西。在里面我们又建了三个文件夹：activity、adapter、fragment，我想看名字你就清楚里面要放什么了。最后我们在重点看看service文件夹中的东西。首先我们来看看里面重要的两个类：RetrofitHelper和RetrofitService。RetrofitHelper主要用于Retrofit的初始化：

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("https://api.douban.com/v2/")
                .client(client)
                .addConverterFactory(factory)
                .addCallAdapterFactory(RxJavaCallAdapterFactory.create())
                .build();
    }
    public RetrofitService getServer(){
        return mRetrofit.create(RetrofitService.class);
    }
}

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

接下来，看一下RetrofitService，其中代码还是上面一样：

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

 

然后我们依次来看一下service文件夹下的四个文件夹：entity、manager、presenter和view。其中entity下放我们请求的实体类，这里就是Book。接下来我们来看一下manager中DataManager。这个类其实就是为了让你更方便的调用RetrofitService 中定义的方法：

public class DataManager {
    private RetrofitService mRetrofitService;
    public DataManager(Context context){
        this.mRetrofitService = RetrofitHelper.getInstance(context).getServer();
    }
    public  Observable<Book> getSearchBooks(String name,String tag,int start,int count){
        return mRetrofitService.getSearchBooks(name,tag,start,count);
    }
}

 可以看到，在它的构造方法中，我们得到了RetrofitService 的实例化，然后定义了一个和RetrofitService 中同名的方法，里面其实就是调用RetrofitService 中的这个方法。这样，把RetrofitService 中定义的方法都封装到DataManager 中，以后无论在哪个要调用方法时直接在DataManager 中调用就可以了，而不是重复建立RetrofitService 的实例化，再调用其中的方法。

好了，我们再来看一下presenter和view，我们在前面说过，presenter主要用于网络的请求以及数据的获取，view就是将presenter获取到的数据进行展示。首先我们先来看view，我们看到我们建了两个接口类View和BookView,其中View是空的，主要用于和Android中的View区别开来：

public interface View {
}

然后让BookView继承自我们自己定义的View ：

public interface BookView extends View {
    void onSuccess(Book mBook);
    void onError(String result);
}

可以看到在里面定义两个方法，一个onSuccess，如果presenter请求成功，将向该方法传入请求下来的实体类，也就是Book，view拿到这个数据实体类后，就可以进行关于这个数据的展示或其他的一些操作。如果请求失败，就会向这个view传入失败信息，你可以弹个Toast来提示请求失败。通常这两个方法比较常用，当然你可以根据项目需要来定义一些其他的方法。接下来我们看看presenter是如何进行网络请求的 。我们也定义了一个基础Presenter：

public interface Presenter {
    void onCreate();

    void onStart();//暂时没用到

    void onStop();

    void pause();//暂时没用到

    void attachView(View view);

    void attachIncomingIntent(Intent intent);//暂时没用到
}

 里面我们可以看到，定义了一些方法，前面几个onCreate、onStart等方法对应着Activity中生命周期的方法，当然没必要写上Activity生命周期中所有回调方法，通常也就用到了onCreate和onStop，除非需求很复杂，在Activity不同生命周期请求的情况不同。接着我们定义了一个attachView方法，用于绑定我们定义的View。也就是，你想把请求下来的数据实体类给哪个View就传入哪个View。下面这个attachIncomingIntent暂且没用到，就不说了。好了，我们来看一下BookPresenter具体是怎么实现的：

public class BookPresenter implements Presenter {
    private DataManager manager;
    private CompositeSubscription mCompositeSubscription;
    private Context mContext;
    private BookView mBookView;
    private Book mBook;
    public BookPresenter (Context mContext){
        this.mContext = mContext;
    }
    @Override
    public void onCreate() {
        manager = new DataManager(mContext);
        mCompositeSubscription = new CompositeSubscription();
    }

    @Override
    public void onStart() {

    }

    @Override
    public void onStop() {
        if (mCompositeSubscription.hasSubscriptions()){
            mCompositeSubscription.unsubscribe();
        }
    }

    @Override
    public void pause() {

    }

    @Override
    public void attachView(View view) {
        mBookView = (BookView)view;
    }

    @Override
    public void attachIncomingIntent(Intent intent) {
    }
    public void getSearchBooks(String name,String tag,int start,int count){
        mCompositeSubscription.add(manager.getSearchBooks(name,tag,start,count)
                .subscribeOn(Schedulers.io())
                .observeOn(AndroidSchedulers.mainThread())
                .subscribe(new Observer<Book>() {
                    @Override
                    public void onCompleted() {
                        if (mBook != null){
                            mBookView.onSuccess(mBook);
                        }
                    }

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

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

 BookPresenter实现了我们定义的基础Presenter，在onCreate中我们创建了DataManager的实体类，便于调用RetrofitService中的方法，还新建了一个CompositeSubscription对象，CompositeSubscription是用来存放RxJava中的订阅关系的。注意请求完数据要及时清掉这个订阅关系，不然会发生内存泄漏。可在onStop中通过调用CompositeSubscription的unsubscribe方法来取消这个订阅关系，不过一旦调用这个方法，那么这个CompositeSubscription也就无法再用了，要想再用只能重新new一个。然后我们可以看到在attachView中，我们把BookView传进去。也就是说我们要把请求下来的实体类交给BookView来处理。接下来我们定义了一个方法getSearchBooks，名字和入参都和请求接口RetrofitService中的方法相同。这里的这个方法也就是请求的具体实现过程。其实也很简单，就是向CompositeSubscription添加一个订阅关系。上面我们已经说过manager.getSearchBooks就是调用RetrofitService的getSearchBooks方法，而这个方法返回的是一个泛型为Book的Observable，即被观察者，然后通过subscribeOn(Schedulers.io())来定义请求事件发生在io线程，然后通过observeOn(AndroidSchedulers.mainThread())来定义事件在主线程消费，即在主线程进行数据的处理，最后通过subscribe使观察者订阅它。在观察者中有三个方法：onNext、onCompleted、onError。当请求成功话，就会调用onNext，并传入请求返回的Book实体类，我们在onNext中，把请求下来的Book实体类存到内存中，当请求结束后会调用onCompleted，我们把请求下来的Book实体类交给BookView处理就可以了，如果请求失败，那么不会调用onCompleted而调用onError，这样我们可以向BookView传递错误消息。

好了，这样我们我们就可以调用这个接口方法来进行网络的请求了，我们先写一下页面的布局：

<?xml version="1.0" encoding="utf-8"?>
<LinearLayout xmlns:android="http://schemas.android.com/apk/res/android"
    android:id="@+id/activity_main"
    android:layout_width="match_parent"
    android:layout_height="match_parent"
    android:paddingBottom="@dimen/activity_vertical_margin"
    android:paddingLeft="@dimen/activity_horizontal_margin"
    android:paddingRight="@dimen/activity_horizontal_margin"
    android:orientation="vertical"
    android:paddingTop="@dimen/activity_vertical_margin">

    <TextView
        android:id="@+id/text"
        android:layout_width="wrap_content"
        android:layout_height="wrap_content"
        android:text="Hello World!" />
    <Button
        android:id="@+id/button"
        android:onClick="getFollowers"
        android:layout_width="match_parent"
        android:layout_height="wrap_content"
        android:text="请求"/>
</LinearLayout>

 界面很简单，一共两个控件，一个Button，点击时进行网络请求，一个TextView，用于显示请求下来的数据。然后我么看一下Activity中代码：

public class MainActivity extends AppCompatActivity {

    private TextView text;
    private Button button;
    private BookPresenter mBookPresenter = new BookPresenter(this);
    @Override
    protected void onCreate(Bundle savedInstanceState) {
        super.onCreate(savedInstanceState);
        setContentView(R.layout.activity_main);
        text = (TextView)findViewById(R.id.text);
        button = (Button)findViewById(R.id.button);
        button.setOnClickListener(new View.OnClickListener() {
            @Override
            public void onClick(View v) {
                mBookPresenter.getSearchBooks("金瓶梅", null, 0, 1);
            }
        });
        mBookPresenter.onCreate();
        mBookPresenter.attachView(mBookView);
    }

    private BookView mBookView = new BookView() {
        @Override
        public void onSuccess(Book mBook) {
            text.setText(mBook.toString());
        }

        @Override
        public void onError(String result) {
            Toast.makeText(MainActivity.this,result, Toast.LENGTH_SHORT).show();
        }
    };
    @Override
    protected void onDestroy(){
        super.onDestroy();
        mBookPresenter.onStop();
    }
}

 逻辑并不复杂，我们先创建了一个BookPresenter 对象，然后调用它的onCreate方法进行初始化，接着调用attachView来绑定BookView。BookView的实现也很简单，在onSuccess方法中将Book 中内容显示在TextView上，在onError中弹出一个Toast提示。然后点击按钮的时候就调用BookPresenter中getSearchBooks方法，同时传入必要的入参。这样网络请求就开始了，如果请求成功就会回调BookView 中的onSuccess方法，失败就回调onError方法。当活动销毁时记得调用BookPresenter的onStop方法来释放订阅关系，防止内存泄漏。

最后别忘了在AndroidManifest中添加网络权限：

<uses-permission android:name="android.permission.INTERNET"/>

好了，我们运行一下看一下效果：

演示

代码已上传github：MVPDemo