/**
* OkHttp封装网络请求
*/
public class OkHttpUtils {
private static final String MEDIA_TYPE = "application/json;charset=utf-8";
private static final String METHOD_GET = "GET";
private static final String METHOD_POST = "POST";
private static final String METHOD_PUT = "PUT";
private static final String METHOD_DELETE = "DELETE";
private static OkHttpClient okHttpClient;
private static Gson gson = new Gson();
/**
* 私有化构造方法
* 使用单例模式
*/
private OkHttpUtils() {
}
public static void init(Map headers) {
OkHttpClient.Builder builder = new OkHttpClient.Builder();
builder.connectTimeout(3000, TimeUnit.MILLISECONDS);
builder.readTimeout(3000, TimeUnit.MILLISECONDS);
builder.writeTimeout(3000, TimeUnit.MILLISECONDS);
builder.addInterceptor(new OKHeaderInterceptor(headers));//添加请求头
builder.addInterceptor(new OkLogInterceptor());//添加log日志
okHttpClient = builder.build();
}
/**
* 创建request对象
* @param url
* @param method
* @param baseRequest
* @return
*/
public static Request createRequest(String url, String method, BaseRequest baseRequest) {
RequestBody requestBody = null;
if (baseRequest != null) {
String bodyJson = gson.toJson(baseRequest);
MediaType JSON = MediaType.parse(MEDIA_TYPE);
requestBody = RequestBody.create(JSON, bodyJson);
}
Request.Builder builder = new Request.Builder().url(url);
Request request = null;
switch (method) {
case METHOD_GET:
request = builder.build();
break;
case METHOD_POST:
request = builder.post(requestBody).build();
break;
case METHOD_PUT:
if (requestBody != null) {
request = builder.put(requestBody).build();
}
break;
case METHOD_DELETE:
if (requestBody!=null){
request = builder.delete(requestBody).build();
}else {
request = builder.delete().build();
}
break;
}
return request;
}
/**
* 异步post方法
* @param url
* @param baseRequest
* @param callback
*/
public static void enqueuePost(String url,BaseRequest baseRequest, Callback callback){
Request request = createRequest(url,METHOD_POST,baseRequest);
Call call = okHttpClient.newCall(request);
call.enqueue(callback);
}
/**
* 异步get方法
* @param url
* @param callback
*/
public static void enqueueGet(String url,Callback callback){
Request request = createRequest(url,METHOD_GET,null);
Call call = okHttpClient.newCall(request);
call.enqueue(callback);
}
/**
* 同步post方法 不能再主线程中调用
* @param url
* @param baseRequest
* @return
* @throws IOException
*/
public static Response executePost(String url,BaseRequest baseRequest) throws IOException {
Request request = createRequest(url,METHOD_POST,baseRequest);
Call call = okHttpClient.newCall(request);
Response response = call.execute();
return response;
}
public static Response executeGet(String url) throws IOException {
Request request = createRequest(url, METHOD_GET, null);
Call call = okHttpClient.newCall(request);
Response response = call.execute();
return response;
}
}
请求日志拦截器
public class OkLogInterceptor implements Interceptor {
@Override
public Response intercept(Chain chain) throws IOException {
Request request = chain.request();
String method = request.method();
HttpUrl url = request.url();
Log.d("本次请求", "url:" + url.toString() + "=====method=====" + method);
Log.d("本次json", "json" + request.toString());
Headers headers = request.headers();
Set<String> names = headers.names();
Iterator<String> iterator = names.iterator();
while (iterator.hasNext()) {
String next = iterator.next();
String value = headers.get(next);
Log.d("=============",next + ":" + value);
}
return chain.proceed(request);
}
}
请求头拦截器
public class OKHeaderInterceptor implements Interceptor {
private Map<String,String> headers;
public OKHeaderInterceptor(Map headers){
if (headers!=null){
this.headers = headers;
}
}
@Override
public Response intercept(Chain chain) throws IOException {
Request request= chain.request();
Request.Builder builder = request.newBuilder();
if (headers!=null){
Set set = headers.keySet();
Iterator<String> iterator = set.iterator();
while (iterator.hasNext()){
String next = iterator.next();
builder.addHeader(next,headers.get(next));
}
}
request = builder.build();
return chain.proceed(request);
}
}