/**
* 类描述：网络请求管理 <br/>
* 创建人：吴冬冬<br/>
* 创建时间：2017/8/4 15:58 <br/>
*/
public class HttpManger {
public static final int HTTP_MANGER_CIRCLE = 10010;
private static Context mContext;
private static HttpManger mHttpManger;
private static OkHttpClient.Builder okhttpBuilder;
private static Retrofit.Builder retrofitBuilder;
private static OkHttpClient okHttpClient;
private static Retrofit retrofit;
public static BaseApiService apiManager;
private final String baseUrl;
private boolean isShowLoading = false;
private int isShowLoadingType = HTTP_MANGER_CIRCLE;
private HttpManger(String baseUrl, BaseApiService apiManager, boolean isShowLoading, int isShowLoadingType){
this.baseUrl = baseUrl;
this.apiManager = apiManager;
this.isShowLoading = isShowLoading;
this.isShowLoadingType = isShowLoadingType;
}
public void executeGet(Context context, final String url, RetrofitCallback retrofitCallback) {
Call<ResponseBody> call = apiManager.executeGet(url);
if (isShowLoading == true) {
retrofitCallback.addShowLoading(context, isShowLoading, isShowLoadingType);
}
call.enqueue(retrofitCallback);
}
public void executeGet(Context context, final String url, @QueryMap(encoded = true) final Map<String, String> maps, RetrofitCallback retrofitCallback) {
Call<ResponseBody> call = apiManager.executeGet(url, maps);
if (isShowLoading == true) {
retrofitCallback.addShowLoading(context, isShowLoading, isShowLoadingType);
}
call.enqueue(retrofitCallback);
}
public void executePost(Context context, final String url, @FieldMap(encoded = true) final Map<String, String> maps, RetrofitCallback retrofitCallback) {
Call<ResponseBody> call = apiManager.executePost(url, maps);
if (isShowLoading == true) {
retrofitCallback.addShowLoading(context, isShowLoading, isShowLoadingType);
}
call.enqueue(retrofitCallback);
}
public static final class Builder {
private static final int DEFAULT_TIMEOUT = 15;
private Context context;
private String baseUrl;
private boolean isLog = false;
private Converter.Factory converterFactory;
private boolean isShowLoading = false;
private int isShowLoadingType = HTTP_MANGER_CIRCLE;
public Builder(Context context) {
okhttpBuilder = new OkHttpClient.Builder();
retrofitBuilder = new Retrofit.Builder();
if(context instanceof Activity) {
this.context = ((Activity) context).getApplicationContext();
} else {
this.context = context;
}
}
/**
* 添加默认地址
*/
public Builder baseUrl(String baseUrl) {
this.baseUrl = Utils.checkNotNull(baseUrl, "baseUrl == null");
return this;
}
/**
* 设置okhttpClient
*/
@NonNull
public Builder client(OkHttpClient client) {
retrofitBuilder.client(Utils.checkNotNull(client, "client == null"));
return this;
}
/**
* 设置连接时间
*/
public Builder connectTimeout(int timeout) {
return connectTimeout(timeout, TimeUnit.SECONDS);
}
public Builder connectTimeout(int timeout, TimeUnit unit) {
if (timeout != -1) {
okhttpBuilder.connectTimeout(timeout, unit);
} else {
okhttpBuilder.connectTimeout(DEFAULT_TIMEOUT, TimeUnit.SECONDS);
}
return this;
}
/**
* 设置写时间
*/
public Builder writeTimeout(int timeout) {
return writeTimeout(timeout, TimeUnit.SECONDS);
}
public Builder writeTimeout(int timeout, TimeUnit unit) {
if (timeout != -1) {
okhttpBuilder.writeTimeout(timeout, unit);
} else {
okhttpBuilder.writeTimeout(DEFAULT_TIMEOUT, TimeUnit.SECONDS);
}
return this;
}
/**
* 设置读时间
*/
public Builder readTimeout(int timeout) {
return readTimeout(timeout, TimeUnit.SECONDS);
}
public Builder readTimeout(int timeout, TimeUnit unit) {
if (timeout != -1) {
okhttpBuilder.readTimeout(timeout, unit);
} else {
okhttpBuilder.readTimeout(DEFAULT_TIMEOUT, TimeUnit.SECONDS);
}
return this;
}
/**
* 设置是否显示网络连接log
*/
public Builder addLog(boolean isLog) {
this.isLog = isLog;
return this;
}
/**
* 是否显示加载框
*/
public Builder addShowLoading(boolean isShowLoading){
this.isShowLoading = isShowLoading;
return this;
}
/**
* 是否显示加载框
*/
public Builder addShowLoading(boolean isShowLoading, int type){
this.isShowLoading = isShowLoading;
this.isShowLoadingType = type;
return this;
}
/**
* 设置添加gson解析fastJson解析。。。
*/
public Builder addConverterFactory(Converter.Factory factory) {
this.converterFactory = factory;
return this;
}
public HttpManger build() {
if (baseUrl == null) {
throw new IllegalStateException("Base URL required.");
}
if (okhttpBuilder == null) {
throw new IllegalStateException("okhttpBuilder required.");
}
if (retrofitBuilder == null) {
throw new IllegalStateException("retrofitBuilder required.");
}
mContext = context;
//ConfigLoader.init(context);
retrofitBuilder.baseUrl(baseUrl);
//gson
/*if (converterFactory == null) {
converterFactory = GsonConverterFactory.create();
}*/
if (converterFactory != null) {
retrofitBuilder.addConverterFactory(converterFactory);
}
//rxjava
/*if (callAdapterFactory == null) {
callAdapterFactory = RxJavaCallAdapterFactory.create();
}
retrofitBuilder.addCallAdapterFactory(callAdapterFactory);*/
//LogWraper.setDebug(isLog && !BuildConfig.DEBUG);
if (isLog) {
okhttpBuilder.addNetworkInterceptor(
new HttpLoggingInterceptor().setLevel(HttpLoggingInterceptor.Level.HEADERS));
okhttpBuilder.addNetworkInterceptor(
new HttpLoggingInterceptor().setLevel(HttpLoggingInterceptor.Level.BODY));
}
okHttpClient = okhttpBuilder.build();
retrofitBuilder.client(okHttpClient);
retrofit = retrofitBuilder.build();
apiManager = retrofit.create(BaseApiService.class);
return new HttpManger(baseUrl, apiManager, isShowLoading, isShowLoadingType);
}
}
}
/**
* 类描述：retrofit接口服务<br/>
* 创建人：吴冬冬<br/>
* 创建时间：2017/8/4 14:51 <br/>
*/
public interface BaseApiService {
/**
* @Url 替换url
* @QueryMap 替换url中查询参数
* @Header 替换header
* @FieldMap 替换post请求body中参数
* @FormUrlEncoded post请求需要加的方法注解
* @POST() 标示该方法为post请求
* @GET() 标示该方法为get请求
*/
@GET()
Call<ResponseBody> executeGet(@Url String url);
//@GET("{path}")
//Call<ResponseBody> executeGet(@Path("path") String path, @QueryMap Map<String, String> datas);
//如果上面这种写法或出现URL异常
// http://api.myapi.com/http%3A%2F%2Fapi.mysite.com%2Fuser%2Flist
//@GET("{path}")
//Call<ResponseBody> executeGet(@Path(value = "path", encoded = true) String path, @QueryMap Map<String, String> datas);
@GET()
Call<ResponseBody> executeGet(@Url String url, @QueryMap Map<String, String> datas);
//@FormUrlEncoded//如果使用fileMap必须加上encoded注解
//@POST("{path}")
//Call<ResponseBody> postMethod(@Path(value = "path", encoded = true) String path, @FieldMap Map<String, String> dates);
@FormUrlEncoded//如果使用fileMap必须加上encoded注解
@POST()
Call<ResponseBody> executePost(@Url String url, @FieldMap Map<String, String> dates);
}
/**
* 类描述： <br/>
* 创建人：吴冬冬<br/>
* 创建时间：2017/8/4 18:26 <br/>
*/
public abstract class RetrofitCallback implements Callback {
private ProgressDialog mProgressDialog;
/**
* 成功中也会可能有错误信息，如账号错误之类的
*/
public abstract void onSuccess(String success);
public abstract void onError(String error);
public void addShowLoading(Context context, boolean isShowLoading, int isShowLoadingType){
if (isShowLoading) {
if (isShowLoadingType == HttpManger.HTTP_MANGER_CIRCLE) {//无限循环
mProgressDialog = new ProgressDialog(context);
mProgressDialog.setMessage(context.getString(R.string.net_loading));
} else {
//其他类型加载框
}
if (mProgressDialog != null) {
mProgressDialog.show();
}
}
}
@Override
public void onResponse(Call call, Response response) {
if (mProgressDialog.isShowing()) {
mProgressDialog.dismiss();
}
if (response.isSuccessful()) {
onSuccess(response.body().toString());
}
}
@Override
public void onFailure(Call call, Throwable t) {
if (mProgressDialog.isShowing()) {
mProgressDialog.dismiss();
}
if (t != null && t.getMessage() != null) {
onError(t.getMessage());
}
}
}
/**
* 类描述：工具类 <br/>
* 创建人：吴冬冬<br/>
* 创建时间：2017/8/4 17:20 <br/>
*/
public class Utils {
public static <T> T checkNotNull(T object, String message) {
if (object == null) {
throw new NullPointerException(message);
}
return object;
}
}
网友评论