首先是一个单例模式,之后是对doPost,doGet的一个简单封装
public class HttpUtils {
private static final String TAG =
"HttpUtils-----";
private static HttpUtils httpUtils;
private final int SUCCESS =
0;
private final int ERROR =
1;
private MyHandler myHandler =
new MyHandler();
private OkLoadListener okLoadListener;
public static HttpUtils
getHttpUtils() {
if (httpUtils ==
null) {
httpUtils =
new HttpUtils();
}
return httpUtils;
}
class MyHandler extends Handler {
@Override
public void handleMessage(Message msg) {
switch (msg.what) {
case SUCCESS:
String json = (String) msg.obj;
okLoadListener.okLoadSuccess(json);
break;
case ERROR:
String error = (String) msg.obj;
okLoadListener.okLoadError(error);
break;
}
}
}
public void okGet(String url) {
OkHttpClient okHttpClient =
new OkHttpClient.Builder().addInterceptor(
new MyIntercepter()).build();
Request request =
new Request.Builder().url(url).build();
Call call = okHttpClient.newCall(request);
call.enqueue(
new Callback() {
@Override
public void onFailure(Call call, IOException e) {
Message message = myHandler.obtainMessage();
message.what = ERROR;
message.obj = e.getMessage();
myHandler.sendMessage(message);
}
@Override
public void onResponse(Call call, Response response)
throws IOException {
Message message = myHandler.obtainMessage();
message.what = SUCCESS;
message.obj = response.body().string();
myHandler.sendMessage(message);
}
});
}
public interface OkLoadListener {
void okLoadSuccess(String json);
void okLoadError(String error);
}
public void setOkLoadListener(OkLoadListener okLoadListener) {
this.okLoadListener = okLoadListener;
}
public void okPost(String url, Map<String, String> params) {
OkHttpClient okHttpClient =
new OkHttpClient.Builder().addInterceptor(
new MyIntercepter()).build();
FormBody.Builder builder =
new FormBody.Builder();
Set<String> keySet = params.keySet();
for (String key :
keySet) {
String value = params.get(key);
builder.add(key, value);
}
FormBody formBody = builder.build();
Request request =
new Request.Builder().url(url).post(formBody).build();
Call call = okHttpClient.newCall(request);
call.enqueue(
new Callback() {
@Override
public void onFailure(Call call, IOException e) {
Message message = myHandler.obtainMessage();
message.what = ERROR;
message.obj = e.getMessage();
myHandler.sendMessage(message);
}
@Override
public void onResponse(Call call, Response response)
throws IOException {
Message message = myHandler.obtainMessage();
message.what = SUCCESS;
message.obj = response.body().string();
myHandler.sendMessage(message);
}
});
}
class MyIntercepter implements Interceptor {
@Override
public Response
intercept(Chain chain)
throws IOException {
Request request = chain.request();
String method = request.method();
if (method.equals(
"GET")) {
String url = request.url().toString();
boolean contains = url.contains(
"?");
if (contains) {
url = url +
"&source=android";
}
else {
url = url +
"?source=android";
}
Request request1 = request.newBuilder().url(url).build();
Response response = chain.proceed(request1);
return response;
}
else if (method.equals(
"POST")) {
RequestBody body = request.body();
if (body
instanceof FormBody) {
FormBody.Builder newBuilder =
new FormBody.Builder();
for (
int i =
0; i < ((FormBody) body).size(); i++) {
String key = ((FormBody) body).name(i);
String value = ((FormBody) body).value(i);
newBuilder.add(key, value);
}
newBuilder.add(
"source",
"android");
FormBody newBody = newBuilder.build();
Request request1 = request.newBuilder().post(newBody).build();
Response response = chain.proceed(request1);
return response;
}
}
return null;
}
}
public void upLoadImage(String url, String path) {
MediaType mediaType = MediaType.parse(
"image/*");
MultipartBody.Builder builder =
new MultipartBody.Builder().setType(MultipartBody.FORM);
File file =
new File(path);
MultipartBody multipartBody = builder.addFormDataPart(
"file", file.getName(), RequestBody.create(mediaType, file)).build();
OkHttpClient okHttpClient =
new OkHttpClient();
Request request =
new Request.Builder().url(url).post(multipartBody).build();
Call call = okHttpClient.newCall(request);
call.enqueue(
new Callback() {
@Override
public void onFailure(Call call, IOException e) {
Log.d(TAG,
"上传失败0----: ");
}
@Override
public void onResponse(Call call, Response response)
throws IOException {
Log.d(TAG,
"上传成功: ");
}
});
}
}