源码理解主要从这几个方面
- 解析网络请求接口的注解配置网络请求参数
- 动态代理 生成 网络请求对象
- 网络请求适配器 将网络请求对象 进行平台适配
- 网络请求执行器 发送网络请求
- 数据转换器 解析服务器返回的数据
- 回调执行器 切换线程
- 主线程处理返回结果
public final class Retrofit {
//跟网络相关的方法都存储在这个机会中
private final Map<Method, ServiceMethod<?>> serviceMethodCache = new
ConcurrentHashMap<>();
//用来生产call请求对象的 包含同步请求与异步请求
final okhttp3.Call.Factory callFactory;
//网络请求基地在
final HttpUrl baseUrl;
//数据转换器工厂
final List<Converter.Factory> converterFactories;
//网络请求适配器的集合 用来放置网络请求适配器
final List<CallAdapter.Factory> callAdapterFactories;
//线程切换器 主线程与子线程相互切换使用
final @Nullable Executor callbackExecutor;
final boolean validateEagerly;
OkHttpClient.Builder httpClient = new OkHttpClient.Builder();
Retrofit retrofit = new Retrofit.Builder()
.baseUrl("https://reqres.in/")
.addConverterFactory(GsonConverterFactory.create())
.client(httpClient.build())
.build();
UserService service = retrofit.create(UserService.class);
网络请求实例的创建 create使用到了动态代理
public <T> T create(final Class<T> service) {
Utils.validateServiceInterface(service);
if (validateEagerly) {
eagerlyValidateMethods(service);
}
return (T) Proxy.newProxyInstance(service.getClassLoader(), new Class<?>[] { service },
new InvocationHandler() {//生成动态代理对象
private final Platform platform = Platform.get();
private final Object[] emptyArgs = new Object[0];
//通过invoke 方法来拦截处理网络请求的方法 和注解 返回一个动态代理对象
@Override public @Nullable Object invoke(Object proxy, Method method,
@Nullable Object[] args) throws Throwable {
// If the method is a method from Object then defer to normal invocation.
if (method.getDeclaringClass() == Object.class) {
return method.invoke(this, args);
}
if (platform.isDefaultMethod(method)) {
return platform.invokeDefaultMethod(method, service, proxy, args);
}
return loadServiceMethod(method).invoke(args != null ? args : emptyArgs);
}
});
}
loadServiceMethod使用单例模式 保证唯一性
ServiceMethod<?> loadServiceMethod(Method method) {
ServiceMethod<?> result = serviceMethodCache.get(method);
if (result != null) return result;
synchronized (serviceMethodCache) {
result = serviceMethodCache.get(method);
if (result == null) {
result = ServiceMethod.parseAnnotations(this, method);
serviceMethodCache.put(method, result);
}
}
return result;
}
网友评论