基于okhttp3封装的HttpUtils
HttpUtils
package thread.test.utils;
import com.google.common.collect.Maps;
import okhttp3.*;
import okhttp3.Request.Builder;
import org.apache.commons.collections4.MapUtils;
import org.apache.commons.lang3.StringUtils;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import java.io.File;
import java.io.IOException;
import java.util.Map;
import java.util.concurrent.TimeUnit;
/**
* @author: liubowen
* @date: 2019-04-17 11:32
* @description:
*/
public class HttpUtils {
private static final Logger logger = LoggerFactory.getLogger(HttpUtils.class);
private static final Long READ_TIMEOUT = 5 * 60 * 1000L;
private static final MediaType JSON = MediaType.parse("application/json;charset=utf-8");
public static String doGet(String url) {
return doGet(url, null);
}
public static String doGet(String url, long readTimeout) {
return doGet(url, null, readTimeout);
}
public static String doGet(String url, Map<String, String> headers) {
return doGet(url, headers, READ_TIMEOUT);
}
public static String doGet(String url, Map<String, String> headers, long readTimeout) {
try {
OkHttpClient okHttpClient = okHttpClient(readTimeout);
Builder builder = okHttpClientBuilder(url, headers);
final Request request = builder.build();
final Call call = okHttpClient.newCall(request);
Response response = call.execute();
ResponseBody body = response.body();
String string = body.string();
return string;
} catch (IOException e) {
e.printStackTrace();
}
return null;
}
public static String doPostByFrom(String url) {
return doPostByFrom(url, null);
}
public static String doPostByFrom(String url, long readTimeout) {
return doPostByFrom(url, null, readTimeout);
}
public static String doPostByFrom(String url, Map<String, String> params) {
return doPostByFrom(url, null, params);
}
public static String doPostByFrom(String url, Map<String, String> params, long readTimeout) {
return doPostByFrom(url, null, params, readTimeout);
}
public static String doPostByFrom(String url, Map<String, String> headers, Map<String, String> params) {
return doPostByFrom(url, headers, params, READ_TIMEOUT);
}
public static String doPostByFrom(String url, Map<String, String> headers, Map<String, String> params,
long readTimeout) {
return doPostByFrom(url, headers, params, null, null, null, readTimeout);
}
public static String doPostByFrom(String url, String fileName, File file, MediaType fileType) {
return doPostByFrom(url, fileName, file, fileType, READ_TIMEOUT);
}
public static String doPostByFrom(String url, String fileName, File file, MediaType fileType, long readTimeout) {
return doPostByFrom(url, null, fileName, file, fileType, readTimeout);
}
public static String doPostByFrom(String url, Map<String, String> headers, String fileName, File file,
MediaType fileType, long readTimeout) {
return doPostByFrom(url, headers, null, fileName, file, fileType, readTimeout);
}
public static String doPostByFrom(String url, Map<String, String> headers, Map<String, String> params,
String fileName, File file, MediaType fileType, long readTimeout) {
try {
OkHttpClient okHttpClient = okHttpClient(readTimeout);
Builder builder = okHttpClientBuilder(url, headers);
if (!MapUtils.isEmpty(params)) {
MultipartBody.Builder requestBody = new MultipartBody.Builder().setType(MultipartBody.FORM);
params.forEach((name, value) -> {
requestBody.addFormDataPart(name, value);
});
if (!StringUtils.isEmpty(fileName) && file != null && fileType != null) {
RequestBody body = RequestBody.create(fileType, file);
String filename = file.getName();
// 参数分别为， 请求key ，文件名称 ， RequestBody
requestBody.addFormDataPart(fileName, filename, body);
}
builder.post(requestBody.build());
}
final Request request = builder.build();
final Call call = okHttpClient.newCall(request);
Response response = call.execute();
ResponseBody body = response.body();
String string = body.string();
return string;
} catch (IOException e) {
e.printStackTrace();
}
return null;
}
public static String doPostByJson(String url) {
return doPostByJson(url, Maps.newHashMap(), null, READ_TIMEOUT);
}
public static String doPostByJson(String url, long readTimeout) {
return doPostByJson(url, Maps.newHashMap(), null, readTimeout);
}
public static String doPostByJson(String url, String jsonString) {
return doPostByJson(url, Maps.newHashMap(), jsonString, READ_TIMEOUT);
}
public static String doPostByJson(String url, String jsonString, long readTimeout) {
return doPostByJson(url, Maps.newHashMap(), jsonString, readTimeout);
}
public static String doPostByJson(String url, Map<String, String> headers, String jsonString, long readTimeout) {
try {
OkHttpClient okHttpClient = okHttpClient(readTimeout);
Builder builder = okHttpClientBuilder(url, headers);
if (!StringUtils.isEmpty(jsonString)) {
RequestBody requestBody = RequestBody.create(JSON, jsonString);
builder.post(requestBody);
}
final Request request = builder.build();
final Call call = okHttpClient.newCall(request);
Response response = call.execute();
ResponseBody body = response.body();
String string = body.string();
return string;
} catch (IOException e) {
e.printStackTrace();
}
return null;
}
private static OkHttpClient okHttpClient(long readTimeout) {
OkHttpClient.Builder okHttpClientBuilder = new OkHttpClient.Builder();
// okHttpClientBuilder.connectTimeout(60 * 1000, TimeUnit.MILLISECONDS)
// .readTimeout(5 * 60 * 1000, TimeUnit.MILLISECONDS)
// .writeTimeout(5 * 60 * 1000, TimeUnit.MILLISECONDS);
okHttpClientBuilder.readTimeout(readTimeout, TimeUnit.MILLISECONDS);
OkHttpClient okHttpClient = okHttpClientBuilder.build();
return okHttpClient;
}
private static Builder okHttpClientBuilder(String url, Map<String, String> headers) {
Builder builder = new Builder();
builder.url(url);
if (!MapUtils.isEmpty(headers)) {
headers.forEach((name, value) -> {
builder.addHeader(name, value);
});
}
return builder;
}
}
<dependency>
<groupId>com.squareup.okhttp3</groupId>
<artifactId>okhttp</artifactId>
<version>3.14.1</version>
</dependency>
<dependency>
<groupId>com.google.guava</groupId>
<artifactId>guava</artifactId>
<version>27.1-jre</version>
</dependency>
<dependency>
<groupId>org.apache.commons</groupId>
<artifactId>commons-collections4</artifactId>
<version>4.3</version>
</dependency>
<dependency>
<groupId>ch.qos.logback</groupId>
<artifactId>logback-access</artifactId>
<version>1.2.3</version>
</dependency>
<dependency>
<groupId>ch.qos.logback</groupId>
<artifactId>logback-classic</artifactId>
<version>1.2.3</version>
</dependency>
<dependency>
<groupId>org.apache.commons</groupId>
<artifactId>commons-lang3</artifactId>
<version>3.9</version>
</dependency>
本人第一次发贴 希望大家多多指导， 谢谢🙏
