Android Retrofit + RxJava使用详解

封面

1.Retrofit基本使用

首先来了解下Retrofit是什么,在官网中对于Retrofit的描述是这样的:

A type-safe HTTP client for Android and Java.

适用于Android和Java的类型安全的HTTP客户端。

可以理解成一个封装好的网络请求库。

Retrofit GitHub地址

接下来学习一下Retrofit的基本使用方法:

在app根目录的build.gradle文件中加入依赖:

compile 'com.squareup.retrofit2:retrofit:2.3.0'

创建实体类:

我们使用http://www.kuaidi100.com/query?type=yuantong&postid=11111111111 这个快递接口来测试,根据返回数据创建实体类,类名为PostInfo,在这里就不贴代码了,可以在文末下载Demo查看代码。

定义请求参数接口:

public interface RetrofitService {

    /**
     * 获取快递信息
     *
     * @param type   快递类型
     * @param postid 快递单号
     * @return Call<PostInfo>
     */
    @GET("query")
    Call<PostInfo> getPostInfo(@Query("type") String type, @Query("postid") String postid);
}

定义一个接口RetrofitService,和普通的接口类相同,在里面定义一个方法getPostInfo,可以看到这个方法使用了@GET("query")注解,代表这是一个GET请求,请求接口为query(完整请求地址中域名/到?之间的字段),方法返回值为Call<PostInfo>实体,这个稍后会用于具体的网络请求,PostInfo就是我们刚刚定义的实体类。参数中也使用了注解@Query,用于拼接传入的字段(type=yuantong&postid=11111111111)。

网络请求:

Retrofit retrofit = new Retrofit.Builder()
        .baseUrl("http://www.kuaidi100.com/")
        .addConverterFactory(GsonConverterFactory.create())
        .build();
        
RetrofitService service = retrofit.create(RetrofitService.class);
Call<PostInfo> call = service.getPostInfo("yuantong", "11111111111");
call.enqueue(new Callback<PostInfo>() {
    @Override
    public void onResponse(Call<PostInfo> call, Response<PostInfo> response) {
        Log.i("http返回:", response.body().toString() + "");
    }

    @Override
    public void onFailure(Call<PostInfo> call, Throwable t) {

    }
});

可以看到Retrofit使用了Builder模式,首先传入baseUrl,由于返回的数据是json类型的,还需要添加转换工厂类,这需要在build.gradle文件中加入依赖:

compile 'com.squareup.retrofit2:converter-gson:2.3.0'

然后调用Retrofit的create方法创建RetrofitService的实体类,得到实体类之后就可以调用其中的getPostInfo方法并传入参数,getPostInfo方法会返回一个Call实体类,接着调用Call的enqueue方法,传入Callback回调,重写onResponse(请求成功回调)和onFailure(请求失败回调)方法,response参数中包含了请求结果中的所有信息(body、code、headers等)。

OK,到这里Retrofit的基本用法就讲完了,接下来我们来了解一下Retrofit的其他用法。

2.Retrofit更多用法

请求方法

在RetrofitService的getPostInfo方法中,我们使用了@GET注解,说明这是一个GET方法,当然也可以写成HTTP协议中的其他请求方法(比如POST、PUT、DELETE、HEAD等)。

请求参数

在getPostInfo方法的参数中使用了@Query注解,除此之外还可以使用@QueryMap、@Path、@Body、@FormUrlEncoded/@Field、@Multipart/@Part、@Header/@Headers。

  • @Query()
@GET("query")
Call<PostInfo> getPostInfo(@Query("type") String type, @Query("postid") String postid);

相当于

@GET(query?type=type&postid=postid)
Call<PostInfo> getPostInfo(@Query("type") String type, @Query("postid") String postid);
  • @QueryMap

当参数很多的时候可以使用Map集合:

@GET("query")
Call<Book> getSearchBook(@QueryMap Map<String, String> parameters);
  • @Path

用于替换url中的某些字段,当url中字段不确定时可以使用:

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

id可以为任意字段,需要和@Path("id")中的字段保持一致,如果需要请求参数,也可以使用@Query拼接:

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

可以使用实体类作为请求体,Retrofit会帮我们自动转换:

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

用于传送表单数据,注意在头部需要加上@FormUrlEncoded,first_name代表key,first代表value:

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

用于上传文件:

@Multipart
@PUT("user/photo")
Call<User> updateUser(@Part("photo") RequestBody photo, @Part("description") RequestBody description);
  • @Header/@Headers

用于设置请求头:

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

也可以通过@Headers设置:

@Headers("Cache-Control: max-age=640000")
@GET("widget/list")
Call<List<Widget>> widgetList();
@Headers({
    "Accept: application/vnd.github.v3.full+json",
    "User-Agent: Retrofit-Sample-App"
})
@GET("users/{username}")
Call<User> getUser(@Path("username") String username);

转换器

Retrofit支持的序列化库:

  • Gson: com.squareup.retrofit2:converter-gson

  • Jackson: com.squareup.retrofit2:converter-jackson

  • Moshi: com.squareup.retrofit2:converter-moshi

  • Protobuf: com.squareup.retrofit2:converter-protobuf

  • Wire: com.squareup.retrofit2:converter-wire

  • Simple XML: com.squareup.retrofit2:converter-simplexml

  • Scalars (primitives, boxed, and String): com.squareup.retrofit2:converter-scalars

3.Retrofit + RxJava结合使用

如果你对RxJava还不太了解,可以看下这篇文章《给 Android 开发者的 RxJava 详解》

首先在build.gradle文件中加入依赖:

compile 'com.squareup.retrofit2:adapter-rxjava:2.3.0'
compile 'io.reactivex:rxandroid:1.2.1'

将RetrofitService类中getPostInfo方法的返回值修改为Observable(被观察者):

public interface RetrofitService {

    /**
     * 获取快递信息
     * Rx方式
     *
     * @param type   快递类型
     * @param postid 快递单号
     * @return Observable<PostInfo>
     */
    @GET("query")
    Observable<PostInfo> getPostInfoRx(@Query("type") String type, @Query("postid") String postid);
}

在创建Retrofit时添加RxJava支持:

Retrofit retrofit = new Retrofit.Builder()
        .baseUrl("http://www.kuaidi100.com/")
        .addConverterFactory(GsonConverterFactory.create())
        .addCallAdapterFactory(RxJavaCallAdapterFactory.create()) // 支持RxJava
        .build();

获取被观察者:

RetrofitService service = retrofit.create(RetrofitService.class);
Observable<PostInfo> observable = service.getPostInfoRx("yuantong", "11111111111");

订阅:

observable.subscribeOn(Schedulers.io()) // 在子线程中进行Http访问
        .observeOn(AndroidSchedulers.mainThread()) // UI线程处理返回接口
        .subscribe(new Observer<PostInfo>() { // 订阅

            @Override
            public void onCompleted() {

            }

            @Override
            public void onError(Throwable e) {

            }

            @Override
            public void onNext(PostInfo postInfo) {
                Log.i("http返回:", postInfo.toString() + "");
            }
        });

在RxJava中,由于链式调用的影响,是被观察者订阅观察者。

到这里Retrofit + RxJava结合使用就讲完了,由于Retrofit、RxJava属于同门师兄弟,结合使用还是很容易的。

4.Retrofit打印请求参数

Retrofit中无法打印请求参数,由于Retrofit是基于OkHttp进行封装的,可以对OkHttp添加日志拦截器来打印请求参数:

在build.gradle文件中加入依赖:

compile 'com.squareup.okhttp3:logging-interceptor:3.8.0'

OkHttp添加拦截器:

public class RetrofitUtils {

    /**
     * 获取OkHttpClient
     * 用于打印请求参数
     *
     * @return OkHttpClient
     */
    public static OkHttpClient getOkHttpClient() {
        // 日志显示级别
        HttpLoggingInterceptor.Level level = HttpLoggingInterceptor.Level.BODY;
        // 新建log拦截器
        HttpLoggingInterceptor loggingInterceptor = new HttpLoggingInterceptor(new HttpLoggingInterceptor.Logger() {
            @Override
            public void log(String message) {
                Log.i("Http请求参数:", message);
            }
        });
        loggingInterceptor.setLevel(level);
        // 定制OkHttp
        OkHttpClient.Builder httpClientBuilder = new OkHttpClient.Builder();
        // OkHttp进行添加拦截器loggingInterceptor
        httpClientBuilder.addInterceptor(loggingInterceptor);
        return httpClientBuilder.build();
    }
}

将定制的OkHttpClient添加到Retrofit中:

Retrofit retrofit = new Retrofit.Builder()
        .baseUrl(Constant.SERVER_URL)
        .addConverterFactory(GsonConverterFactory.create())
        .client(RetrofitUtils.getOkHttpClient()) // 打印请求参数
        .build();

大功告成!

5.写在最后

源码已托管到GitHub上,欢迎Fork,觉得还不错就Start一下吧!

GitHub传送门

点击下载源码

欢迎同学们吐槽评论,如果你觉得本篇博客对你有用,那么就留个言或者点下喜欢吧(^-^)

在下篇文章中将会探讨一下Retrofit封装的最佳姿势,敬请期待!

《Android 探讨一下Retrofit封装的最佳姿势》

已修改为支持RxJava2,最新代码已同步至GitHub。

compile 'com.squareup.retrofit2:retrofit:2.3.0'
compile 'com.squareup.retrofit2:converter-gson:2.3.0'
compile 'com.squareup.retrofit2:adapter-rxjava2:2.3.0'
compile 'com.squareup.okhttp3:logging-interceptor:3.8.0'
compile 'io.reactivex.rxjava2:rxandroid:2.0.1'
最后编辑于
©著作权归作者所有,转载或内容合作请联系作者
  • 序言:七十年代末,一起剥皮案震惊了整个滨河市,随后出现的几起案子,更是在滨河造成了极大的恐慌,老刑警刘岩,带你破解...
    沈念sama阅读 206,126评论 6 481
  • 序言:滨河连续发生了三起死亡事件,死亡现场离奇诡异,居然都是意外死亡,警方通过查阅死者的电脑和手机,发现死者居然都...
    沈念sama阅读 88,254评论 2 382
  • 文/潘晓璐 我一进店门,熙熙楼的掌柜王于贵愁眉苦脸地迎上来,“玉大人,你说我怎么就摊上这事。” “怎么了?”我有些...
    开封第一讲书人阅读 152,445评论 0 341
  • 文/不坏的土叔 我叫张陵,是天一观的道长。 经常有香客问我,道长,这世上最难降的妖魔是什么? 我笑而不...
    开封第一讲书人阅读 55,185评论 1 278
  • 正文 为了忘掉前任,我火速办了婚礼,结果婚礼上,老公的妹妹穿的比我还像新娘。我一直安慰自己,他们只是感情好,可当我...
    茶点故事阅读 64,178评论 5 371
  • 文/花漫 我一把揭开白布。 她就那样静静地躺着,像睡着了一般。 火红的嫁衣衬着肌肤如雪。 梳的纹丝不乱的头发上,一...
    开封第一讲书人阅读 48,970评论 1 284
  • 那天,我揣着相机与录音,去河边找鬼。 笑死,一个胖子当着我的面吹牛,可吹牛的内容都是我干的。 我是一名探鬼主播,决...
    沈念sama阅读 38,276评论 3 399
  • 文/苍兰香墨 我猛地睁开眼,长吁一口气:“原来是场噩梦啊……” “哼!你这毒妇竟也来了?” 一声冷哼从身侧响起,我...
    开封第一讲书人阅读 36,927评论 0 259
  • 序言:老挝万荣一对情侣失踪,失踪者是张志新(化名)和其女友刘颖,没想到半个月后,有当地人在树林里发现了一具尸体,经...
    沈念sama阅读 43,400评论 1 300
  • 正文 独居荒郊野岭守林人离奇死亡,尸身上长有42处带血的脓包…… 初始之章·张勋 以下内容为张勋视角 年9月15日...
    茶点故事阅读 35,883评论 2 323
  • 正文 我和宋清朗相恋三年,在试婚纱的时候发现自己被绿了。 大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
    茶点故事阅读 37,997评论 1 333
  • 序言:一个原本活蹦乱跳的男人离奇死亡,死状恐怖,灵堂内的尸体忽然破棺而出,到底是诈尸还是另有隐情,我是刑警宁泽,带...
    沈念sama阅读 33,646评论 4 322
  • 正文 年R本政府宣布,位于F岛的核电站,受9级特大地震影响,放射性物质发生泄漏。R本人自食恶果不足惜,却给世界环境...
    茶点故事阅读 39,213评论 3 307
  • 文/蒙蒙 一、第九天 我趴在偏房一处隐蔽的房顶上张望。 院中可真热闹,春花似锦、人声如沸。这庄子的主人今日做“春日...
    开封第一讲书人阅读 30,204评论 0 19
  • 文/苍兰香墨 我抬头看了看天上的太阳。三九已至,却和暖如春,着一层夹袄步出监牢的瞬间,已是汗流浃背。 一阵脚步声响...
    开封第一讲书人阅读 31,423评论 1 260
  • 我被黑心中介骗来泰国打工, 没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留,地道东北人。 一个月前我还...
    沈念sama阅读 45,423评论 2 352
  • 正文 我出身青楼,却偏偏与公主长得像,于是被迫代替她去往敌国和亲。 传闻我的和亲对象是个残疾皇子,可洞房花烛夜当晚...
    茶点故事阅读 42,722评论 2 345

推荐阅读更多精彩内容

  • Android 自定义View的各种姿势1 Activity的显示之ViewRootImpl详解 Activity...
    passiontim阅读 171,498评论 25 707
  • Retrofit 实际上并不能说是一个网络请求框架,它其实是对 okHttp 这个网络请求框架在接口层面的封装,网...
    EmanLu阅读 1,032评论 0 2
  • 前言 如果看Retrofit的源码会发现其实质上就是对okHttp的封装,使用面向接口的方式进行网络请求,利用动态...
    李某人吖阅读 2,026评论 0 0
  • “小庄子,依你看长孙平此次之行,结果该当如何?”“皇上英明神武,运筹帷幄,知人善任,决胜千里,莫说长孙大人是一代骁...
    飒飒秋风爽why阅读 265评论 0 2
  • 当局者迷,旁观者清!呵呵, 摩天轮的角度没有找对 大霖一眼就看出来了 我却画过之后才看出来 明天重新来画吧 哈哈,加油哦
    华姐手心里的温柔阅读 231评论 0 0