Android Rxjava+Retrofit网络请求框架封装（一）

image

目录

一、简介
二、Retrofit基本使用
（1）在build文件中加入相关依赖
（2）基本使用
（3）测试
三、Retrofit 自定义的OkHttpClient
（1）设置自定义的OkHttpClient
（2）Retrofit 添加client
（3）打印效果
四、Retrofit 与 Rxjava 结合使用
（1）添加依赖
（2）Retrofit 设置
（3）其他修改
（4）测试结果
五、防止Rxjava引发的内存泄漏
（1）添加依赖
（2）基本使用
六、总结与封装
七、Demo地址
八、内容推荐

前言

这是第二次改编、之前第一次写这篇博客的时候只是当成笔记记录一下。都没有怎么仔细介绍内容，可能导致一些朋友们没看明白，这次重新组织一下。当然由于内容比较多，不可能太详细。我尽量做到让更多人能够看明白，哈哈 当然 朋友们也要跟着我的步骤一步一步来实现 ，这样会比较好理解。

一、简介

大家都知道Retrofit是对OKHttp的第二次封装，使用上也比较简单。那为什么还要对Retrofit进行封装呢，个人理解主要还是对Retrofit进行更规范的分类，有利于项目的开发与维护，提高网络请求这一块的效率。好了，可以开始跟我走了。。一步一步的走向巅峰，然后再回头来听我吹牛逼。。

​​​​
2.gif

二、Retrofit基本使用

（1）在build文件中加入相关依赖

//github地址：https://github.com/square/retrofit
//文档地址：https://square.github.io/retrofit/
implementation 'com.squareup.retrofit2:retrofit:2.5.0'
image.gif

（2）基本使用

public interface ApiUrl {
    //get请求
    @GET(Constans.retrofit)
    Call<Bean> getRetrofit();
}
image.gif
Retrofit retrofit = new Retrofit.Builder()
                .baseUrl(Constans.BaseUrl)
                .build();

        ApiUrl api = retrofit.create(ApiUrl.class);
        Call<Bean> demo = api.getRetrofit();
        demo.enqueue(new Callback<Bean>() {
            @Override
            public void onResponse(Call<Bean> call, Response<Bean> response) {
                Log.e(TAG, "请求成功信息: "+response.body().toString());
            }

            @Override
            public void onFailure(Call<Bean> call, Throwable t) {
                Log.e(TAG, "请求失败信息: " +t.getMessage());
            }
        });
image.gif

目前大部分后台一般会返回JSON数据类型所以我们需要Retrofit 添加JSON支持

    //retrofit添加Json解析返回数据
    implementation 'com.squareup.retrofit2:converter-gson:2.5.0'
image.gif
        Retrofit retrofit = new Retrofit.Builder()
                .baseUrl(Constans.BaseUrl)
                //添加GSON解析：返回数据转换成GSON类型 
                .addConverterFactory(GsonConverterFactory.create())
                .build();
image.gif

这样就可以解析JSON数据

（3）测试

这里提供测试Url,返回的是JSON数据类型

    public final static  String BaseUrl = "http://120.78.186.81/api/";
    public final static  String retrofit = "values/5";
image.gif

映射返回数据

/**
 * {
 *     "res_code": 200,
 *     "err_msg": "Web page does not exist",
 *     "demo": {
 *         "id": "1001",
 *         "appid": "1021",
 *         "name": "sss",
 *         "showtype": "text"
 *     }
 * }
 */
public class Bean {

    @Override
    public String toString() {
        return "bean{" +
                "res_code=" + res_code +
                ", err_code=" + err_code +
                ", err_msg='" + err_msg + '\'' +
                ", demo=" + demo +
                '}';
    }
    private int res_code;
    private int err_code;
    private String err_msg;
    private DemoBean demo;

    public int getRes_code() {
        return res_code;
    }

    public void setRes_code(int res_code) {
        this.res_code = res_code;
    }

    public int getErr_code() {
        return err_code;
    }

    public void setErr_code(int err_code) {
        this.err_code = err_code;
    }

    public String getErr_msg() {
        return err_msg;
    }

    public void setErr_msg(String err_msg) {
        this.err_msg = err_msg;
    }

    public DemoBean getDemo() {
        return demo;
    }

    public void setDemo(DemoBean demo) {
        this.demo = demo;
    }

    public static class DemoBean {
        @Override
        public String toString() {
            return "DemoBean{" +
                    "id='" + id + '\'' +
                    ", appid='" + appid + '\'' +
                    ", name='" + name + '\'' +
                    ", showtype='" + showtype + '\'' +
                    '}';
        }
        private String id;
        private String appid;
        private String name;
        private String showtype;

        public String getId() {
            return id;
        }

        public void setId(String id) {
            this.id = id;
        }

        public String getAppid() {
            return appid;
        }

        public void setAppid(String appid) {
            this.appid = appid;
        }

        public String getName() {
            return name;
        }

        public void setName(String name) {
            this.name = name;
        }

        public String getShowtype() {
            return showtype;
        }

        public void setShowtype(String showtype) {
            this.showtype = showtype;
        }
    }
}
image.gif

发送请求并打印返回数据

 Retrofit retrofit = new Retrofit.Builder()
                .baseUrl(Constans.BaseUrl)
                //添加GSON解析
                .addConverterFactory(GsonConverterFactory.create())
                .build();

        ApiUrl api = retrofit.create(ApiUrl.class);
        Call<Bean> demo = api.getRetrofit();
        demo.enqueue(new Callback<Bean>() {
            @Override
            public void onResponse(Call<Bean> call, Response<Bean> response) {
                Log.e(TAG, "请求成功信息: "+response.body().toString());
            }

            @Override
            public void onFailure(Call<Bean> call, Throwable t) {
                Log.e(TAG, "请求失败信息: " +t.getMessage());
            }
        });
image.gif

别忘了——添加网络权限

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

打印结果：

 E/RetrofitActivity: 请求成功信息: bean{res_code=200, err_code=0, err_msg='Web page does not exist', demo=DemoBean{id='1001', appid='1021', name='sss', showtype='text'}}
image.gif

三、Retrofit 自定义的OkHttpClient

这里介绍一些常用的设置

（1）设置自定义的OkHttpClient 

       OkHttpClient client = new OkHttpClient().newBuilder()
                .readTimeout(Constans.DEFAULT_TIME, TimeUnit.SECONDS)//设置读取超时时间
                .connectTimeout(Constans.DEFAULT_TIME, TimeUnit.SECONDS)//设置请求超时时间
                .writeTimeout(Constans.DEFAULT_TIME,TimeUnit.SECONDS)//设置写入超时时间
                .addInterceptor(new LogInterceptor())//添加打印拦截器
                .retryOnConnectionFailure(true)//设置出现错误进行重新连接。
                .build();
image.gif
    //设置默认超时时间
    public static final int DEFAULT_TIME=10;
image.gif
/**
 *  TODO Log拦截器代码
 */

import android.util.Log;
import java.io.IOException;
import java.util.Locale;
import okhttp3.Interceptor;
import okhttp3.Request;

/**
 *  TODO Log拦截器代码
 */
public class LogInterceptor implements Interceptor {
    private String TAG = "okhttp";

    @Override
    public okhttp3.Response intercept(Chain chain) throws IOException {
        Request request = chain.request()
//                .newBuilder()
//                .addHeader("Content-Type", "application/x-www-form-urlencoded; charset=UTF-8")
//                .addHeader("Accept-Encoding", "gzip, deflate")
//                .addHeader("Connection", "keep-alive")
//                .addHeader("Accept", "*/*")
//                .addHeader("Cookie", "add cookies here")
//                .build()
                  ;

        Log.e(TAG,"request:" + request.toString());
        long t1 = System.nanoTime();
        okhttp3.Response response = chain.proceed(chain.request());
        long t2 = System.nanoTime();
        Log.e(TAG,String.format(Locale.getDefault(), "Received response for %s in %.1fms%n%s",
                response.request().url(), (t2 - t1) / 1e6d, response.headers()));
        okhttp3.MediaType mediaType = response.body().contentType();
        String content = response.body().string();
        Log.e(TAG, "response body:" + content);
        return response.newBuilder()
                .body(okhttp3.ResponseBody.create(mediaType, content))
//                .header("Authorization", Your.sToken)
                .build();
    }
}
image.gif

（2）Retrofit 添加client

        Retrofit retrofit = new Retrofit.Builder()
                //设置自定义okHttp
                .client(client)
                .baseUrl(Constans.BaseUrl)
                //添加GSON解析
                .addConverterFactory(GsonConverterFactory.create())
                .build();
image.gif

（3）打印效果

E/okhttp: request:Request{method=GET, url=http://pndatsn5v.bkt.clouddn.com/retrofit.txt, tags={class retrofit2.Invocation=retrofit.interfaces.ApiUrl.getRetrofit() []}}

E/okhttp: Received response for http://pndatsn5v.bkt.clouddn.com/retrofit.txt in 55.1ms
    Server: Tengine
    Content-Type: text/plain
    Connection: keep-alive
    Date: Sat, 23 Feb 2019 08:17:35 GMT
    Accept-Ranges: bytes
    Access-Control-Allow-Origin: *
    Access-Control-Expose-Headers: X-Log, X-Reqid
    Access-Control-Max-Age: 2592000
    Cache-Control: public, max-age=31536000
    Content-Disposition: inline; filename="retrofit.txt"; filename*=utf-8' 'retrofit.txt
    Content-Transfer-Encoding: binary
    Etag: "Fh65gSkYd4KepQbHi-rWZDlhKjmO.gz"
    Last-Modified: Sat, 23 Feb 2019 08:14:42 GMT
    Vary: Accept-Encoding
    X-Log: AC;CFGG:4;redis.g/404;redis.g;rs5_shard.sel:2;rwro.get:2;RS.dbs:2;RS:3;redis.s;2s.gh;PFDS;AUTHPROXY_dg_out;IO:85
    X-M-Log: QNM:xs1172;QNM3
    X-M-Reqid: dGUAAMyobctL8IUV
    X-Qiniu-Zone: 2
    X-Qnm-Cache: Hit
    X-Reqid: EkMAAA7s1xso8IUV
    X-Svr: IO
    Ali-Swift-Global-Savetime: 1550909855
    Via: cache4.l2et15[10,200-0,M], cache15.l2et15[11,0], vcache19.cn1177[0,200-0,H], vcache2.cn1177[1,0]
    Age: 80679
    X-Cache: HIT TCP_MEM_HIT dirn:2:55209266
    X-Swift-SaveTime: Sat, 23 Feb 2019 08:17:35 GMT
    X-Swift-CacheTime: 2592000
    Timing-Allow-Origin: *
    EagleId: 1b9f47ca15509905340914033e

E/okhttp: response body:{
        "res_code": 200,
        "err_msg": "Web page does not exist",
        "demo": {
            "id": "1001",
            "appid": "1021",
            "name": "sss",
            "showtype": "text"
        }
    }

E/RetrofitActivity: 请求成功信息: bean{res_code=200, err_code=0, err_msg='Web page does not exist', demo=DemoBean{id='1001', appid='1021', name='sss', showtype='text'}}
image.gif

四、Retrofit 与 Rxjava 结合使用

（1）添加依赖

implementation 'com.jakewharton.retrofit:retrofit2-rxjava2-adapter:1.0.0'
image.gif

（2）Retrofit 设置

Retrofit retrofit = new Retrofit.Builder()
                .client(client)
                .baseUrl(Constans.BaseUrl)
                //添加GSON解析：返回数据转换成GSON类型
                .addConverterFactory(GsonConverterFactory.create())
                //添加Rxjava支持
                .addCallAdapterFactory(RxJava2CallAdapterFactory.create())
                .build();
image.gif

（3）其他修改

//@GET(Constans.retrofit)
//Call<Bean> getRetrofit();

@GET(Constans.retrofit)
Observable<Bean> getRetrofit1();
image.gif
        retrofit.create(ApiUrl.class)
                .getRetrofit1()
                .subscribeOn(Schedulers.io())
                .observeOn(AndroidSchedulers.mainThread())
                .subscribe(new Observer<Bean>() {
                    @Override
                    public void onSubscribe(Disposable d) {
                        Log.e(TAG, "onSubscribe: " );
                    }

                    @Override
                    public void onNext(Bean demo) {
                        Log.e(TAG, "onNext: " +demo.toString());
                    }

                    @Override
                    public void onError(Throwable e) {
                        Log.e(TAG, "Throwable: " + e.getMessage());
                    }

                    @Override
                    public void onComplete() {
                        Log.e(TAG, "onComplete: " );
                    }
                });
image.gif

（4）测试结果

E/RetrofitActivity: onSubscribe: 
E/RetrofitActivity: onNext: bean{res_code=200, err_code=0, err_msg='Web page does not exist', demo=DemoBean{id='1001', appid='1021', name='sss', showtype='text'}}
E/RetrofitActivity: onComplete:
image.gif

五、防止Rxjava引发的内存泄漏

当使用RxJava订阅并执行耗时任务后，当Activity被finish时，如果耗时任务还未完成，没有及时取消订阅，就会导致Activity无法被回收，从而引发内存泄漏。为了解决这个问题，就产生了RxLifecycle，让RxJava变得有生命周期感知，使得其能及时取消订阅，避免出现内存泄漏问题。

（1）添加依赖

    implementation 'com.trello.rxlifecycle2:rxlifecycle-components:2.1.0'
image.gif

（2）基本使用

Activity 需继承自 RxAppCompatActivity 或 RxFragmentActivity 或 RxActivity

Fragment 需继承 RxFragment

retrofit.create(ApiUrl.class)
                .getRetrofit1()
                .subscribeOn(Schedulers.io())
                .observeOn(AndroidSchedulers.mainThread())
                //绑定生命周期
                .compose(bindUntilEvent(ActivityEvent.DESTROY))
                .subscribe(new Observer<Bean>() {
                    @Override
                    public void onSubscribe(Disposable d) {
                        Log.e(TAG, "onSubscribe: " );
                    }

                    @Override
                    public void onNext(Bean demo) {
                        Log.e(TAG, "onNext: " +demo.toString());
                    }

                    @Override
                    public void onError(Throwable e) {
                        Log.e(TAG, "Throwable: " + e.getMessage());
                    }

                    @Override
                    public void onComplete() {
                        Log.e(TAG, "onComplete: " );
                    }
                });
image.gif

好了 目前了解这些已经够用了 不过直接使用还是很麻烦，重复代码比较多 。所以需要进行整理和封装

image

六、总结与封装

《Android Rxjava+Retrofit网络请求框架封装（二）》

七、Demo地址

https://github.com/DayorNight/RxjavaRetrofit2

八、内容推荐

CSDN：
《Android Rxjava+Retrofit网络请求框架封装（一）》

《Android JUnit单元测试》

《Android Log日志封装》

《Android 仿微信全局字体大小调整》

如果你觉得我写的不错或者对您有所帮助的话

不妨顶一个【微笑】，别忘了点赞、收藏、加关注哈

看在我花了这么多时间整理写成文章分享给大家的份上，记得手下留情哈

您的每个举动都是对我莫大的支持

image
最后编辑于 ：
©著作权归作者所有,转载或内容合作请联系作者
  • 人面猴
    序言：七十年代末，一起剥皮案震惊了整个滨河市，随后出现的几起案子，更是在滨河造成了极大的恐慌，老刑警刘岩，带你破解...
    沈念sama阅读 202,056评论 5赞 474
  • 死咒
    序言：滨河连续发生了三起死亡事件，死亡现场离奇诡异，居然都是意外死亡，警方通过查阅死者的电脑和手机，发现死者居然都...
    沈念sama阅读 84,842评论 2赞 378
  • 救了他两次的神仙让他今天三更去死
    文/潘晓璐 我一进店门，熙熙楼的掌柜王于贵愁眉苦脸地迎上来，“玉大人，你说我怎么就摊上这事。” “怎么了？”我有些...
    开封第一讲书人阅读 148,938评论 0赞 335
  • 道士缉凶录：失踪的卖姜人
    文/不坏的土叔 我叫张陵，是天一观的道长。 经常有香客问我，道长，这世上最难降的妖魔是什么？ 我笑而不...
    开封第一讲书人阅读 54,296评论 1赞 272
  • 港岛之恋（遗憾婚礼）
    正文 为了忘掉前任，我火速办了婚礼，结果婚礼上，老公的妹妹穿的比我还像新娘。我一直安慰自己，他们只是感情好，可当我...
    茶点故事阅读 63,292评论 5赞 363
  • 恶毒庶女顶嫁案：这布局不是一般人想出来的
    文/花漫 我一把揭开白布。 她就那样静静地躺着，像睡着了一般。 火红的嫁衣衬着肌肤如雪。 梳的纹丝不乱的头发上，一...
    开封第一讲书人阅读 48,413评论 1赞 281
  • 城市分裂传说
    那天，我揣着相机与录音，去河边找鬼。 笑死，一个胖子当着我的面吹牛，可吹牛的内容都是我干的。 我是一名探鬼主播，决...
    沈念sama阅读 37,824评论 3赞 393
  • 双鸳鸯连环套：你想象不到人心有多黑
    文/苍兰香墨 我猛地睁开眼，长吁一口气：“原来是场噩梦啊……” “哼！你这毒妇竟也来了？” 一声冷哼从身侧响起，我...
    开封第一讲书人阅读 36,493评论 0赞 256
  • 万荣杀人案实录
    序言：老挝万荣一对情侣失踪，失踪者是张志新（化名）和其女友刘颖，没想到半个月后，有当地人在树林里发现了一具尸体，经...
    沈念sama阅读 40,686评论 1赞 295
  • 护林员之死
    正文 独居荒郊野岭守林人离奇死亡，尸身上长有42处带血的脓包…… 初始之章·张勋 以下内容为张勋视角 年9月15日...
    茶点故事阅读 35,502评论 2赞 318
  • 白月光启示录
    正文 我和宋清朗相恋三年，在试婚纱的时候发现自己被绿了。 大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
    茶点故事阅读 37,553评论 1赞 329
  • 活死人
    序言：一个原本活蹦乱跳的男人离奇死亡，死状恐怖，灵堂内的尸体忽然破棺而出，到底是诈尸还是另有隐情，我是刑警宁泽，带...
    沈念sama阅读 33,281评论 4赞 318
  • 日本核电站爆炸内幕
    正文 年R本政府宣布，位于F岛的核电站，受9级特大地震影响，放射性物质发生泄漏。R本人自食恶果不足惜，却给世界环境...
    茶点故事阅读 38,820评论 3赞 305
  • 男人毒药：我在死后第九天来索命
    文/蒙蒙 一、第九天 我趴在偏房一处隐蔽的房顶上张望。 院中可真热闹，春花似锦、人声如沸。这庄子的主人今日做“春日...
    开封第一讲书人阅读 29,873评论 0赞 19
  • 一桩弑父案，背后竟有这般阴谋
    文/苍兰香墨 我抬头看了看天上的太阳。三九已至，却和暖如春，着一层夹袄步出监牢的瞬间，已是汗流浃背。 一阵脚步声响...
    开封第一讲书人阅读 31,109评论 1赞 258
  • 情欲美人皮
    我被黑心中介骗来泰国打工， 没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留，地道东北人。 一个月前我还...
    沈念sama阅读 42,699评论 2赞 348
  • 代替公主和亲
    正文 我出身青楼，却偏偏与公主长得像，于是被迫代替她去往敌国和亲。 传闻我的和亲对象是个残疾皇子，可洞房花烛夜当晚...
    茶点故事阅读 42,257评论 2赞 341

推荐阅读更多精彩内容