一个老程序猿的焦虑4

---

一、写在前面

• 当这个 焦虑系列 进行到第四章，我更焦虑了。
• 确实像一些业界良心大佬所说，几乎每天都在想到底还要分享些什么。
• 上周没有分享，不是不想，实在是工作已经让我筋疲力尽，不过也很幸福，感觉收获满满。
• 本周发生了很多事，容我一一总结，一一道来。
• Life is short, and professional life shorter still。
• 好吧，目标是技术文章，还是老套路分享一波技术。

---

二、进入正题

相信，在当今这个Android大环境下，如果你不会Retrofit或者RxJava, 你都不好意思出门。所以今天，简单分享一下Retrofit+RxJava实现简单的网络请求。

2.1 前言

• 本章讲的 Retrofit 指的都是Retrofit2.0，关于具体如何入门，不在此章书写范围。
• 关于RxJava, 强力推荐扔物线老师的大作 给 Android 开发者的 RxJava 详解，此文绝对值得你多读两遍。
• 代码部分只会粘关键部分，需要源码的同学可以在文章末加我微信。

2.2 封装OkHttpClient对象

    OkHttpClient okHttpClient = new OkHttpClient.Builder()
                .cookieJar(NetConifg.getCookieJar())
                .addInterceptor(NetConfig.getInterceptor())
                .connectTimeout(NetConfig.getConnectionTimeout(), TimeUnit.SECONDS)
                .readTimeout(NetConfig.getReadTimeout(), TimeUnit.SECONDS)
                .sslSocketFactory(NetConfig.getSslContext().getSocketFactory())
                .hostnameVerifier(org.apache.http.conn.ssl.SSLSocketFactory.ALLOW_ALL_HOSTNAME_VERIFIER)
                .build();

• OkHttpClient对象的创建相对比较简单，不过我们可以将其封装进工厂里，从而达到复用的效果。

• 关于CookieJar、网络Interceptor、Https封装，不在本章讲解范围之内，故一笔带过。
• 网络Interceptor里可以对请求头部分进行设置，包括长连接、Authorization等。

2.3 封装初始化方法

    public static void init(String baseUrl) {
        if (retrofit == null) {
            synchronized (RetrofitHandler.class) {
                if (retrofit == null) {
                    retrofit = new Retrofit.Builder()
                            .baseUrl(baseUrl).client(client)
                            .addCallAdapterFactory(RxJavaCallAdapterFactory.create())
                            .addConverterFactory(JacksonConverterFactory.create(objectMapper))
                            .build();
                }
            }
        }
    }

• 可以看到其实就是使用单例模式生成了Retroift对象，需要传入的参数只有url。

• 然后就是引入url、client、RxJava、Jackson解析库。

2.4 封装具体调用的方法

    public static <T> T getService(final Class<T> service) {
        T result = (T) serviceCache.get(service);
        if (result == null) {
            result = (T) Proxy.newProxyInstance(service.getClassLoader(), new Class<?>[]{service},
                    new InvocationHandler() {
                        T t = (T) retrofit.create(service);

                        @Override
                        public Object invoke(Object proxy, Method method, Object[] args) throws Throwable {
                            return ((Observable) Proxy.getInvocationHandler(t)
                                    .invoke(t, method, args))
                                    .compose(NetConfig.getThreadTransformer())
                                    .flatMap(NetConfig.getServerErrorInterceptor());
                        }
                    });
            serviceCache.put(service, result);
        }
        return result;
    }

• 这个方法是我们以后网络请求常用的一个前置方法，其实就是根据传入的接口的Class生成对应的对象。

• 这其中用到了嵌套的动态代理技术，感兴趣的同学可以稍后加我微信沟通。
• 然后利用RxJava的compose操作符对线程转换进行了封装，利用flatMap操作符对server返回的错误码进行了自定义封装。

2.5 具体使用

终于到了实战了，还真是有点小激动呢。好吧，没啥好激动的。。。

• 初始化，一般在Application里进行即可

    NetManager.init("http://192.168.9.23:90/apps-server/");

• 定义接口，使用RxJava的Observable作为返回的类别。

    public interface BlogService {
    @GET(NetConfig.GET_BLOG)
    Observable<JsonResult<List<Blog>>> getAllBlog(@Query("userId") String userId);
}

• 调用接口

    NetManager.getService(BlogService.class).getAllBlog(userId)
                .subscribe(new Subscriber<JsonResult<MsgThruOF>>() {
                    @Override
                    public void onStart() {
                        super.onStart();
                        //做一些准备工作
                    }
        
                    @Override
                    public void onNext(List<String> strings) {
                        //对具体请求到的数据做处理
                    }
        
                    @Override
                    public void onCompleted() {
        
                    }
        
                    @Override
                    public void onError(Throwable e) {
        
                    }
                });

• 配合RxJava调用接口非常的方便，而且完全是链式编程，代码结构看起来也很舒服。

• 这里针对Subscriber类还可以进行进一步的封装，平常用到最多的方法其实就是onNext()和onError()。
• 到这，一个基于Retrofit+RxJava的简单网络请求框架已经搭建完毕，其中省略了不少简易代码部分，相信大家基本都看懂了。
• 好吧，这次多加一个章节的部分，相信大家可以收获更多。

---

三、分享部分

今天首先推荐三个公众号，感兴趣的同学，希望大家一起学习，一起成长。
提前声明：这三个公众号跟我半毛钱关系都没有，纯属义务推广。

3.1 码农每日一题

• 也许每天只需要花费几分钟时间，你就可以掌握一个技术面试知识点。

• 而且，更重要的是，马上就要推出针对Android的每日一题了。
• 请相信，坚持的力量。

3.2 老马说编程

• 从入门到高阶、深入浅出，带你领略编程和计算机技术的本质。

3.3 码农翻身

• 作者有15年的IBM架构师经验，以戏谑的方式带你走进计算机的世界。

四、最后

• 很多事情，确实是开头最难，所以永远不要停下脚步。我们还年轻，我们在路上。
• 熟悉我的朋友，可能了解我，到这了，怎么也会扯回到焦虑这个话题上。
• LPL再次丧失总决赛的参赛资格，让不少人觉得青春总是不完美的，亦如当年的纳什。
• 不过，也有朋友告诉我LPL可以再坚持一年。因为明年，大魔王faker要去服兵役了。我的天，好吧，我还能说啥。
• 不过今天的三星真的打的好，提前打哭了faker，原来不止是我们的青春不完美，还有大魔王的。
• 一个 小学妹母亲 出了车祸，作为朋友的我们其实真的帮不了啥，希望 好心人 能多一些吧！
• 自己的母亲好像真的老了，自己好像越来越适应单身的生活。
• 喜欢的人也越来越少了。。。
• 最后的最后，还是忍不住推荐一篇面经好文 How I interviewed for 5 top companies in 5 days and got job offers from all of them 。

大家晚安。

本人微信,有兴趣的，加一波
阅读原文