package com.ruoyi.worker.voice.util;
|
|
import lombok.extern.slf4j.Slf4j;
|
import org.apache.commons.io.IOUtils;
|
import org.apache.commons.lang3.StringUtils;
|
|
import javax.net.ssl.*;
|
import java.io.*;
|
import java.net.URL;
|
import java.net.URLEncoder;
|
import java.security.cert.CertificateException;
|
import java.security.cert.X509Certificate;
|
import java.util.Map;
|
|
/**
|
* HTTP协议传输工具类
|
*/
|
@Slf4j
|
public class HttpUtil {
|
|
private static final int HTTP_STATUS_OK = 200;
|
|
/**
|
* 向指定 URL发送POST方法的请求
|
*
|
* @param appKey
|
* @param appSecret
|
* @param url
|
* @param jsonBody
|
* @return
|
*/
|
public static String sendPost(String appKey, String appSecret, String url, String jsonBody) {
|
DataOutputStream out = null;
|
BufferedReader in = null;
|
StringBuffer result = new StringBuffer();
|
HttpsURLConnection connection = null;
|
InputStream is = null;
|
HostnameVerifier hv = new HostnameVerifier() {
|
|
@Override
|
public boolean verify(String hostname, SSLSession session) {
|
return true;
|
}
|
};
|
try {
|
trustAllHttpsCertificates();
|
} catch (Exception e1) {
|
e1.printStackTrace();
|
}
|
try {
|
URL realUrl = new URL(url);
|
connection = (HttpsURLConnection) realUrl.openConnection();
|
|
connection.setHostnameVerifier(hv);
|
connection.setDoOutput(true);
|
connection.setDoInput(true);
|
connection.setRequestMethod("POST");
|
connection.setRequestProperty("Accept", "application/json");
|
connection.setRequestProperty("Content-Type", "application/json;charset=UTF-8");
|
connection.setRequestProperty("Authorization",
|
"AKSK realm=\"SDP\",profile=\"UsernameToken\",type=\"Appkey\"");
|
connection.setRequestProperty("X-AKSK", StringUtil.buildAKSKHeader(appKey, appSecret));
|
|
log.info("RequestBody is : " + jsonBody);
|
|
connection.connect();
|
out = new DataOutputStream(connection.getOutputStream());
|
out.writeBytes(jsonBody);
|
out.flush();
|
out.close();
|
|
int status = connection.getResponseCode();
|
if (HTTP_STATUS_OK == status) {
|
is = connection.getInputStream();
|
} else {
|
is = connection.getErrorStream();
|
}
|
in = new BufferedReader(new InputStreamReader(is, "UTF-8"));
|
String line = "";
|
while ((line = in.readLine()) != null) {
|
result.append(line);
|
}
|
} catch (Exception e) {
|
log.info("Send Post request catch exception: " + e.toString());
|
}
|
finally {
|
IOUtils.closeQuietly(out);
|
IOUtils.closeQuietly(is);
|
IOUtils.closeQuietly(in);
|
if (null != connection) {
|
IOUtils.close(connection);
|
}
|
}
|
return result.toString();
|
}
|
|
/**
|
* 向指定 URL发送PUT方法的请求
|
*
|
* @param appKey
|
* @param appSecret
|
* @param url
|
* @param jsonBody
|
* @return
|
*/
|
public static String sendPut(String appKey, String appSecret, String url, String jsonBody) {
|
DataOutputStream out = null;
|
BufferedReader in = null;
|
StringBuffer result = new StringBuffer();
|
HttpsURLConnection connection = null;
|
InputStream is = null;
|
HostnameVerifier hv = new HostnameVerifier() {
|
|
@Override
|
public boolean verify(String hostname, SSLSession session) {
|
return true;
|
}
|
};
|
try {
|
trustAllHttpsCertificates();
|
} catch (Exception e1) {
|
e1.printStackTrace();
|
}
|
try {
|
URL realUrl = new URL(url);
|
connection = (HttpsURLConnection) realUrl.openConnection();
|
|
connection.setHostnameVerifier(hv);
|
connection.setDoOutput(true);
|
connection.setDoInput(true);
|
connection.setRequestMethod("PUT");
|
connection.setRequestProperty("Accept", "application/json");
|
connection.setRequestProperty("Content-Type", "application/json;charset=UTF-8");
|
connection.setRequestProperty("Authorization",
|
"AKSK realm=\"SDP\",profile=\"UsernameToken\",type=\"Appkey\"");
|
connection.setRequestProperty("X-AKSK", StringUtil.buildAKSKHeader(appKey, appSecret));
|
|
log.info("RequestBody is : " + jsonBody);
|
|
connection.connect();
|
out = new DataOutputStream(connection.getOutputStream());
|
out.writeBytes(jsonBody);
|
out.flush();
|
out.close();
|
|
int status = connection.getResponseCode();
|
if (HTTP_STATUS_OK == status) {
|
is = connection.getInputStream();
|
} else {
|
is = connection.getErrorStream();
|
}
|
in = new BufferedReader(new InputStreamReader(is));
|
String line;
|
while ((line = in.readLine()) != null) {
|
result.append(line);
|
}
|
} catch (Exception e) {
|
log.info("Send Put request catch exception: " + e.toString());
|
e.printStackTrace();
|
}
|
finally {
|
IOUtils.closeQuietly(out);
|
IOUtils.closeQuietly(is);
|
IOUtils.closeQuietly(in);
|
if (null != connection) {
|
IOUtils.close(connection);
|
}
|
}
|
return result.toString();
|
}
|
|
/**
|
* 向指定 URL发送DELETE方法的请求
|
*
|
* @param appKey
|
* @param appSecret
|
* @param url
|
* @param params
|
* @return
|
*/
|
public static String sendDelete(String appKey, String appSecret, String url, String params) {
|
BufferedReader in = null;
|
StringBuffer result = new StringBuffer();
|
HttpsURLConnection connection = null;
|
InputStream is = null;
|
|
HostnameVerifier hv = new HostnameVerifier() {
|
|
@Override
|
public boolean verify(String hostname, SSLSession session) {
|
return true;
|
}
|
};
|
try {
|
trustAllHttpsCertificates();
|
} catch (Exception e1) {
|
e1.printStackTrace();
|
}
|
try {
|
String realPath = url + (StringUtils.isEmpty(params) ? "" : "?" + params);
|
URL realUrl = new URL(realPath);
|
connection = (HttpsURLConnection) realUrl.openConnection();
|
|
connection.setHostnameVerifier(hv);
|
connection.setDoInput(true);
|
connection.setRequestMethod("DELETE");
|
connection.setRequestProperty("Accept", "application/json");
|
connection.setRequestProperty("Content-Type", "application/json;charset=UTF-8");
|
connection.setRequestProperty("Authorization",
|
"AKSK realm=\"SDP\",profile=\"UsernameToken\",type=\"Appkey\"");
|
connection.setRequestProperty("X-AKSK", StringUtil.buildAKSKHeader(appKey, appSecret));
|
|
log.info("RequestBody is : " + params);
|
|
connection.connect();
|
|
int status = connection.getResponseCode();
|
if (HTTP_STATUS_OK == status) {
|
is = connection.getInputStream();
|
} else {
|
is = connection.getErrorStream();
|
}
|
in = new BufferedReader(new InputStreamReader(is));
|
String line;
|
while ((line = in.readLine()) != null) {
|
result.append(line);
|
}
|
} catch (Exception e) {
|
log.info("Send DELETE request catch exception: " + e.toString());
|
}
|
finally {
|
IOUtils.closeQuietly(is);
|
IOUtils.closeQuietly(in);
|
if (null != connection) {
|
IOUtils.close(connection);
|
}
|
}
|
return result.toString();
|
}
|
|
/**
|
* 向指定 URL发送GET方法的请求
|
*
|
* @param appKey
|
* @param appSecret
|
* @param url
|
* @param params
|
* @return
|
*/
|
public static String sendGet(String appKey, String appSecret, String url, String params) {
|
BufferedReader in = null;
|
StringBuffer result = new StringBuffer();
|
HttpsURLConnection connection = null;
|
InputStream is = null;
|
|
HostnameVerifier hv = new HostnameVerifier() {
|
|
@Override
|
public boolean verify(String hostname, SSLSession session) {
|
return true;
|
}
|
};
|
try {
|
trustAllHttpsCertificates();
|
} catch (Exception e1) {
|
e1.printStackTrace();
|
}
|
try {
|
String realPath = url + (StringUtils.isEmpty(params) ? "" : "?" + params);
|
URL realUrl = new URL(realPath);
|
connection = (HttpsURLConnection) realUrl.openConnection();
|
|
connection.setHostnameVerifier(hv);
|
connection.setDoInput(true);
|
connection.setRequestMethod("GET");
|
connection.setRequestProperty("Accept", "application/json");
|
connection.setRequestProperty("Content-Type", "application/json;charset=UTF-8");
|
connection.setRequestProperty("Authorization",
|
"AKSK realm=\"SDP\",profile=\"UsernameToken\",type=\"Appkey\"");
|
connection.setRequestProperty("X-AKSK", StringUtil.buildAKSKHeader(appKey, appSecret));
|
connection.setInstanceFollowRedirects(false); //设置本次连接不自动处理重定向
|
|
log.info("RequestBody is : " + params);
|
|
connection.connect();
|
|
int status = connection.getResponseCode();
|
if (301 == status) { //获取录音文件下载地址
|
return connection.getHeaderField("Location");
|
}else if (HTTP_STATUS_OK == status) { //查询绑定信息
|
is = connection.getInputStream();
|
} else { //获取错误码
|
is = connection.getErrorStream();
|
}
|
in = new BufferedReader(new InputStreamReader(is));
|
String line;
|
while ((line = in.readLine()) != null) {
|
result.append(line);
|
}
|
} catch (Exception e) {
|
log.info("Send GET request catch exception: " + e.toString());
|
}
|
finally {
|
IOUtils.closeQuietly(is);
|
IOUtils.closeQuietly(in);
|
if (null != connection) {
|
IOUtils.close(connection);
|
}
|
}
|
return result.toString();
|
}
|
|
/**
|
* 键值对转查询url
|
*
|
* @param map
|
* @return
|
*/
|
public static String map2UrlEncodeString(Map<String, Object> map) {
|
if(null == map || map.isEmpty()) {
|
return "";
|
}
|
StringBuilder sb = new StringBuilder();
|
String temp = "";
|
|
for (String s : map.keySet()) {
|
try {
|
temp = URLEncoder.encode(String.valueOf(map.get(s)), "UTF-8");
|
} catch (UnsupportedEncodingException e) {
|
e.printStackTrace();
|
}
|
sb.append(s).append("=").append(temp).append("&");
|
}
|
return sb.deleteCharAt(sb.length() - 1).toString();
|
}
|
|
/**
|
* 忽略SSL证书校验
|
*
|
* @throws Exception
|
*/
|
static void trustAllHttpsCertificates() throws Exception {
|
TrustManager[] trustAllCerts = new TrustManager[] { new X509TrustManager() {
|
public void checkClientTrusted(X509Certificate[] chain, String authType) throws CertificateException {
|
return;
|
}
|
|
public void checkServerTrusted(X509Certificate[] chain, String authType) throws CertificateException {
|
return;
|
}
|
|
public X509Certificate[] getAcceptedIssuers() {
|
return null;
|
}
|
} };
|
SSLContext sc = SSLContext.getInstance("SSL");
|
sc.init(null, trustAllCerts, null);
|
HttpsURLConnection.setDefaultSSLSocketFactory(sc.getSocketFactory());
|
}
|
}
|
