我所搭建的MVVM设计模式的Android框架（三）

网络通信用的就是okhttp,这一篇就不详细介绍了，主要分享一下封装好的工具类。
用到的依赖库：

    //网络框架
    implementation 'com.squareup.okhttp3:okhttp:4.6.0'
    //网络请求封装框架
    implementation 'com.squareup.retrofit2:retrofit:2.6.2'
    implementation 'com.squareup.retrofit2:converter-gson:2.6.2'
    implementation 'com.squareup.retrofit2:adapter-rxjava:2.6.2'

public class RetrofitUtil {

    private Retrofit sRetrofit;

    private RetrofitUtil() {
        sRetrofit = initRetrofit();
    }

    private static class Inner {
        private static final RetrofitUtil INSTANCE = new RetrofitUtil();
    }

    /**
     * 获取 静态内部类单例
     * @return 静态内部类单例
     */
    public static RetrofitUtil getInstance() {
        return Inner.INSTANCE;
    }

    /**
     * 创建 Retrofit 实例
     * @return Retrofit实例
     */
    private Retrofit initRetrofit() {
        OkHttpClient.Builder builder = new OkHttpClient().newBuilder()
                .readTimeout(10, TimeUnit.SECONDS)    //传输超时时间
                .connectTimeout(10, TimeUnit.SECONDS)    //连接超时时间
                //网络数据查看拦截器
                .addInterceptor(new CustomInterceptor());

        final Gson gson = new GsonBuilder()
                .disableHtmlEscaping() //禁止转码
                .setLenient()  //允许超长字符串
                .create();

        return new Retrofit.Builder()
                .baseUrl(“这里填服务器地址(http://www.xxx.com/)”)  //服务器地址
                .client(builder.build())
                .addConverterFactory(CustomGsonConverterFactory.create(gson))//解析的封装类
                .addCallAdapterFactory(RxJava2CallAdapterFactory.create())//使用注解方式把请求定义成接口
                .build();
    }

    /**
     * 创建 Api 请求类
     * @param api Api请求原始反射类
     * @param <T> 泛型
     * @return Api请求类
     */
    public <T> T create(final Class<T> api) {
        return sRetrofit.create(api);
    }
}

CustomInterceptor网络拦截器我要额外说一下，当时的网络拦截器会主动请求服务器两次，当时让我找了好久才找到位置改好,下面是改好后的。

public class CustomInterceptor implements Interceptor {

    @NotNull
    @Override
    public Response intercept(@NotNull Chain chain) throws IOException {

        Request request = chain.request();
        RequestBody requestBody = request.body();
        if (requestBody instanceof FormBody) {
            //表单请求
            FormBody formBody = (FormBody) requestBody;
            StringBuilder strBuilder = new StringBuilder();

            for (int i = 0; i < formBody.size(); ++i) {
                String encodeName = formBody.encodedName(i);
                String encodeValue = formBody.encodedValue(i);
                String name = formBody.name(i);
                String value = formBody.value(i);
                strBuilder.append(name + "=" + value + "\n");
//                strBuilder.append(" encodeName: " + encodeName + "  encodeValue: " + encodeValue + "  name: " + name + "  value: " + value);
            }
            System.out.println("请求头: " + formBody.contentType());
            System.out.println("请求体: " + strBuilder.toString());
            System.out.println("url:" + request.url());
        } else if (requestBody instanceof MultipartBody) {
            //文件上传请求
            MultipartBody multipartBody = (MultipartBody) requestBody;
        }

        Response response = chain.proceed(request);
        ResponseBody responseBody = response.body();
        BufferedSource source = responseBody.source();
        source.request(Long.MAX_VALUE); // Buffer the entire body.
        Buffer buffer = source.getBuffer();
        Charset UTF8 = Charset.forName("UTF-8");

        System.out.println("返回数据: " + buffer.clone().readString(UTF8));

        return response;
    }

}

使用方法：

public class BaseBean<T> {

    @SerializedName("code")
    public int code;
    @SerializedName("msg")
    public String msg;
    @SerializedName("data")
    public T data;

    public T getData() {
        return CastUtil.cast(data);
    }

}

public class LoginBean {

    @SerializedName("id")
    public String id;
    @SerializedName("username")
    public String username;
    @SerializedName("password")
    public String password;

}

/**
     * 网络请求接口
     *
     * @param postMap 数据
     * @return Single
     */
    @FormUrlEncoded
    @POST("这里填接口地址(index/index/login)")
    Single<这里填bean类(BaseBean<LoginBean>)> login(@FieldMap Map<String, Object> postMap);

RetrofitUtil.getInstance()
         .create(ServerApi.class)
         .login(postMap)//Map参数集合
         .subscribeOn(Schedulers.io())
         .observeOn(AndroidSchedulers.mainThread())
         .subscribe((BaseBean<LoginBean> bean) -> {

          }, (Throwable throwable) -> {
               throwable.printStackTrace();
          });