一、写在前面

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

二、进入正题

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

2.1 前言

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

2.2 封装OkHttpClient对象

  1. OkHttpClient okHttpClient = new OkHttpClient.Builder()
  2.                 .cookieJar(NetConifg.getCookieJar())
  3.                 .addInterceptor(NetConfig.getInterceptor())
  4.                 .connectTimeout(NetConfig.getConnectionTimeout(), TimeUnit.SECONDS)
  5.                 .readTimeout(NetConfig.getReadTimeout(), TimeUnit.SECONDS)
  6.                 .sslSocketFactory(NetConfig.getSslContext().getSocketFactory())
  7.                 .hostnameVerifier(org.apache.http.conn.ssl.SSLSocketFactory.ALLOW_ALL_HOSTNAME_VERIFIER)
  8.                 .build();
  • OkHttpClient对象的创建相对比较简单，不过我们可以将其封装进工厂里，从而达到复用的效果。
  • 关于CookieJar、网络Interceptor、Https封装，不在本章讲解范围之内，故一笔带过。
  • 网络Interceptor里可以对请求头部分进行设置，包括长连接、Authorization等。

2.3 封装初始化方法

  1. public
  2. static
  3. void
  4. init
  5. (String baseUrl)
  6. {
  7.         if (retrofit == null) {
  8.             synchronized (RetrofitHandler.class) {
  9.                 if (retrofit == null) {
  10.                     retrofit = new Retrofit.Builder()
  11.                             .baseUrl(baseUrl).client(client)
  12.                             .addCallAdapterFactory(RxJavaCallAdapterFactory.create())
  13.                             .addConverterFactory(JacksonConverterFactory.create(objectMapper))
  14.                             .build();
  15.                 }
  16.             }
  17.         }
  18.     }
  • 可以看到其实就是使用单例模式生成了Retroift对象，需要传入的参数只有url。
  • 然后就是引入url、client、RxJava、Jackson解析库。

2.4 封装具体调用的方法

  1. public static <T> T getService(final Class<T> service) {
  2.         T result = (T) serviceCache.get(service);
  3.         if (result == null) {
  4.             result = (T) Proxy.newProxyInstance(service.getClassLoader(), new Class<?>[]{service},
  5.                     new InvocationHandler() {
  6.                         T t = (T) retrofit.create(service);
  7.  
  8.                         @Override
  9.                         
  10. public
  11.  Object 
  12. invoke
  13. (Object proxy, Method method, Object[] args)
  14. throws
  15.  Throwable 
  16. {
  17.                             return ((Observable) Proxy.getInvocationHandler(t)
  18.                                     .invoke(t, method, args))
  19.                                     .compose(NetConfig.getThreadTransformer())
  20.                                     .flatMap(NetConfig.getServerErrorInterceptor());
  21.                         }
  22.                     });
  23.             serviceCache.put(service, result);
  24.         }
  25.         return result;
  26.     }
  • 这个方法是我们以后网络请求常用的一个前置方法，其实就是根据传入的接口的Class生成对应的对象。
  • 这其中用到了嵌套的动态代理技术，感兴趣的同学可以稍后加我微信沟通。
  • 然后利用RxJava的compose操作符对线程转换进行了封装，利用flatMap操作符对server返回的错误码进行了自定义封装。

2.5 具体使用

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

  • 初始化，一般在Application里进行即可
    1. NetManager.init("http://192.168.9.23:90/apps-server/");
  • 定义接口，使用RxJava的Observable作为返回的类别。
    1. public interface BlogService {
    2.   @GET(NetConfig.GET_BLOG)
    3.   Observable<JsonResult<List<Blog>>> getAllBlog(@Query("userId") String userId);
    4. }
  • 调用接口 
    1. NetManager.getService(BlogService.class).getAllBlog(userId)
    2.               .subscribe(new Subscriber<JsonResult<MsgThruOF>>() {
    3.                   @Override
    4.                   
    5. public
    6. void
    7. onStart
    8. ()
    9. {
    10.                       super.onStart();
    11.                       //做一些准备工作
    12.                   }
    13.  
    14.                   @Override
    15.                   
    16. public
    17. void
    18. onNext
    19. (List<String> strings)
    20. {
    21.                       //对具体请求到的数据做处理
    22.                   }
    23.  
    24.                   @Override
    25.                   
    26. public
    27. void
    28. onCompleted
    29. ()
    30. {
    31.  
    32.                   }
    33.  
    34.                   @Override
    35.                   
    36. public
    37. void
    38. onError
    39. (Throwable e)
    40. {
    41.  
    42.                   }
    43.               });
  • 配合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。

大家晚安。

本人微信,有兴趣的，加一波