Android:手把手带你 深入读懂 Retrofit 2.0 源码

前言

在Android开发中,网络请求十分常用

而在Android网络请求库中,Retrofit是当下最热的一个网络请求库

Github截图

今天,我将手把手带你深入剖析Retrofit v2.0的源码,希望你们会喜欢

请尽量在PC端而不要在移动端看,否则图片可能看不清。

在阅读本文前,建议先阅读文章:这是一份很详细的 Retrofit 2.0 使用教程(含实例讲解)

目录

目录

1. 简介

示意图

特别注意:

准确来说,Retrofit 是一个 RESTful 的 HTTP 网络请求框架的封装。

原因:网络请求的工作本质上是OkHttp完成,而 Retrofit 仅负责 网络请求接口的封装

流程图

App应用程序通过 Retrofit 请求网络,实际上是使用 Retrofit 接口层封装请求参数、Header、Url 等信息,之后由 OkHttp 完成后续的请求操作

在服务端返回数据之后,OkHttp 将原始的结果交给 Retrofit,Retrofit根据用户的需求对结果进行解析

2. 与其他网络请求开源库对比

除了Retrofit,如今Android中主流的网络请求框架有:

Android-Async-Http

Volley

OkHttp

下面是简单介绍:

网络请求加载 - 介绍

一图让你了解全部的网络请求库和他们之间的区别!

网络请求库 - 对比

附:各个主流网络请求库的Github地址

Android-Async-Http

Volley

OkHttp

Retrofit

3. Retrofit 的具体使用

具体请看我写的文章:这是一份很详细的 Retrofit 2.0 使用教程(含实例讲解)

4. 源码分析

4.1 Retrofit的本质流程

一般从网络通信过程如下图:

网络请求的过程

其实Retrofit的本质和上面是一样的套路

只是Retrofit通过使用大量的设计模式进行功能模块的解耦,使得上面的过程进行得更加简单 & 流畅

如下图:

Retrofit的本质

具体过程解释如下:

通过解析 网络请求接口的注解 配置 网络请求参数

通过 动态代理 生成 网络请求对象

通过 网络请求适配器 将 网络请求对象 进行平台适配

平台包括:Android、Rxjava、Guava和java8

通过 网络请求执行器 发送网络请求

通过 数据转换器 解析服务器返回的数据

通过 回调执行器 切换线程(子线程 ->>主线程)

用户在主线程处理返回结果

下面介绍上面提到的几个角色

角色说明

特别注意:因下面的 源码分析 是根据 使用步骤 逐步带你debug进去的,所以必须先看文章这是一份很详细的 Retrofit 2.0 使用教程(含实例讲解)

4.2 源码分析

先来回忆Retrofit的使用步骤:

创建Retrofit实例

创建 网络请求接口实例 并 配置网络请求参数

发送网络请求

封装了 数据转换、线程切换的操作

处理服务器返回的数据

4.2.1 创建Retrofit实例

a. 使用步骤

Retrofit retrofit =newRetrofit.Builder()                                .baseUrl("http://fanyi.youdao.com/")                                .addConverterFactory(GsonConverterFactory.create())                                .build();

b. 源码分析

Retrofit实例是使用建造者模式通过Builder类进行创建的

建造者模式:将一个复杂对象的构建与表示分离,使得用户在不知道对象的创建细节情况下就可以直接创建复杂的对象。具体请看文章:建造者模式(Builder Pattern)- 最易懂的设计模式解析

接下来,我将分五个步骤对创建Retrofit实例进行逐步分析

分析步骤

步骤1

步骤1

<-- Retrofit类 -->publicfinalclassRetrofit{privatefinalMap serviceMethodCache =newLinkedHashMap<>();// 网络请求配置对象(对网络请求接口中方法注解进行解析后得到的对象)// 作用:存储网络请求相关的配置,如网络请求的方法、数据转换器、网络请求适配器、网络请求工厂、基地址等privatefinalHttpUrl baseUrl;// 网络请求的url地址privatefinalokhttp3.Call.Factory callFactory;// 网络请求器的工厂// 作用:生产网络请求器(Call)// Retrofit是默认使用okhttpprivatefinalList adapterFactories;// 网络请求适配器工厂的集合// 作用:放置网络请求适配器工厂// 网络请求适配器工厂作用:生产网络请求适配器(CallAdapter)// 下面会详细说明privatefinalList converterFactories;// 数据转换器工厂的集合// 作用:放置数据转换器工厂// 数据转换器工厂作用:生产数据转换器(converter)privatefinalExecutor callbackExecutor;// 回调方法执行器privatefinalbooleanvalidateEagerly;// 标志位// 作用:是否提前对业务接口中的注解进行验证转换的标志位<-- Retrofit类的构造函数 -->Retrofit(okhttp3.Call.Factory callFactory, HttpUrl baseUrl,        List converterFactories, List adapterFactories,        Executor callbackExecutor,booleanvalidateEagerly) {this.callFactory = callFactory;this.baseUrl = baseUrl;this.converterFactories = unmodifiableList(converterFactories);this.adapterFactories = unmodifiableList(adapterFactories);// unmodifiableList(list)近似于UnmodifiableList<E>(list)// 作用:创建的新对象能够对list数据进行访问,但不可通过该对象对list集合中的元素进行修改this.callbackExecutor = callbackExecutor;this.validateEagerly = validateEagerly;    ...// 仅贴出关键代码}

成功建立一个Retrofit对象的标准:配置好Retrofit类里的成员变量,即配置好:

serviceMethod:包含所有网络请求信息的对象

baseUrl:网络请求的url地址

callFactory:网络请求工厂

adapterFactories:网络请求适配器工厂的集合

converterFactories:数据转换器工厂的集合

callbackExecutor:回调方法执行器

所谓xxxFactory、“xxx工厂”其实是设计模式中工厂模式的体现:将“类实例化的操作”与“使用对象的操作”分开,使得使用者不用知道具体参数就可以实例化出所需要的“产品”类。

具体请看我写的文章

简单工厂模式(SimpleFactoryPattern)- 最易懂的设计模式解析

工厂方法模式(Factory Method)- 最易懂的设计模式解析

抽象工厂模式(Abstract Factory)- 最易懂的设计模式解析

这里详细介绍一下:CallAdapterFactory:该Factory生产的是CallAdapter,那么CallAdapter又是什么呢?

CallAdapter详细介绍

定义:网络请求执行器(Call)的适配器

Call在Retrofit里默认是OkHttpCall

在Retrofit中提供了四种CallAdapterFactory: ExecutorCallAdapterFactory(默认)、GuavaCallAdapterFactory、Java8CallAdapterFactory、RxJavaCallAdapterFactory

作用:将默认的网络请求执行器(OkHttpCall)转换成适合被不同平台来调用的网络请求执行器形式

如:一开始Retrofit只打算利用OkHttpCall通过ExecutorCallbackCall切换线程;但后来发现使用Rxjava更加方便(不需要Handler来切换线程)。想要实现Rxjava的情况,那就得使用RxJavaCallAdapterFactoryCallAdapter将OkHttpCall转换成Rxjava(Scheduler):

// 把response封装成rxjava的Observeble,然后进行流式操作Retrofit.Builder.addCallAdapterFactory(newRxJavaCallAdapterFactory().create());// 关于RxJava的使用这里不作更多的展开

Retrofit还支持java8、Guava平台。

好处:用最小代价兼容更多平台,即能适配更多的使用场景

所以,接下来需要分析的步骤2、步骤3、步骤4、步骤4的目的是配置好上述所有成员变量

步骤2

步骤2

我们先来看Builder类

请按下面提示的步骤进行查看

<-- Builder类-->publicstaticfinalclassBuilder{privatePlatform platform;privateokhttp3.Call.Factory callFactory;privateHttpUrl baseUrl;privateList converterFactories =newArrayList<>();privateList adapterFactories =newArrayList<>();privateExecutor callbackExecutor;privatebooleanvalidateEagerly;// 从上面可以发现, Builder类的成员变量与Retrofit类的成员变量是对应的// 所以Retrofit类的成员变量基本上是通过Builder类进行配置// 开始看步骤1<-- 步骤1-->// Builder的构造方法(无参)publicBuilder(){this(Platform.get());// 用this调用自己的有参构造方法public Builder(Platform platform) ->>步骤5(看完步骤2、3、4再看)// 并通过调用Platform.get()传入了Platform对象// 继续看Platform.get()方法 ->>步骤2// 记得最后继续看步骤5的Builder有参构造方法}...}<-- 步骤2-->classPlatform{privatestaticfinalPlatform PLATFORM = findPlatform();// 将findPlatform()赋给静态变量staticPlatformget(){returnPLATFORM;// 返回静态变量PLATFORM,即findPlatform() ->>步骤3}<-- 步骤3-->privatestaticPlatformfindPlatform(){try{      Class.forName("android.os.Build");// Class.forName(xxx.xx.xx)的作用:要求JVM查找并加载指定的类(即JVM会执行该类的静态代码段)if(Build.VERSION.SDK_INT !=0) {returnnewAndroid();// 此处表示:如果是Android平台,就创建并返回一个Android对象 ->>步骤4}    }catch(ClassNotFoundException ignored) {    }try{// 支持Java平台Class.forName("java.util.Optional");returnnewJava8();    }catch(ClassNotFoundException ignored) {    }try{// 支持iOS平台Class.forName("org.robovm.apple.foundation.NSObject");returnnewIOS();    }catch(ClassNotFoundException ignored) {    }// 从上面看出:Retrofit2.0支持3个平台:Android平台、Java平台、IOS平台// 最后返回一个Platform对象(指定了Android平台)给Builder的有参构造方法public Builder(Platform platform)  --> 步骤5// 说明Builder指定了运行平台为AndroidreturnnewPlatform();  }...}<-- 步骤4-->// 用于接收服务器返回数据后进行线程切换在主线程显示结果staticclassAndroidextendsPlatform{@OverrideCallAdapter.FactorydefaultCallAdapterFactory(Executor callbackExecutor){returnnewExecutorCallAdapterFactory(callbackExecutor);// 创建默认的网络请求适配器工厂// 该默认工厂生产的 adapter 会使得Call在异步调用时在指定的 Executor 上执行回调// 在Retrofit中提供了四种CallAdapterFactory: ExecutorCallAdapterFactory(默认)、GuavaCallAdapterFactory、Java8CallAdapterFactory、RxJavaCallAdapterFactory// 采用了策略模式}@OverridepublicExecutordefaultCallbackExecutor(){// 返回一个默认的回调方法执行器// 该执行器作用:切换线程(子->>主线程),并在主线程(UI线程)中执行回调方法returnnewMainThreadExecutor();    }staticclassMainThreadExecutorimplementsExecutor{privatefinalHandler handler =newHandler(Looper.getMainLooper());// 获取与Android 主线程绑定的Handler @Overridepublicvoidexecute(Runnable r){                        handler.post(r);// 该Handler是上面获取的与Android 主线程绑定的Handler // 在UI线程进行对网络请求返回数据处理等操作。}    }// 切换线程的流程:// 1. 回调ExecutorCallAdapterFactory生成了一个ExecutorCallbackCall对象//2. 通过调用ExecutorCallbackCall.enqueue(CallBack)从而调用MainThreadExecutor的execute()通过handler切换到主线程}// 下面继续看步骤5的Builder有参构造方法<-- 步骤5-->//  Builder类的构造函数2(有参)publicBuilder(Platform platform){// 接收Platform对象(Android平台)this.platform = platform;// 通过传入BuiltInConverters()对象配置数据转换器工厂(converterFactories)// converterFactories是一个存放数据转换器Converter.Factory的数组// 配置converterFactories即配置里面的数据转换器converterFactories.add(newBuiltInConverters());// BuiltInConverters是一个内置的数据转换器工厂(继承Converter.Factory类)// new BuiltInConverters()是为了初始化数据转换器}

对Builder类分析完毕,总结:Builder设置了默认的

平台类型对象:Android

网络请求适配器工厂:CallAdapterFactory

CallAdapter用于对原始Call进行再次封装,如Call<R>到Observable<R>

数据转换器工厂: converterFactory

回调执行器:callbackExecutor

特别注意,这里只是设置了默认值,但未真正配置到具体的Retrofit类的成员变量当中

步骤3

步骤3

还是按部就班按步骤来观看

<-- 步骤1-->publicBuilderbaseUrl(String baseUrl){// 把String类型的url参数转化为适合OKhttp的HttpUrl类型HttpUrl httpUrl = HttpUrl.parse(baseUrl);// 最终返回带httpUrl类型参数的baseUrl()// 下面继续看baseUrl(httpUrl) ->> 步骤2returnbaseUrl(httpUrl);    }<-- 步骤2-->publicBuilderbaseUrl(HttpUrl baseUrl){//把URL参数分割成几个路径碎片List pathSegments = baseUrl.pathSegments();// 检测最后一个碎片来检查URL参数是不是以"/"结尾// 不是就抛出异常    if(!"".equals(pathSegments.get(pathSegments.size() -1))) {thrownewIllegalArgumentException("baseUrl must end in /: "+ baseUrl);      }this.baseUrl = baseUrl;returnthis;    }

至此,步骤3分析完毕

总结:baseUrl()用于配置Retrofit类的网络请求url地址

将传入的String类型url转化为适合OKhttp的HttpUrl类型的url

步骤4

步骤4

我们从里往外看,即先看GsonConverterFactory.creat()

publicfinalclassGsonConverterFactoryextendsConverter.Factory{<-- 步骤1-->publicstaticGsonConverterFactorycreate(){// 创建一个Gson对象returncreate(newGson()); ->>步骤2}<-- 步骤2-->publicstaticGsonConverterFactorycreate(Gson gson){// 创建了一个含有Gson对象实例的GsonConverterFactoryreturnnewGsonConverterFactory(gson); ->>步骤3}privatefinalGson gson;<-- 步骤3-->privateGsonConverterFactory(Gson gson){if(gson ==null)thrownewNullPointerException("gson == null");this.gson = gson;  }

所以,GsonConverterFactory.creat()是创建了一个含有Gson对象实例的GsonConverterFactory,并返回给addConverterFactory()

接下来继续看:addConverterFactory()

// 将上面创建的GsonConverterFactory放入到 converterFactories数组// 在第二步放入一个内置的数据转换器工厂BuiltInConverters()后又放入了一个GsonConverterFactorypublicBuilderaddConverterFactory(Converter.Factory factory){      converterFactories.add(checkNotNull(factory,"factory == null"));returnthis;    }

至此,分析完毕

总结:步骤4用于创建一个含有Gson对象实例的GsonConverterFactory并放入到数据转换器工厂converterFactories里

即Retrofit默认使用Gson进行解析

若使用其他解析方式(如Json、XML或Protocobuf),也可通过自定义数据解析器来实现(必须继承 Converter.Factory)

步骤5

步骤5

终于到了最后一个步骤了。

publicRetrofitbuild(){  <--  配置网络请求执行器(callFactory)-->      okhttp3.Call.Factory callFactory =this.callFactory;// 如果没指定,则默认使用okhttp// 所以Retrofit默认使用okhttp进行网络请求if(callFactory ==null) {        callFactory =newOkHttpClient();      } <--  配置回调方法执行器(callbackExecutor)-->      Executor callbackExecutor =this.callbackExecutor;// 如果没指定,则默认使用Platform检测环境时的默认callbackExecutor// 即Android默认的callbackExecutorif(callbackExecutor ==null) {        callbackExecutor = platform.defaultCallbackExecutor();      } <--  配置网络请求适配器工厂(CallAdapterFactory)-->      List adapterFactories =newArrayList<>(this.adapterFactories);// 向该集合中添加了步骤2中创建的CallAdapter.Factory请求适配器(添加在集合器末尾)adapterFactories.add(platform.defaultCallAdapterFactory(callbackExecutor));// 请求适配器工厂集合存储顺序:自定义1适配器工厂、自定义2适配器工厂...默认适配器工厂(ExecutorCallAdapterFactory)<--  配置数据转换器工厂:converterFactory -->// 在步骤2中已经添加了内置的数据转换器BuiltInConverters()(添加到集合器的首位)// 在步骤4中又插入了一个Gson的转换器 - GsonConverterFactory(添加到集合器的首二位)List converterFactories =newArrayList<>(this.converterFactories);// 数据转换器工厂集合存储的是:默认数据转换器工厂( BuiltInConverters)、自定义1数据转换器工厂(GsonConverterFactory)、自定义2数据转换器工厂....// 注://1. 获取合适的网络请求适配器和数据转换器都是从adapterFactories和converterFactories集合的首位-末位开始遍历// 因此集合中的工厂位置越靠前就拥有越高的使用权限// 最终返回一个Retrofit的对象,并传入上述已经配置好的成员变量returnnewRetrofit(callFactory, baseUrl, converterFactories, adapterFactories,          callbackExecutor, validateEagerly);    }

至此,步骤5分析完毕

总结:在最后一步中,通过前面步骤设置的变量,将Retrofit类的所有成员变量都配置完毕。

所以,成功创建了Retrofit的实例

总结

Retrofit使用建造者模式通过Builder类建立了一个Retrofit实例,具体创建细节是配置了:

平台类型对象(Platform - Android)

网络请求的url地址(baseUrl)

网络请求工厂(callFactory)

默认使用OkHttpCall

网络请求适配器工厂的集合(adapterFactories)

本质是配置了网络请求适配器工厂- 默认是ExecutorCallAdapterFactory

数据转换器工厂的集合(converterFactories)

本质是配置了数据转换器工厂

回调方法执行器(callbackExecutor)

默认回调方法执行器作用是:切换线程(子线程 - 主线程)

由于使用了建造者模式,所以开发者并不需要关心配置细节就可以创建好Retrofit实例,建造者模式get。

在创建Retrofit对象时,你可以通过更多更灵活的方式去处理你的需求,如使用不同的Converter、使用不同的CallAdapter,这也就提供了你使用RxJava来调用Retrofit的可能

2. 创建网络请求接口的实例

2.1 使用步骤

<-- 步骤1:定义接收网络数据的类 --><-- JavaBean.java -->publicclassJavaBean{  ..// 这里就不介绍了}<-- 步骤2:定义网络请求的接口类 --><-- AccessApi.java -->publicinterfaceAccessApi{// 注解GET:采用Get方法发送网络请求// Retrofit把网络请求的URL分成了2部分:1部分baseurl放在创建Retrofit对象时设置;另一部分在网络请求接口设置(即这里)// 如果接口里的URL是一个完整的网址,那么放在创建Retrofit对象时设置的部分可以不设置@GET("openapi.do?keyfrom=Yanzhikai&key=2032414398&type=data&doctype=json&version=1.1&q=car")// 接受网络请求数据的方法CallgetCall();// 返回类型为Call<*>,*是解析得到的数据类型,即JavaBean}<-- 步骤3:在MainActivity创建接口类实例  -->AccessApi NetService = retrofit.create(AccessApi.class);      <-- 步骤4:对发送请求的url进行封装,即生成最终的网络请求对象  -->        Call call = NetService.getCall();

2.2 源码分析

结论:Retrofit是通过外观模式 & 代理模式 使用create()方法创建网络请求接口的实例(同时,通过网络请求接口里设置的注解进行了网络请求参数的配置)

外观模式:定义一个统一接口,外部与通过该统一的接口对子系统里的其他接口进行访问。具体请看:外观模式(Facade Pattern) - 最易懂的设计模式解析

代理模式:通过访问代理对象的方式来间接访问目标对象。具体请看:代理模式(Proxy Pattern)- 最易懂的设计模式解析

下面主要分析步骤3和步骤4:

<--步骤3:在MainActivity创建接口类实例-->AccessApi NetService = retrofit.create(NetService.class);<--步骤4:对发送请求的url进行封装,即生成最终的网络请求对象-->Callcall = NetService.getCall();

步骤3讲解:AccessApi NetService = retrofit.create(NetService.class);

public T create(finalClassservice){if(validateEagerly) {// 判断是否需要提前验证eagerlyValidateMethods(service);// 具体方法作用:// 1. 给接口中每个方法的注解进行解析并得到一个ServiceMethod对象// 2. 以Method为键将该对象存入LinkedHashMap集合中// 特别注意:如果不是提前验证则进行动态解析对应方法(下面会详细说明),得到一个ServiceMethod对象,最后存入到LinkedHashMap集合中,类似延迟加载(默认)}// 创建了网络请求接口的动态代理对象,即通过动态代理创建网络请求接口的实例 (并最终返回)// 该动态代理是为了拿到网络请求接口实例上所有注解return(T) Proxy.newProxyInstance(          service.getClassLoader(),// 动态生成接口的实现类 newClass[]{ service },// 动态创建实例newInvocationHandler() {// 将代理类的实现交给 InvocationHandler类作为具体的实现(下面会解释)privatefinalPlatform platform = Platform.get();// 在 InvocationHandler类的invoke()实现中,除了执行真正的逻辑(如再次转发给真正的实现类对象),还可以进行一些有用的操作// 如统计执行时间、进行初始化和清理、对接口调用进行检查等。@OverridepublicObject invoke(Object proxy, Method method, Object... args)              throws Throwable {// 下面会详细介绍 invoke()的实现// 即下面三行代码ServiceMethod serviceMethod = loadServiceMethod(method);                OkHttpCall okHttpCall =newOkHttpCall<>(serviceMethod, args);returnserviceMethod.callAdapter.adapt(okHttpCall);          }        });  }// 特别注意// return (T) roxy.newProxyInstance(ClassLoader loader, Class<?>[] interfaces,  InvocationHandler invocationHandler)// 可以解读为:getProxyClass(loader, interfaces) .getConstructor(InvocationHandler.class).newInstance(invocationHandler);// 即通过动态生成的代理类,调用interfaces接口的方法实际上是通过调用InvocationHandler对象的invoke()来完成指定的功能// 先记住结论,在讲解步骤4的时候会再次详细说明<-- 关注点1:eagerlyValidateMethods() -->privatevoid eagerlyValidateMethods(Classservice){      Platform platform = Platform.get();for(Method method : service.getDeclaredMethods()) {if(!platform.isDefaultMethod(method)) {  loadServiceMethod(method); }// 将传入的ServiceMethod对象加入LinkedHashMap<Method, ServiceMethod>集合// 使用LinkedHashMap集合的好处:lruEntries.values().iterator().next()获取到的是集合最不经常用到的元素,提供了一种Lru算法的实现}  }

创建网络接口实例用了外观模式 & 代理模式:

使用外观模式进行访问,里面用了代理模式

1. 外观模式

外观模式:定义一个统一接口,外部与通过该统一的接口对子系统里的其他接口进行访问。具体请看:外观模式(Facade Pattern) - 最易懂的设计模式解析

Retrofit对象的外观(门店) =retrofit.create()

通过这一外观方法就可以在内部调用各个方法创建网络请求接口的实例配置网络请求参数

大大降低了系统的耦合度

2. 代理模式

代理模式:通过访问代理对象的方式来间接访问目标对象

分为静态代理 & 动态代理:

静态代理:代理类在程序运行前已经存在的代理方式

动态代理:代理类在程序运行前不存在、运行时由程序动态生成的代理方式

具体请看文章代理模式(Proxy Pattern)- 最易懂的设计模式解析

return (T) roxy.newProxyInstance(ClassLoader loader, Class<?>[] interfaces, InvocationHandler invocationHandler)通过代理模式中的动态代理模式,动态生成网络请求接口的代理类,并将代理类的实例创建交给InvocationHandler类作为具体的实现,并最终返回一个动态代理对象。

生成实例过程中含有生成实现类的缓存机制(单例模式),下面会详细分析

使用动态代理的好处:

当NetService对象调用getCall()接口中方法时会进行拦截,调用都会集中转发到 InvocationHandler#invoke (),可集中进行处理

获得网络请求接口实例上的所有注解

更方便封装ServiceMethod

下面看源码分析

下面将详细分析InvocationHandler类 # invoke()里的具体实现

newInvocationHandler() {privatefinalPlatform platform = Platform.get();@OverridepublicObjectinvoke(Object proxy, Method method, Object... args)throwsThrowable{// 将详细介绍下面代码// 关注点1// 作用:读取网络请求接口里的方法,并根据前面配置好的属性配置serviceMethod对象ServiceMethod serviceMethod = loadServiceMethod(method);// 关注点2// 作用:根据配置好的serviceMethod对象创建okHttpCall对象 OkHttpCall okHttpCall =newOkHttpCall<>(serviceMethod, args);// 关注点3// 作用:调用OkHttp,并根据okHttpCall返回rejava的Observe对象或者返回CallreturnserviceMethod.callAdapter.adapt(okHttpCall);          }

下面将详细介绍3个关注点的代码。

关注点1:ServiceMethod serviceMethod = loadServiceMethod(method);

<-- loadServiceMethod(method)方法讲解 -->// 一个 ServiceMethod 对象对应于网络请求接口里的一个方法// loadServiceMethod(method)负责加载 ServiceMethod:ServiceMethodloadServiceMethod(Method method){    ServiceMethod result;// 设置线程同步锁synchronized(serviceMethodCache) {      result = serviceMethodCache.get(method);// ServiceMethod类对象采用了单例模式进行创建// 即创建ServiceMethod对象前,先看serviceMethodCache有没有缓存之前创建过的网络请求实例// 若没缓存,则通过建造者模式创建 serviceMethod 对象if(result ==null) {// 下面会详细介绍ServiceMethod生成实例的过程result =newServiceMethod.Builder(this, method).build();        serviceMethodCache.put(method, result);      }    }returnresult;  }// 这里就是上面说的创建实例的缓存机制:采用单例模式从而实现一个 ServiceMethod 对象对应于网络请求接口里的一个方法// 注:由于每次获取接口实例都是传入 class 对象// 而 class 对象在进程内单例的,所以获取到它的同一个方法 Method 实例也是单例的,所以这里的缓存是有效的。

下面,我将分3个步骤详细分析serviceMethod实例的创建过程:

Paste_Image.png

步骤1:ServiceMethod类构造函数

Paste_Image.png

<-- ServiceMethod 类 -->publicfinalclassServiceMethod{finalokhttp3.Call.Factory callFactory;// 网络请求工厂  finalCallAdapter callAdapter;// 网络请求适配器工厂// 具体创建是在new ServiceMethod.Builder(this, method).build()最后的build()中// 下面会详细说明privatefinalConverter responseConverter;// Response内容转换器  // 作用:负责把服务器返回的数据(JSON或者其他格式,由 ResponseBody 封装)转化为 T 类型的对象;privatefinalHttpUrl baseUrl;// 网络请求地址  privatefinalString relativeUrl;// 网络请求的相对地址  privatefinalString httpMethod;// 网络请求的Http方法  privatefinalHeaders headers;// 网络请求的http请求头 键值对  privatefinalMediaType contentType;// 网络请求的http报文body的类型  privatefinalParameterHandler[] parameterHandlers;// 方法参数处理器// 作用:负责解析 API 定义时每个方法的参数,并在构造 HTTP 请求时设置参数;// 下面会详细说明// 说明:从上面的成员变量可以看出,ServiceMethod对象包含了访问网络的所有基本信息<-- ServiceMethod 类的构造函数 -->// 作用:传入各种网络请求参数ServiceMethod(Builder builder) {this.callFactory = builder.retrofit.callFactory();this.callAdapter = builder.callAdapter;this.responseConverter = builder.responseConverter;this.baseUrl = builder.retrofit.baseUrl();this.relativeUrl = builder.relativeUrl;this.httpMethod = builder.httpMethod;this.headers = builder.headers;this.contentType = builder.contentType; .this.hasBody = builder.hasBody; ythis.isFormEncoded = builder.isFormEncoded;this.isMultipart = builder.isMultipart;this.parameterHandlers = builder.parameterHandlers;  }

步骤2:ServiceMethod的Builder()

Paste_Image.png

publicBuilder(Retrofit retrofit, Method method){this.retrofit = retrofit;this.method = method;// 获取网络请求接口方法里的注释this.methodAnnotations = method.getAnnotations();// 获取网络请求接口方法里的参数类型      this.parameterTypes = method.getGenericParameterTypes();//获取网络请求接口方法里的注解内容    this.parameterAnnotationsArray = method.getParameterAnnotations();        }

步骤3:ServiceMethod的build()

Paste_Image.png

// 作用:控制ServiceMethod对象的生成流程publicServiceMethodbuild(){      callAdapter = createCallAdapter();// 根据网络请求接口方法的返回值和注解类型,从Retrofit对象中获取对应的网络请求适配器  -->关注点1responseType = callAdapter.responseType();// 根据网络请求接口方法的返回值和注解类型,从Retrofit对象中获取该网络适配器返回的数据类型responseConverter = createResponseConverter();// 根据网络请求接口方法的返回值和注解类型,从Retrofit对象中获取对应的数据转换器  -->关注点3// 构造 HTTP 请求时,我们传递的参数都是String// Retrofit 类提供 converter把传递的参数都转化为 String // 其余类型的参数都利用 Converter.Factory 的stringConverter 进行转换// @Body 和 @Part 类型的参数利用Converter.Factory 提供的 requestBodyConverter 进行转换// 这三种 converter 都是通过“询问”工厂列表进行提供,而工厂列表我们可以在构造 Retrofit 对象时进行添加。for(Annotation annotation : methodAnnotations) {        parseMethodAnnotation(annotation);      }// 解析网络请求接口中方法的注解// 主要是解析获取Http请求的方法// 注解包括:DELETE、GET、POST、HEAD、PATCH、PUT、OPTIONS、HTTP、retrofit2.http.Headers、Multipart、FormUrlEncoded// 处理主要是调用方法 parseHttpMethodAndPath(String httpMethod, String value, boolean hasBody) ServiceMethod中的httpMethod、hasBody、relativeUrl、relativeUrlParamNames域进行赋值intparameterCount = parameterAnnotationsArray.length;// 获取当前方法的参数数量parameterHandlers =newParameterHandler[parameterCount];for(intp =0; p < parameterCount; p++) {        Type parameterType = parameterTypes[p];        Annotation[] parameterAnnotations = parameterAnnotationsArray[p];// 为方法中的每个参数创建一个ParameterHandler<?>对象并解析每个参数使用的注解类型// 该对象的创建过程就是对方法参数中注解进行解析// 这里的注解包括:Body、PartMap、Part、FieldMap、Field、Header、QueryMap、Query、Path、Url parameterHandlers[p] = parseParameter(p, parameterType, parameterAnnotations);      }returnnewServiceMethod<>(this);<-- 总结 -->// 1. 根据返回值类型和方法标注从Retrofit对象的的网络请求适配器工厂集合和内容转换器工厂集合中分别获取到该方法对应的网络请求适配器和Response内容转换器;// 2. 根据方法的标注对ServiceMethod的域进行赋值// 3. 最后为每个方法的参数的标注进行解析,获得一个ParameterHandler<?>对象// 该对象保存有一个Request内容转换器——根据参数的类型从Retrofit的内容转换器工厂集合中获取一个Request内容转换器或者一个String内容转换器。}<-- 关注点1:createCallAdapter() -->privateCallAdapter createCallAdapter() {// 获取网络请求接口里方法的返回值类型Type returnType = method.getGenericReturnType();// 获取网络请求接口接口里的注解// 此处使用的是@GetAnnotation[] annotations = method.getAnnotations();try{returnretrofit.callAdapter(returnType, annotations);// 根据网络请求接口方法的返回值和注解类型,从Retrofit对象中获取对应的网络请求适配器// 下面会详细说明retrofit.callAdapter() -- >关注点2}...<-- 关注点2:retrofit.callAdapter()  -->publicCallAdapter callAdapter(Type returnType, Annotation[] annotations) {returnnextCallAdapter(null, returnType, annotations);  }publicCallAdapter nextCallAdapter(CallAdapter.Factory skipPast, Type returnType,      Annotation[] annotations) {// 创建 CallAdapter 如下// 遍历 CallAdapter.Factory 集合寻找合适的工厂(该工厂集合在第一步构造 Retrofit 对象时进行添加(第一步时已经说明))// 如果最终没有工厂提供需要的 CallAdapter,将抛出异常for(inti = start, count = adapterFactories.size(); i < count; i++) {      CallAdapter adapter = adapterFactories.get(i).get(returnType, annotations,this);if(adapter !=null) {returnadapter;      }    }<--  关注点3:createResponseConverter() -->privateConvertercreateResponseConverter(){      Annotation[] annotations = method.getAnnotations();try{// responseConverter 还是由 Retrofit 类提供  -->关注点4returnretrofit.responseBodyConverter(responseType, annotations);      }catch(RuntimeException e) {throwmethodError(e,"Unable to create converter for %s", responseType);      }    }<--  关注点4:responseBodyConverter() -->publicConverterresponseBodyConverter(Type type, Annotation[] annotations){returnnextResponseBodyConverter(null, type, annotations);  }publicConverternextResponseBodyConverter(Converter.Factory skipPast,intstart = converterFactories.indexOf(skipPast)+ 1;for(inti = start, count = converterFactories.size(); i < count; i++) {// 获取Converter 过程:(和获取 callAdapter 基本一致)Converter converter =          converterFactories.get(i).responseBodyConverter(type, annotations,this);// 遍历 Converter.Factory 集合并寻找合适的工厂(该工厂集合在构造 Retrofit 对象时进行添加(第一步时已经说明))// 由于构造Retroifit采用的是Gson解析方式,所以取出的是GsonResponseBodyConverter// Retrofit - Converters 还提供了 JSON,XML,ProtoBuf 等类型数据的转换功能。// 继续看responseBodyConverter() -->关注点5    }<--  关注点5:responseBodyConverter() -->@OverridepublicConverter responseBodyConverter(Type type,    Annotation[] annotations, Retrofit retrofit) {    TypeAdapter adapter = gson.getAdapter(TypeToken.get(type));// 根据目标类型,利用 Gson#getAdapter 获取相应的 adapterreturnnewGsonResponseBodyConverter<>(gson, adapter);}// 做数据转换时调用 Gson 的 API 即可。finalclassGsonResponseBodyConverterimplementsConverter{privatefinalGson gson;privatefinalTypeAdapter adapter;  GsonResponseBodyConverter(Gson gson, TypeAdapter adapter) {this.gson = gson;this.adapter = adapter;  }@OverridepublicTconvert(ResponseBody value)throwsIOException{    JsonReader jsonReader = gson.newJsonReader(value.charStream());try{returnadapter.read(jsonReader);    }finally{      value.close();    }  }}

当选择了RxjavaCallAdapterFactory后,Rxjava通过策略模式选择对应的adapter

关于策略模式的讲解,请看文章策略模式(Strategy Pattern)- 最易懂的设计模式解析

具体过程是:根据网络接口方法的返回值类型来选择具体要用哪种CallAdapterFactory,然后创建具体的CallAdapter实例

采用工厂模式使得各功能模块高度解耦

上面提到了两种工厂:CallAdapter.Factory & Converter.Factory分别负责提供不同的功能模块

工厂负责如何提供、提供何种功能模块

Retrofit 只负责提供选择何种工厂的决策信息(如网络接口方法的参数、返回值类型、注解等)

这正是所谓的高内聚低耦合,工厂模式get。

关于工厂模式请看我写的文章:

简单工厂模式(SimpleFactoryPattern)- 最易懂的设计模式解析

工厂方法模式(Factory Method)- 最易懂的设计模式解析

抽象工厂模式(Abstract Factory)- 最易懂的设计模式解析

终于配置完网络请求参数(即配置好ServiceMethod对象)。接下来将讲解第二行代码:okHttpCall对象的创建

第二行:OkHttpCall okHttpCall = new OkHttpCall<>(serviceMethod, args);

根据第一步配置好的ServiceMethod对象和输入的请求参数创建okHttpCall对象

<--OkHttpCall类 -->publicclassOkHttpCall{privatefinalServiceMethod serviceMethod;// 含有所有网络请求参数信息的对象  privatefinalObject[] args;// 网络请求接口的参数 privateokhttp3.Call rawCall;//实际进行网络访问的类  privateThrowable creationFailure;//几个状态标志位  privatebooleanexecuted;privatevolatilebooleancanceled;    <--OkHttpCall构造函数 -->publicOkHttpCall(ServiceMethod<T> serviceMethod, Object[] args){// 传入了配置好的ServiceMethod对象和输入的请求参数this.serviceMethod = serviceMethod;this.args = args;  }

第三行:return serviceMethod.callAdapter.adapt(okHttpCall);

将第二步创建的OkHttpCall对象传给第一步创建的serviceMethod对象中对应的网络请求适配器工厂的adapt()

返回对象类型:Android默认的是Call<>;若设置了RxJavaCallAdapterFactory,返回的则是Observable<>

<--  adapt()详解-->publicCalladapt(Call<R> call){returnnewExecutorCallbackCall<>(callbackExecutor, call);        }  ExecutorCallbackCall(Executor callbackExecutor, Call delegate) {this.delegate = delegate;// 把上面创建并配置好参数的OkhttpCall对象交给静态代理delegate// 静态代理和动态代理都属于代理模式// 静态代理作用:代理执行被代理者的方法,且可在要执行的方法前后加入自己的动作,进行对系统功能的拓展this.callbackExecutor = callbackExecutor;// 传入上面定义的回调方法执行器// 用于进行线程切换  }

采用了装饰模式:ExecutorCallbackCall = 装饰者,而里面真正去执行网络请求的还是OkHttpCall

使用装饰模式的原因:希望在OkHttpCall发送请求时做一些额外操作。这里的额外操作是线程转换,即将子线程切换到主线程

OkHttpCall的enqueue()是进行网络异步请求的:当你调用OkHttpCall.enqueue()时,回调的callback是在子线程中,需要通过Handler转换到主线程进行回调。ExecutorCallbackCall就是用于线程回调;

当然以上是原生Retrofit使用的切换线程方式。如果你用Rxjava,那就不会用到这个ExecutorCallbackCall而是RxJava的Call,此处不过多展开

步骤4讲解:Call<JavaBean> call = NetService.getCall();

NetService对象实际上是动态代理对象Proxy.newProxyInstance()(步骤3中已说明),并不是真正的网络请求接口创建的对象

当NetService对象调用getCall()时会被动态代理对象Proxy.newProxyInstance()拦截,然后调用自身的InvocationHandler # invoke()

invoke(Object proxy, Method method, Object... args)会传入3个参数:Object proxy:(代理对象)、

Method method(调用的getCall())

Object... args(方法的参数,即getCall(*)中的*)

接下来利用Java反射获取到getCall()的注解信息,配合args参数创建ServiceMethod对象。

如上面步骤3描述,此处不再次讲解

最终创建并返回一个OkHttpCall类型的Call对象

OkHttpCall类是OkHttp的包装类

创建了OkHttpCall类型的Call对象还不能发送网络请求,需要创建Request对象才能发送网络请求

总结

Retrofit采用了外观模式统一调用创建网络请求接口实例和网络请求参数配置的方法,具体细节是:

动态创建网络请求接口的实例(代理模式 - 动态代理)

创建serviceMethod对象(建造者模式 & 单例模式(缓存机制))

对serviceMethod对象进行网络请求参数配置:通过解析网络请求接口方法的参数、返回值和注解类型,从Retrofit对象中获取对应的网络请求的url地址、网络请求执行器、网络请求适配器 & 数据转换器。(策略模式)

对serviceMethod对象加入线程切换的操作,便于接收数据后通过Handler从子线程切换到主线程从而对返回数据结果进行处理(装饰模式)

最终创建并返回一个OkHttpCall类型的网络请求对象

3. 执行网络请求

Retrofit默认使用OkHttp,即OkHttpCall类(实现了retrofit2.Call<T>接口)

但可以自定义选择自己需要的Call类

OkHttpCall提供了两种网络请求方式:

同步请求:OkHttpCall.execute()

异步请求:OkHttpCall.enqueue()

下面将详细介绍这两种网络请求方式。

对于OkHttpCall的enqueue()、execute()此处不往下分析,有兴趣的读者可以看OkHttp的源码

3.1 同步请求OkHttpCall.execute()

3.1.1 发送请求过程

步骤1:对网络请求接口的方法中的每个参数利用对应ParameterHandler进行解析,再根据ServiceMethod对象创建一个OkHttp的Request对象

步骤2:使用OkHttp的Request发送网络请求;

步骤3:对返回的数据使用之前设置的数据转换器(GsonConverterFactory)解析返回的数据,最终得到一个Response<T>对象

3.1.2 具体使用

Responseresponse = call.execute();

上面简单的一行代码,其实包含了整个发送网络同步请求的三个步骤。

3.1.3 源码分析

@OverridepublicResponseexecute()throwsIOException{  okhttp3.Call call;// 设置同步锁synchronized(this) {    call = rawCall;if(call ==null) {try{        call = rawCall = createRawCall();// 步骤1:创建一个OkHttp的Request对象请求 -->关注1}catch(IOException | RuntimeException e) {        creationFailure = e;throwe;      }    }  }returnparseResponse(call.execute());// 步骤2:调用OkHttpCall的execute()发送网络请求(同步)// 步骤3:解析网络请求返回的数据parseResponse() -->关注2}<-- 关注1:createRawCall()  -->privateokhttp3.CallcreateRawCall()throwsIOException{    Request request = serviceMethod.toRequest(args);// 从ServiceMethod的toRequest()返回一个Request对象okhttp3.Call call = serviceMethod.callFactory.newCall(request);// 根据serviceMethod和request对象创建 一个okhttp3.Requestif(call ==null) {thrownewNullPointerException("Call.Factory returned null.");  }returncall;}<--  关注2:parseResponse()-->ResponseparseResponse(okhttp3.Response rawResponse)throwsIOException{  ResponseBody rawBody = rawResponse.body();  rawResponse = rawResponse.newBuilder()      .body(newNoContentResponseBody(rawBody.contentType(), rawBody.contentLength()))      .build();// 收到返回数据后进行状态码检查// 具体关于状态码说明下面会详细介绍intcode = rawResponse.code();if(code <200|| code >=300) {  }if(code ==204|| code ==205) {returnResponse.success(null, rawResponse);  }  ExceptionCatchingRequestBody catchingBody =newExceptionCatchingRequestBody(rawBody);try{    T body = serviceMethod.toResponse(catchingBody);// 等Http请求返回后 & 通过状态码检查后,将response body传入ServiceMethod中,ServiceMethod通过调用Converter接口(之前设置的GsonConverterFactory)将response body转成一个Java对象,即解析返回的数据// 生成Response类returnResponse.success(body, rawResponse);  }catch(RuntimeException e) {    ...// 异常处理}}

特别注意:

ServiceMethod几乎保存了一个网络请求所需要的数据

发送网络请求时,OkHttpCall需要从ServiceMethod中获得一个Request对象

解析数据时,还需要通过ServiceMethod使用Converter(数据转换器)转换成Java对象进行数据解析

为了提高效率,Retrofit还会对解析过的请求ServiceMethod进行缓存,存放在Map<Method, ServiceMethod> serviceMethodCache = new LinkedHashMap<>();对象中,即第二步提到的单例模式

关于状态码检查时的状态码说明:

Paste_Image.png

以上便是整个以同步的方式发送网络请求的过程。

3.2 异步请求OkHttpCall.enqueue()

3.2.1 发送请求过程

步骤1:对网络请求接口的方法中的每个参数利用对应ParameterHandler进行解析,再根据ServiceMethod对象创建一个OkHttp的Request对象

步骤2:使用OkHttp的Request发送网络请求;

步骤3:对返回的数据使用之前设置的数据转换器(GsonConverterFactory)解析返回的数据,最终得到一个Response<T>对象

步骤4:进行线程切换从而在主线程处理返回的数据结果

若使用了RxJava,则直接回调到主线程

异步请求的过程跟同步请求类似,唯一不同之处在于:异步请求会将回调方法交给回调执行器在指定的线程中执行。

指定的线程此处是指主线程(UI线程)

3.2.2 具体使用

call.enqueue(newCallback() {@OverridepublicvoidonResponse(Call<JavaBean> call, Response<JavaBean> response){                System.out.println(response.isSuccessful());if(response.isSuccessful()) {                    response.body().show();                }else{try{                        System.out.println(response.errorBody().string());                    }catch(IOException e) {                        e.printStackTrace();                    } ;                }            }

从上面分析有:call是一个静态代理

使用静态代理的作用是:在okhttpCall发送网络请求的前后进行额外操作

这里的额外操作是:线程切换,即将子线程切换到主线程,从而在主线程对返回的数据结果进行处理

3.2.3 源码分析

<--  call.enqueue()解析  -->@Overridepublicvoidenqueue(finalCallback callback){      delegate.enqueue(newCallback() {// 使用静态代理 delegate进行异步请求 ->>分析1// 等下记得回来@OverridepublicvoidonResponse(Call call,finalResponse response){// 步骤4:线程切换,从而在主线程显示结果callbackExecutor.execute(newRunnable() {// 最后Okhttp的异步请求结果返回到callbackExecutor// callbackExecutor.execute()通过Handler异步回调将结果传回到主线程进行处理(如显示在Activity等等),即进行了线程切换// 具体是如何做线程切换 ->>分析2@Overridepublicvoidrun(){if(delegate.isCanceled()) {                callback.onFailure(ExecutorCallbackCall.this,newIOException("Canceled"));              }else{                callback.onResponse(ExecutorCallbackCall.this, response);              }            }          });        }@OverridepublicvoidonFailure(Call call,finalThrowable t){          callbackExecutor.execute(newRunnable() {@Overridepublicvoidrun(){              callback.onFailure(ExecutorCallbackCall.this, t);            }          });        }      });    }<-- 分析1:delegate.enqueue()解析 -->@Overridepublicvoidenqueue(finalCallback callback){      okhttp3.Call call;    Throwable failure;// 步骤1:创建OkHttp的Request对象,再封装成OkHttp.call// delegate代理在网络请求前的动作:创建OkHttp的Request对象,再封装成OkHttp.callsynchronized(this) {if(executed)thrownewIllegalStateException("Already executed.");      executed =true;      call = rawCall;      failure = creationFailure;if(call ==null&& failure ==null) {try{                  call = rawCall = createRawCall();// 创建OkHttp的Request对象,再封装成OkHttp.call// 方法同发送同步请求,此处不作过多描述  }catch(Throwable t) {          failure = creationFailure = t;        }      }// 步骤2:发送网络请求// delegate是OkHttpcall的静态代理// delegate静态代理最终还是调用Okhttp.enqueue进行网络请求call.enqueue(newokhttp3.Callback() {@OverridepublicvoidonResponse(okhttp3.Call call, okhttp3.Response rawResponse)throwsIOException{        Response response;try{// 步骤3:解析返回数据response = parseResponse(rawResponse);        }catch(Throwable e) {          callFailure(e);return;        }        callSuccess(response);      }@OverridepublicvoidonFailure(okhttp3.Call call, IOException e){try{          callback.onFailure(OkHttpCall.this, e);        }catch(Throwable t) {          t.printStackTrace();        }      }privatevoidcallFailure(Throwable e){try{          callback.onFailure(OkHttpCall.this, e);        }catch(Throwable t) {          t.printStackTrace();        }      }privatevoidcallSuccess(Response<T> response){try{          callback.onResponse(OkHttpCall.this, response);        }catch(Throwable t) {          t.printStackTrace();        }      }    });  }// 请回去上面分析1的起点<-- 分析2:异步请求后的线程切换-->// 线程切换是通过一开始创建Retrofit对象时Platform在检测到运行环境是Android时进行创建的:(之前已分析过)// 采用适配器模式staticclassAndroidextendsPlatform{// 创建默认的回调执行器工厂// 如果不将RxJava和Retrofit一起使用,一般都是使用该默认的CallAdapter.Factory// 后面会对RxJava和Retrofit一起使用的情况进行分析@OverrideCallAdapter.FactorydefaultCallAdapterFactory(Executor callbackExecutor){returnnewExecutorCallAdapterFactory(callbackExecutor);    }@OverridepublicExecutordefaultCallbackExecutor(){// 返回一个默认的回调方法执行器// 该执行器负责在主线程(UI线程)中执行回调方法returnnewMainThreadExecutor();    }// 获取主线程HandlerstaticclassMainThreadExecutorimplementsExecutor{privatefinalHandler handler =newHandler(Looper.getMainLooper());@Overridepublicvoidexecute(Runnable r){// Retrofit获取了主线程的handler// 然后在UI线程执行网络请求回调后的数据显示等操作。handler.post(r);      }    }// 切换线程的流程:// 1. 回调ExecutorCallAdapterFactory生成了一个ExecutorCallbackCall对象// 2. 通过调用ExecutorCallbackCall.enqueue(CallBack)从而调用MainThreadExecutor的execute()通过handler切换到主线程处理返回结果(如显示在Activity等等)}

以上便是整个以异步方式发送网络请求的过程。

5. 总结

Retrofit本质上是一个RESTful的HTTP网络请求框架的封装,即通过 大量的设计模式 封装了OkHttp,使得简洁易用。具体过程如下:

Retrofit将Http请求 抽象 成Java接口

在接口里用 注解 描述和配置 网络请求参数

用动态代理 的方式,动态将网络请求接口的注解 解析 成HTTP请求

最后执行HTTP请求

最后贴一张非常详细的Retrofit源码分析图:

Retrofit源码分析图

6. 最后

看完本文,相信你已经非常熟悉Retrofit 2.0的源码分析

关于Retrofit 2.0的详细使用教程,请看文章这是一份很详细的 Retrofit 2.0 使用教程(含实例讲解)

接下来,我将继续分析与 Retrofit 配合使用的RxJava,有兴趣可以继续关注Carson_Ho的安卓开发笔记

作者:Carson_Ho

链接:https://www.jianshu.com/p/0c055ad46b6c

来源:简书

简书著作权归作者所有,任何形式的转载都请联系作者获得授权并注明出处。

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

推荐阅读更多精彩内容