128 lines
4.7 KiB
Java
128 lines
4.7 KiB
Java
package com.eg.www.common.utils;
|
||
|
||
import cn.hutool.json.JSONObject;
|
||
import cn.hutool.json.JSONUtil;
|
||
import okhttp3.*;
|
||
import com.eg.www.common.CommonConstants;
|
||
import com.eg.www.common.MyConsole;
|
||
|
||
import java.util.concurrent.TimeUnit;
|
||
|
||
/**
|
||
* Description: http请求工具类
|
||
* Author: Eg
|
||
* Date: 2021/08/29
|
||
*/
|
||
public class OkHttpUtil {
|
||
|
||
// 日志界面
|
||
MyConsole console = CommonConstants.console;
|
||
|
||
static OkHttpClient client = new OkHttpClient().newBuilder().connectTimeout(5, TimeUnit.MINUTES).build();
|
||
static MediaType mediaType = MediaType.parse("application/json");
|
||
static RequestBody body;
|
||
static Request request;
|
||
|
||
|
||
/**
|
||
* 阿里云盘交互的POST请求
|
||
* @param url https://websv.aliyundrive.com/token/refresh
|
||
* @param data
|
||
* @return
|
||
* @throws Exception
|
||
*/
|
||
public JSONObject doPost(String url, JSONObject data){
|
||
int errNum=0;
|
||
try {
|
||
body = RequestBody.create(mediaType,data.toString());
|
||
request = new Request.Builder()
|
||
.url(url)
|
||
.method("POST", body)
|
||
.addHeader("authorization", CommonConstants.TOKEN)
|
||
.addHeader("Content-Type", "application/json").build();
|
||
Response response = client.newCall(request).execute();
|
||
String result = response.body().string();
|
||
CommonConstants.addConsole("请求状态码："+response.code());
|
||
//System.out.println("result：>>>>>>>>>>>>>>>>>>>"+result);
|
||
return JSONUtil.parseObj(result);
|
||
} catch (Exception e) {
|
||
if (e.toString().contains("A JSONObject text")){
|
||
CommonConstants.addConsole("普通请求遇到异常："+e.toString());
|
||
return null;
|
||
}else {
|
||
errNum++;
|
||
CommonConstants.addConsole("普通请求遇到异常："+e.toString());
|
||
if (errNum>5){
|
||
CommonConstants.addConsole("普通请求失败次数超过："+errNum+" 次....已停止");
|
||
return null;
|
||
}else{
|
||
CommonConstants.addConsole("普通请求发起第："+errNum+" 次重试");
|
||
return doPost(url,data);
|
||
}
|
||
}
|
||
}
|
||
}
|
||
|
||
/**
|
||
* 阿里云盘上传文件的POST请求
|
||
* @param url https://api.aliyundrive.com/v2/file/create
|
||
* @param data
|
||
* @return
|
||
* @throws Exception
|
||
*/
|
||
public JSONObject doFilePost(String url,JSONObject data){
|
||
int errNum=0;
|
||
try {
|
||
RequestBody body = RequestBody.create(mediaType, data.toString());
|
||
request = new Request.Builder()
|
||
.url(url)
|
||
.method("POST", body)
|
||
.addHeader("authorization",CommonConstants.TOKEN)
|
||
.addHeader("Content-Type", "multipart/form-data").build();
|
||
Response response = client.newCall(request).execute();
|
||
String result = response.body().string();
|
||
CommonConstants.addConsole("请求状态码："+response.code());
|
||
//System.out.println("result：>>>>>>>>>>>>>>>>>>>"+result);
|
||
return JSONUtil.parseObj(result);
|
||
} catch (Exception e) {
|
||
errNum++;
|
||
CommonConstants.addConsole("上传请求遇到异常："+e.toString());
|
||
if (errNum>5){
|
||
CommonConstants.addConsole("上传请求失败次数超过："+errNum+" 次....已停止");
|
||
return null;
|
||
}else{
|
||
CommonConstants.addConsole("上传请求发起第："+errNum+" 次重试");
|
||
return doFilePost(url,data);
|
||
}
|
||
}
|
||
}
|
||
|
||
/**
|
||
* 阿里云盘上传二进制文件
|
||
* @param url
|
||
* @param fileBytes
|
||
* @return
|
||
* @throws Exception
|
||
*/
|
||
public void uploadFileBytes(String url,byte[] fileBytes){
|
||
int errNum=0;
|
||
try {
|
||
RequestBody body = RequestBody.create(fileBytes);
|
||
Request request = new Request.Builder().url(url).method("PUT",body).build();
|
||
Response response = client.newCall(request).execute();
|
||
//String result=response.body().string();
|
||
CommonConstants.addConsole("上传文件请求状态码："+response.code());
|
||
} catch (Exception e) {
|
||
errNum++;
|
||
CommonConstants.addConsole("上传文件遇到异常："+e.toString());
|
||
if (errNum>5){
|
||
CommonConstants.addConsole("上传文件失败次数超过："+errNum+" 次....已停止");
|
||
return;
|
||
}else{
|
||
CommonConstants.addConsole("上传文件发起第："+errNum+" 次重试");
|
||
uploadFileBytes(url,fileBytes);
|
||
}
|
||
}
|
||
}
|
||
}
|