wangbing
5 years ago
parent
f74326117f
commit
d3f84721bd
@ -0,0 +1,431 @@
|
||||
package ${domain};
|
||||
|
||||
import okhttp3.*;
|
||||
|
||||
import java.io.*;
|
||||
import java.net.ConnectException;
|
||||
import java.net.SocketTimeoutException;
|
||||
import java.util.concurrent.TimeUnit;
|
||||
import java.security.PublicKey;
|
||||
|
||||
public class ApiClient {
|
||||
private static ApiClient ourInstance = null;
|
||||
|
||||
public static void init(String serverUrl, String appKey, String appSecret) {
|
||||
init(serverUrl, appKey, appSecret, DEFAULT_CONNECT_TIMEOUT, DEFAULT_READ_TIMEOUT);
|
||||
}
|
||||
|
||||
public static void init(String serverUrl, String appKey, String appSecret, int connectTimeout, int readTimeout) {
|
||||
ourInstance = new ApiClient(serverUrl, appKey, appSecret, connectTimeout, readTimeout);
|
||||
}
|
||||
|
||||
public static ApiClient getInstance() {
|
||||
if (ourInstance == null) {
|
||||
System.err.print("ApiClient need init");
|
||||
}
|
||||
return ourInstance;
|
||||
}
|
||||
|
||||
//基本请求参数KEY
|
||||
private static final String P_APP_KEY = "app_key";
|
||||
private static final String P_TYPE = "type";
|
||||
private static final String P_TARGET = "target";
|
||||
private static final String P_FILE_NAME = "file_name";
|
||||
private static final String P_TIMESTAMP = "timestamp";
|
||||
private static final String P_METHOD = "method";
|
||||
private static final String P_SIGN = "sign";
|
||||
private static final String P_TOKEN = "token_id";
|
||||
private static final String P_ENHANCED = "enhanced";
|
||||
//参数类型
|
||||
private static final String TYPE_JSON = "json";
|
||||
private static final String TYPE_FILE = "file";
|
||||
//应用码
|
||||
private String appKey;
|
||||
//应用安全码
|
||||
private String appSecret;
|
||||
//服务器地址
|
||||
private String serverUrl;
|
||||
//公钥
|
||||
private PublicKey publicKey = null;
|
||||
private OkHttpClient httpClient = null;
|
||||
//默认参数
|
||||
private static final int DEFAULT_CONNECT_TIMEOUT = 3;//秒
|
||||
private static final int DEFAULT_READ_TIMEOUT = 30;//秒
|
||||
//请求配置
|
||||
private int connectTimeout;//3秒
|
||||
private int readTimeout;//30秒
|
||||
private boolean needCheckRequest = true; // 是否在客户端校验请求
|
||||
private boolean needEnableParser = true; // 是否对响应结果进行解释
|
||||
|
||||
private Before before = null;
|
||||
private After after = null;
|
||||
private String token = "";
|
||||
private boolean debug = false;
|
||||
|
||||
private ApiClient(String serverUrl, String appKey, String appSecret, int connectTimeout, int readTimeout) {
|
||||
this.connectTimeout = connectTimeout;
|
||||
this.readTimeout = readTimeout;
|
||||
this.appKey = appKey;
|
||||
this.appSecret = appSecret;
|
||||
this.serverUrl = serverUrl;
|
||||
this.httpClient = new OkHttpClient.Builder()
|
||||
.readTimeout(readTimeout, TimeUnit.SECONDS)
|
||||
.connectTimeout(connectTimeout, TimeUnit.SECONDS)
|
||||
.build();
|
||||
}
|
||||
|
||||
public void setPublicKey(PublicKey publicKey) {
|
||||
this.publicKey = publicKey;
|
||||
}
|
||||
|
||||
public interface Callback<T extends ApiResponse> {
|
||||
void call(T response);
|
||||
}
|
||||
|
||||
public interface Before {
|
||||
void call(ApiRequest request);
|
||||
}
|
||||
|
||||
public interface After {
|
||||
void call(ApiRequest request, ApiResponse response);
|
||||
}
|
||||
|
||||
public void setAfter(After after) {
|
||||
this.after = after;
|
||||
}
|
||||
|
||||
public void setBefore(Before before) {
|
||||
this.before = before;
|
||||
}
|
||||
|
||||
public <T extends ApiResponse> T execute(ApiRequest<T> request, boolean isEnhanced, ProgressRequestBody.ProgressListener listener) {
|
||||
if (before != null) {
|
||||
before.call(request);
|
||||
}
|
||||
|
||||
// 检查请求参数
|
||||
T t = MapperUtil.toJava("{}", request.responseClass());
|
||||
if (isEnhanced && publicKey == null) {
|
||||
t.addError(ErrorType.BUSINESS_ERROR, "publicKey can not be null.");
|
||||
}
|
||||
if (t.hasError()) {
|
||||
return t;
|
||||
}
|
||||
|
||||
try {
|
||||
//装载请求参数
|
||||
String currentTime = String.valueOf(System.currentTimeMillis());
|
||||
RequestBody requestBody = new MultipartBody.Builder()
|
||||
.addFormDataPart(P_APP_KEY, appKey)
|
||||
.addFormDataPart("isEnhanced", "false")
|
||||
.addFormDataPart("encryptData", null, ProgressRequestBody.createProgressRequestBody(encode(request, isEnhanced), listener))
|
||||
.addFormDataPart(P_TIMESTAMP, currentTime)
|
||||
.addFormDataPart(P_SIGN, sign(request, currentTime))
|
||||
.addFormDataPart(P_ENHANCED, String.valueOf(isEnhanced))
|
||||
.addFormDataPart(P_TOKEN, token)
|
||||
.build();
|
||||
|
||||
Request build = new Request.Builder()
|
||||
.url(serverUrl + request.apiMethod())
|
||||
.post(requestBody)
|
||||
.build();
|
||||
|
||||
Response response = httpClient.newCall(build).execute();
|
||||
String responseJson = decryptResponse(response, isEnhanced);
|
||||
t = MapperUtil.toJava(responseJson, request.responseClass());
|
||||
|
||||
} catch (ConnectException e) {
|
||||
t = MapperUtil.toJava("{}", request.responseClass());
|
||||
t.addError(ErrorType.SYSTEM_ERROR, "网络异常!");
|
||||
} catch (SocketTimeoutException e) {
|
||||
t = MapperUtil.toJava("{}", request.responseClass());
|
||||
t.addError(ErrorType.SYSTEM_ERROR, "请求超时!");
|
||||
} catch (IOException e) {
|
||||
t = MapperUtil.toJava("{}", request.responseClass());
|
||||
t.addError(ErrorType.SYSTEM_ERROR, "请求异常!");
|
||||
} finally {
|
||||
if (after != null) {
|
||||
after.call(request, t);
|
||||
}
|
||||
}
|
||||
return t;
|
||||
}
|
||||
|
||||
public <T extends ApiResponse> void execute(ApiRequest<T> request, Callback callback) {
|
||||
execute(request, false, callback, null);
|
||||
}
|
||||
|
||||
public <T extends ApiResponse> void execute(final ApiRequest<T> request, final boolean isEnhanced, final Callback callback, ProgressRequestBody.ProgressListener listener) {
|
||||
if (before != null) {
|
||||
before.call(request);
|
||||
}
|
||||
|
||||
// 检查请求参数
|
||||
T t = MapperUtil.toJava("{}", request.responseClass());
|
||||
if (isEnhanced && publicKey == null) {
|
||||
t.addError(ErrorType.BUSINESS_ERROR, "publicKey can not be null.");
|
||||
}
|
||||
if (t.hasError()) {
|
||||
if (after != null) {
|
||||
after.call(request, t);
|
||||
}
|
||||
if (callback != null) {
|
||||
callback.call(t);
|
||||
}
|
||||
return;
|
||||
}
|
||||
|
||||
try {
|
||||
//装载请求参数
|
||||
String currentTime = String.valueOf(System.currentTimeMillis());
|
||||
RequestBody requestBody = new FormBody.Builder()
|
||||
.add(P_APP_KEY, appKey)
|
||||
.add(P_METHOD, request.apiMethod())
|
||||
.add(P_TYPE, TYPE_JSON)
|
||||
// .add(P_TARGET, null, ProgressRequestBody.createProgressRequestBody(encode(request, isEnhanced), listener))
|
||||
.add(P_TIMESTAMP, currentTime)
|
||||
.add(P_SIGN, sign(request, currentTime))
|
||||
.add(P_ENHANCED, String.valueOf(isEnhanced))
|
||||
.add(P_TOKEN, token)
|
||||
.build();
|
||||
|
||||
Request build = new Request.Builder()
|
||||
.url(serverUrl + request.apiMethod())
|
||||
.post(requestBody)
|
||||
.build();
|
||||
|
||||
httpClient.newCall(build).enqueue(new okhttp3.Callback() {
|
||||
public void onFailure(Call call, IOException e) {
|
||||
e.printStackTrace();
|
||||
T t = MapperUtil.toJava("{}", request.responseClass());
|
||||
if (e instanceof ConnectException) {
|
||||
t.addError(ErrorType.BUSINESS_ERROR, "网络异常!");
|
||||
} else if (e instanceof SocketTimeoutException) {
|
||||
t.addError(ErrorType.BUSINESS_ERROR, "请求超时!");
|
||||
} else {
|
||||
t.addError(ErrorType.BUSINESS_ERROR, "请求异常!");
|
||||
}
|
||||
|
||||
if (after != null) {
|
||||
after.call(request, t);
|
||||
}
|
||||
if (callback != null) {
|
||||
callback.call(t);
|
||||
}
|
||||
}
|
||||
|
||||
public void onResponse(Call call, Response response) throws IOException {
|
||||
T t = null;
|
||||
try {
|
||||
|
||||
String responseJson = decryptResponse(response, isEnhanced);
|
||||
t = MapperUtil.toJava(responseJson, request.responseClass());
|
||||
|
||||
} catch (Exception e) {
|
||||
e.printStackTrace();
|
||||
t = MapperUtil.toJava("{}", request.responseClass());
|
||||
t.addError(ErrorType.BUSINESS_ERROR, "服务器走了下神!");
|
||||
}
|
||||
if (after != null) {
|
||||
after.call(request, t);
|
||||
}
|
||||
if (callback != null) {
|
||||
callback.call(t);
|
||||
}
|
||||
}
|
||||
});
|
||||
} catch (Exception e) {
|
||||
T baseResponse = MapperUtil.toJava("{}", request.responseClass());
|
||||
baseResponse.addError(ErrorType.SYSTEM_ERROR, "请求异常!");
|
||||
if (after != null) {
|
||||
after.call(request, baseResponse);
|
||||
}
|
||||
if (callback != null) {
|
||||
callback.call(baseResponse);
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
|
||||
public void fileUpload(final FileUploadRequest request, final Callback<FileUploadResponse> callback, ProgressRequestBody.ProgressListener listener) {
|
||||
if (before != null) {
|
||||
before.call(request);
|
||||
}
|
||||
|
||||
try {
|
||||
//检查文件是否存在
|
||||
if (!request.isExist()) {
|
||||
FileUploadResponse fileUploadResponse = new FileUploadResponse();
|
||||
fileUploadResponse.addError(ErrorType.BUSINESS_ERROR, "文件不存在!");
|
||||
if (after != null) {
|
||||
after.call(request, fileUploadResponse);
|
||||
}
|
||||
callback.call(fileUploadResponse);
|
||||
return;
|
||||
}
|
||||
|
||||
//装载请求参数
|
||||
String currentTime = String.valueOf(System.currentTimeMillis());
|
||||
MultipartBody.Builder builder = new MultipartBody.Builder()
|
||||
.addFormDataPart(P_APP_KEY, appKey)
|
||||
.addFormDataPart(P_METHOD, request.apiMethod())
|
||||
.addFormDataPart(P_TYPE, TYPE_FILE)
|
||||
.addFormDataPart(P_TIMESTAMP, currentTime)
|
||||
.addFormDataPart(P_SIGN, sign(request, currentTime))
|
||||
.addFormDataPart(P_TOKEN, token);
|
||||
|
||||
if (request.getFile() != null) {
|
||||
builder.addFormDataPart(P_TARGET, request.getFile().getName(), ProgressRequestBody.createProgressRequestBody(MediaType.parse("image/*"), request.getFile(), listener));
|
||||
builder.addFormDataPart(P_FILE_NAME, request.getFileName());
|
||||
} else {
|
||||
builder.addFormDataPart(P_TARGET, null, ProgressRequestBody.createProgressRequestBody(Base64Util.encodeToString(request.getBytes()), listener));
|
||||
builder.addFormDataPart(P_FILE_NAME, request.getFileName());
|
||||
}
|
||||
MultipartBody multipartBody = builder.build();
|
||||
|
||||
Request build = new Request.Builder()
|
||||
.url(serverUrl)
|
||||
.post(multipartBody)
|
||||
.build();
|
||||
|
||||
httpClient.newCall(build).enqueue(new okhttp3.Callback() {
|
||||
public void onFailure(Call call, IOException e) {
|
||||
e.printStackTrace();
|
||||
FileUploadResponse t = MapperUtil.toJava("{}", FileUploadResponse.class);
|
||||
if (e instanceof ConnectException) {
|
||||
t.addError(ErrorType.BUSINESS_ERROR, "网络异常!");
|
||||
} else if (e instanceof SocketTimeoutException) {
|
||||
t.addError(ErrorType.BUSINESS_ERROR, "请求超时!");
|
||||
} else {
|
||||
t.addError(ErrorType.BUSINESS_ERROR, "请求异常!");
|
||||
}
|
||||
|
||||
if (after != null) {
|
||||
after.call(request, t);
|
||||
}
|
||||
if (callback != null) {
|
||||
callback.call(t);
|
||||
}
|
||||
}
|
||||
|
||||
public void onResponse(Call call, Response response) throws IOException {
|
||||
|
||||
FileUploadResponse t = null;
|
||||
try {
|
||||
|
||||
String responseJson = decryptResponse(response, false);
|
||||
t = MapperUtil.toJava(responseJson, FileUploadResponse.class);
|
||||
|
||||
} catch (Exception e) {
|
||||
e.printStackTrace();
|
||||
t = new FileUploadResponse();
|
||||
t.addError(ErrorType.BUSINESS_ERROR, "服务器走了下神!");
|
||||
}
|
||||
|
||||
if (after != null) {
|
||||
after.call(request, t);
|
||||
}
|
||||
if (callback != null) {
|
||||
callback.call(t);
|
||||
}
|
||||
}
|
||||
});
|
||||
|
||||
} catch (Exception e) {
|
||||
e.printStackTrace();
|
||||
}
|
||||
}
|
||||
|
||||
/**
|
||||
* 对请求进行加密编码
|
||||
*
|
||||
* @param request
|
||||
* @return
|
||||
*/
|
||||
private String encode(ApiRequest request, boolean isEnhanced) {
|
||||
String json = MapperUtil.toJson(request);
|
||||
if (isEnhanced) {
|
||||
return RSAUtil.encrypt2Base64(json.getBytes());
|
||||
} else {
|
||||
return AESUtil.encrypt2Base64(json.getBytes(), appSecret);
|
||||
}
|
||||
}
|
||||
|
||||
/**
|
||||
* 对响应进行解密
|
||||
*
|
||||
* @param response
|
||||
* @return
|
||||
*/
|
||||
private String decryptResponse(Response response, boolean isEnhanced) throws IOException {
|
||||
String responseString = response.body().string();
|
||||
String responseJson;
|
||||
if (isEnhanced) {
|
||||
responseJson = RSAUtil.decrypt2String(responseString);
|
||||
} else {
|
||||
responseJson = AESUtil.decrypt2String(responseString, appSecret);
|
||||
}
|
||||
|
||||
if (debug) {
|
||||
System.out.println("加密响应结果:" + responseString);
|
||||
System.out.println("响应结果:" + responseJson);
|
||||
}
|
||||
return responseJson;
|
||||
}
|
||||
|
||||
/**
|
||||
* 对请求进行签名
|
||||
*
|
||||
* @param request
|
||||
* @return
|
||||
*/
|
||||
private String sign(ApiRequest request, String currentTime) {
|
||||
if (request instanceof FileUploadRequest) {//文件签名、对文件字节生成的信息摘要签名
|
||||
FileUploadRequest fileUploadRequest = (FileUploadRequest) request;
|
||||
String encode = MD5Util.encode(fileUploadRequest.getFile() != null ? toByteArray(fileUploadRequest.getFile()) : fileUploadRequest.getBytes());
|
||||
return MD5Util.encode(appSecret + encode + currentTime);
|
||||
} else {//普通参数签名、此处JSON是经过排序生成的JSON字符串,因此验签时也需要排序
|
||||
String json = MapperUtil.toJson(request);
|
||||
return MD5Util.encode(appSecret + json + currentTime);
|
||||
}
|
||||
}
|
||||
|
||||
public static byte[] toByteArray(File file) {
|
||||
File f = file;
|
||||
if (!f.exists()) {
|
||||
return null;
|
||||
}
|
||||
ByteArrayOutputStream bos = new ByteArrayOutputStream((int) f.length());
|
||||
BufferedInputStream in = null;
|
||||
try {
|
||||
in = new BufferedInputStream(new FileInputStream(f));
|
||||
int buf_size = 1024;
|
||||
byte[] buffer = new byte[buf_size];
|
||||
int len = 0;
|
||||
while (-1 != (len = in.read(buffer, 0, buf_size))) {
|
||||
bos.write(buffer, 0, len);
|
||||
}
|
||||
return bos.toByteArray();
|
||||
} catch (IOException e) {
|
||||
return null;
|
||||
} finally {
|
||||
try {
|
||||
in.close();
|
||||
} catch (IOException e) {
|
||||
e.printStackTrace();
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
public void setTokenId(String token) {
|
||||
this.token = token;
|
||||
}
|
||||
|
||||
public boolean isDebug() {
|
||||
return debug;
|
||||
}
|
||||
|
||||
public void setDebug(boolean debug) {
|
||||
this.debug = debug;
|
||||
}
|
||||
}
|
||||
Loading…
Reference in new issue