之前用的是 HttpClient ，發(fā)現(xiàn)好難用近上！
后來發(fā)現(xiàn) OkHttp3 這個(gè)請(qǐng)求工具挺好用的剔宪！
目前只封裝了 get、post 戈锻、以及文件流上傳
<!-- https://mvnrepository.com/artifact/com.squareup.okhttp3/okhttp -->
<dependency>
<groupId>com.squareup.okhttp3</groupId>
<artifactId>okhttp</artifactId>
<version>4.2.2</version>
</dependency>
<!-- https://mvnrepository.com/artifact/com.google.guava/guava -->
<dependency>
<groupId>com.google.guava</groupId>
<artifactId>guava</artifactId>
<version>28.1-jre</version>
</dependency>
<!-- https://mvnrepository.com/artifact/org.apache.commons/commons-lang3 -->
<dependency>
<groupId>org.apache.commons</groupId>
<artifactId>commons-lang3</artifactId>
<version>3.9</version>
</dependency>
<!-- https://mvnrepository.com/artifact/com.alibaba/fastjson -->
<dependency>
<groupId>com.alibaba</groupId>
<artifactId>fastjson</artifactId>
<version>1.2.62</version>
</dependency>
更新日志：
2020/12/28 新增 獲取 URL 數(shù)據(jù)流(用于用于獲取遠(yuǎn)程圖片等IO流)
2019/11/21 新增 JSON格式數(shù)據(jù)請(qǐng)求
import com.alibaba.fastjson.JSONObject;
import com.google.common.collect.Maps;
import okhttp3.*;
import org.apache.commons.lang3.StringUtils;
import java.io.*;
import java.util.Iterator;
import java.util.Map;
/**
* 封裝請(qǐng)求
* @author weiximei
*/
public class OkHttpRequestUtils {
/**
* 定義請(qǐng)求客戶端
*/
private static OkHttpClient client = new OkHttpClient();
/**
* get 請(qǐng)求
* @param url 請(qǐng)求URL
* @return
* @throws Exception
*/
public static String doGet(String url) throws Exception {
return doGet(url, Maps.newHashMap());
}
/**
* get 請(qǐng)求
* @param url 請(qǐng)求URL
* @param query 攜帶參數(shù)參數(shù)
* @return
* @throws Exception
*/
public static String doGet(String url, Map<String, Object> query) throws Exception {
return doGet(url, Maps.newHashMap(), query);
}
/**
* get 請(qǐng)求
* @param url url
* @param header 請(qǐng)求頭參數(shù)
* @param query 參數(shù)
* @return
*/
public static String doGet(String url, Map<String, Object> header, Map<String, Object> query) throws Exception {
// 創(chuàng)建一個(gè)請(qǐng)求 Builder
Request.Builder builder = new Request.Builder();
// 創(chuàng)建一個(gè) request
Request request = builder.url(url).build();
// 創(chuàng)建一個(gè) HttpUrl.Builder
HttpUrl.Builder urlBuilder = request.url().newBuilder();
// 創(chuàng)建一個(gè) Headers.Builder
Headers.Builder headerBuilder = request.headers().newBuilder();
// 裝載請(qǐng)求頭參數(shù)
Iterator<Map.Entry<String, Object>> headerIterator = header.entrySet().iterator();
headerIterator.forEachRemaining(e -> {
headerBuilder.add(e.getKey(), (String) e.getValue());
});
// 裝載請(qǐng)求的參數(shù)
Iterator<Map.Entry<String, Object>> queryIterator = query.entrySet().iterator();
queryIterator.forEachRemaining(e -> {
urlBuilder.addQueryParameter(e.getKey(), (String) e.getValue());
});
// 設(shè)置自定義的 builder
// 因?yàn)?get 請(qǐng)求的參數(shù)歼跟，是在 URL 后面追加 http://xxxx:8080/user?name=xxxx?sex=1
builder.url(urlBuilder.build()).headers(headerBuilder.build());
try (Response execute = client.newCall(builder.build()).execute()) {
return execute.body().string();
}
}
/**
* post 請(qǐng)求， 請(qǐng)求參數(shù) 并且 攜帶文件上傳
* @param url
* @param header
* @param parameter
* @param file 文件
* @param fileFormName 遠(yuǎn)程接口接收 file 的參數(shù)
* @return
* @throws Exception
*/
public static String doPost(String url, Map<String, Object> header, Map<String, Object> parameter, File file, String fileFormName) throws Exception {
// 創(chuàng)建一個(gè)請(qǐng)求 Builder
Request.Builder builder = new Request.Builder();
// 創(chuàng)建一個(gè) request
Request request = builder.url(url).build();
// 創(chuàng)建一個(gè) Headers.Builder
Headers.Builder headerBuilder = request.headers().newBuilder();
// 裝載請(qǐng)求頭參數(shù)
Iterator<Map.Entry<String, Object>> headerIterator = header.entrySet().iterator();
headerIterator.forEachRemaining(e -> {
headerBuilder.add(e.getKey(), (String) e.getValue());
});
// 或者 FormBody.create 方式格遭，只適用于接口只接收文件流的情況
// RequestBody requestBody = FormBody.create(MediaType.parse("application/octet-stream"), file);
MultipartBody.Builder requestBuilder = new MultipartBody.Builder();
// 狀態(tài)請(qǐng)求參數(shù)
Iterator<Map.Entry<String, Object>> queryIterator = parameter.entrySet().iterator();
queryIterator.forEachRemaining(e -> {
requestBuilder.addFormDataPart(e.getKey(), (String) e.getValue());
});
if (null != file) {
// application/octet-stream
requestBuilder.addFormDataPart(StringUtils.isNotBlank(fileFormName) ? fileFormName : "file", file.getName(), RequestBody.create(file, MediaType.parse("application/octet-stream")));
}
// 設(shè)置自定義的 builder
builder.headers(headerBuilder.build()).post(requestBuilder.build());
// 然后再 build 一下
try (Response execute = client.newCall(builder.build()).execute()) {
return execute.body().string();
}
}
/**
* post 請(qǐng)求哈街， 請(qǐng)求參數(shù) 并且 攜帶文件上傳二進(jìn)制流
* @param url
* @param header
* @param parameter
* @param fileName 文件名
* @param fileByte 文件的二進(jìn)制流
* @param fileFormName 遠(yuǎn)程接口接收 file 的參數(shù)
* @return
* @throws Exception
*/
public static String doPost(String url, Map<String, Object> header, Map<String, Object> parameter, String fileName, byte [] fileByte, String fileFormName) throws Exception {
// 創(chuàng)建一個(gè)請(qǐng)求 Builder
Request.Builder builder = new Request.Builder();
// 創(chuàng)建一個(gè) request
Request request = builder.url(url).build();
// 創(chuàng)建一個(gè) Headers.Builder
Headers.Builder headerBuilder = request.headers().newBuilder();
// 裝載請(qǐng)求頭參數(shù)
Iterator<Map.Entry<String, Object>> headerIterator = header.entrySet().iterator();
headerIterator.forEachRemaining(e -> {
headerBuilder.add(e.getKey(), (String) e.getValue());
});
MultipartBody.Builder requestBuilder = new MultipartBody.Builder();
// 狀態(tài)請(qǐng)求參數(shù)
Iterator<Map.Entry<String, Object>> queryIterator = parameter.entrySet().iterator();
queryIterator.forEachRemaining(e -> {
requestBuilder.addFormDataPart(e.getKey(), (String) e.getValue());
});
if (fileByte.length > 0) {
// application/octet-stream
requestBuilder.addFormDataPart(StringUtils.isNotBlank(fileFormName) ? fileFormName : "file", fileName, RequestBody.create(fileByte, MediaType.parse("application/octet-stream")));
}
// 設(shè)置自定義的 builder
builder.headers(headerBuilder.build()).post(requestBuilder.build());
try (Response execute = client.newCall(builder.build()).execute()) {
return execute.body().string();
}
}
/**
* post 請(qǐng)求 攜帶文件上傳
* @param url
* @param file
* @return
* @throws Exception
*/
public static String doPost(String url, File file, String fileFormName) throws Exception {
return doPost(url, Maps.newHashMap(), Maps.newHashMap(), file, fileFormName);
}
/**
* post 請(qǐng)求
* @param url
* @param header 請(qǐng)求頭
* @param parameter 參數(shù)
* @return
* @throws Exception
*/
public static String doPost(String url, Map<String, Object> header, Map<String, Object> parameter) throws Exception {
return doPost(url, header, parameter, null, null);
}
/**
* post 請(qǐng)求
* @param url
* @param parameter 參數(shù)
* @return
* @throws Exception
*/
public static String doPost(String url, Map<String, Object> parameter) throws Exception {
return doPost(url, Maps.newHashMap(), parameter, null, null);
}
/**
* JSON數(shù)據(jù)格式請(qǐng)求
* @param url
* @param header
* @param json
* @return
*/
private static String json(String url, Map<String, Object> header,String json) throws IOException {
// 創(chuàng)建一個(gè)請(qǐng)求 Builder
Request.Builder builder = new Request.Builder();
// 創(chuàng)建一個(gè) request
Request request = builder.url(url).build();
// 創(chuàng)建一個(gè) Headers.Builder
Headers.Builder headerBuilder = request.headers().newBuilder();
// 裝載請(qǐng)求頭參數(shù)
Iterator<Map.Entry<String, Object>> headerIterator = header.entrySet().iterator();
headerIterator.forEachRemaining(e -> {
headerBuilder.add(e.getKey(), (String) e.getValue());
});
// application/octet-stream
RequestBody requestBody = FormBody.create(json, MediaType.parse("application/json"));
// 設(shè)置自定義的 builder
builder.headers(headerBuilder.build()).post(requestBody);
try (Response execute = client.newCall(builder.build()).execute()) {
return execute.body().string();
}
}
/**
* post請(qǐng)求 參數(shù)JSON格式
* @param url
* @param header 請(qǐng)求頭
* @param json JSON數(shù)據(jù)
* @return
* @throws IOException
*/
public static String doPost(String url, Map<String, Object> header,String json) throws IOException {
return json(url, header, json);
}
/**
* post請(qǐng)求 參數(shù)JSON格式
* @param url
* @param json JSON數(shù)據(jù)
* @return
* @throws IOException
*/
public static String doPost(String url,String json) throws IOException {
return json(url, Maps.newHashMap(), json);
}
/**
* 獲取 url 數(shù)據(jù)流
* ps: 用于獲取遠(yuǎn)程圖片等
* @param url
* @return
* @throws IOException
*/
public static byte[] doGetByte(String url) throws IOException {
// 創(chuàng)建一個(gè)請(qǐng)求 Builder
Request.Builder builder = new Request.Builder();
// 創(chuàng)建一個(gè) request
builder.url(url);
try (Response execute = client.newCall(builder.build()).execute()) {
return execute.body().bytes();
}
}
}
現(xiàn)在寫個(gè) main 方法測(cè)試
public static void main(String[] args) throws Exception {
/**
* JSON 數(shù)據(jù)請(qǐng)求
*/
Map<String, Object> headerMap = Maps.newHashMap();
headerMap.put("app_key","xxx999");
headerMap.put("sign","xxxxxx212bc7c939bb");
Map<String, Object> dataMap = Maps.newHashMap();
dataMap.put("appKey", "xxx999");
dataMap.put("shipId","xxx000668888");
Map<String, Object> jsonMap = Maps.newHashMap();
jsonMap.put("action", "xxxlogistics.querylst");
jsonMap.put("data", dataMap);
// JSON 字符串
System.out.println(OkHttpRequestUtils.doPost("http://localhost:8080/openapi-api", headerMap, JSONObject.toJSONString(jsonMap)));
/**
* 上傳文件
*/
byte [] fileByte = null;
File file = new File("file-read-4182.jpg");
FileInputStream fileInputStream = new FileInputStream(file);
ByteArrayOutputStream bos = new ByteArrayOutputStream();
byte[] b = new byte[1024];
int n;
while ((n = fileInputStream.read(b)) != -1)
{
bos.write(b, 0, n);
}
fileInputStream.close();
bos.close();
fileByte = bos.toByteArray();
Map<String, Object> queryMap = Maps.newHashMap();
queryMap.put("pageNum","2");
queryMap.put("pageSize","50");
System.out.println(OkHttpRequestUtils.doPost("http://localhost:8566/uploadImage" , Maps.newHashMap(), Maps.newHashMap(),file.getName(), fileByte, "uploadFile"));
/**
* 獲取遠(yuǎn)程圖片IO數(shù)據(jù)流
*/
byte[] imgByte = doGetByte("你的圖片地址");
System.out.println(imgByte)
}
