Retrofit 源码解读 HTTP

本文主要介绍Retrofit如何使用，源码解读，如何实现HTTP请求？

public interface IMSearchUserService {    @FormUrlEncoded    @POST("/user/heartbeat")    Observable<Result> ping(@FieldMap Map<String, Object> fields);}

        Gson gson = new GsonBuilder() // 用于json的序列化                .setDateFormat("yyyy-MM-dd'T'HH:mm:ss.SSS'Z'")                .serializeNulls()                .create();
        HttpLoggingInterceptor interceptor = new HttpLoggingInterceptor();        interceptor.setLevel(HttpLoggingInterceptor.Level.BODY); // okhttp的拦截器
        TokenInterceptor tokenInterceptor = new TokenInterceptor(); // 自定义okhttp的拦截器        OkHttpClient client = new OkHttpClient.Builder()                .addInterceptor(tokenInterceptor)                .addInterceptor(interceptor)                .retryOnConnectionFailure(true)                .connectTimeout(5, TimeUnit.SECONDS)                .readTimeout(15, TimeUnit.SECONDS)                .build();
        Retrofit mRetrofit = new Retrofit.Builder()                    .baseUrl(ServerConfig.getInstance().getBaseUrl())                    .client(client)                    .addCallAdapterFactory(RxJava2CallAdapterFactory.create())                    .addConverterFactory(GsonConverterFactory.create(gson))                    // .addConverterFactory(FastJsonConverterFactory.create())                    .build();
        IMSearchUserService service = mRetrofit.create(IMSearchUserService.class);

        final Map<String, Object> params = new HashMap<>();        params.put("userId", loginUserId);        params.put("access_token", mAccessToken);        service.ping(params)                .subscribeOn(Schedulers.io())                .observeOn(AndroidSchedulers.mainThread())                .subscribe(result -> { // 请求成功                    // 对请求结果进行解析                }, throwable -> { // 请求失败异常                    LogUtil.printException(throwable);                });

// Retrofit.javapublic <T> T create(final Class<T> service) {    return (T) Proxy.newProxyInstance(service.getClassLoader(), new Class<?>[] { service },        new InvocationHandler() {          private final Platform platform = Platform.get();
          @Override public 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);            }            ServiceMethod<Object, Object> serviceMethod =                (ServiceMethod<Object, Object>) loadServiceMethod(method);            OkHttpCall<Object> okHttpCall = new OkHttpCall<>(serviceMethod, args);            return serviceMethod.callAdapter.adapt(okHttpCall);          }        });  }