Retrofit源码分析

天地不仁以万物为刍狗

终于下定决心开始自己的第一篇技术博客了，有些事最难的或许就是开头了吧，希望能从此一发不可收拾，一日不写bug浑身难受，好吧，是blog。

我们的项目或多或少用到第三方框架，这些框架用起来到是很爽，但如果你不想做一条咸鱼的话请读懂它，改造它，蹂躏它，最后在抛弃它自己写一套。

装逼专用

如上图所示我就是装个B，今天也就是分析下Retrofit源码，我对框架的了解分三种

• 知其然
• 知其所以然
• 造其然

知其然

Retrofit是一款restful风格的框架，是基于OkHttp的一种高度封装，基本使用方法

public interface MovieService { 

        @GET("top250") 
        Call<MovieEntity> getTopMovie(@Query("start") int start, @Query("count") int count)；
        
        @POST("/form")
        @FormUrlEncoded
        Call<ResponseBody> submit(@Field("username") String name, @Field("token") String token);
}

原生态Retrofit使用

//进行网络请求
private void getMovie(){
    String baseUrl = "https://api.douban.com/v2/movie/";

    Retrofit retrofit = new Retrofit.Builder()
            .baseUrl(baseUrl)
            .addConverterFactory(GsonConverterFactory.create())
            .build();

    MovieService movieService = retrofit.create(MovieService.class);
    Call<MovieEntity> call = movieService.getTopMovie(0, 10);
    call.enqueue(new Callback<MovieEntity>() {
        @Override
        public void onResponse(Call<MovieEntity> call, Response<MovieEntity> response) {
            resultTV.setText(response.body().toString());
        }

        @Override
        public void onFailure(Call<MovieEntity> call, Throwable t) {
            resultTV.setText(t.getMessage());
        }
    });
}

添加Rxjava

Retrofit retrofit = new Retrofit.Builder()
        .baseUrl(baseUrl)
        .addConverterFactory(GsonConverterFactory.create())//基础数据解析库，默认gson，也可使用xml等
        .addCallAdapterFactory(RxJavaCallAdapterFactory.create())//添加rxjava支持，adpter模式
        .build();

这样一来我们定义的service返回值就不在是一个Call了，而是一个Observable（还有Completable,Single,后面源码在细说）。
重新定义MovieService

public interface MovieService {
    @GET("top250")
    Observable<MovieEntity> getTopMovie(@Query("start") int start, @Query("count") int count);
}

再次调用

//进行网络请求
private void getMovie(){
    String baseUrl = "https://api.douban.com/v2/movie/";

    Retrofit retrofit = new Retrofit.Builder()
            .baseUrl(baseUrl)
            .addConverterFactory(GsonConverterFactory.create())
            .addCallAdapterFactory(RxJavaCallAdapterFactory.create())
            .build();

    MovieService movieService = retrofit.create(MovieService.class);

    movieService.getTopMovie(0, 10)
            .subscribeOn(Schedulers.io())
            .observeOn(AndroidSchedulers.mainThread())
            .subscribe(new Subscriber<MovieEntity>() {
                @Override
                public void onCompleted() {
                    Toast.makeText(MainActivity.this, "Get Top Movie Completed", Toast.LENGTH_SHORT).show();
                }

                @Override
                public void onError(Throwable e) {
                    resultTV.setText(e.getMessage());
                }

                @Override
                public void onNext(MovieEntity movieEntity) {
                    resultTV.setText(movieEntity.toString());
                }
            });
}

一定很失望吧，对，Retrofit的使用我就想写这么多，因为我的重点是源码分析，从源码分析Retrofit的使用及技巧，我们的目标是知其所以然

比较全面的Retrofit使用可以参考https://blog.csdn.net/carson_ho/article/details/73732076