Skip to content

规范httpclientutil异常处理逻辑 #75

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Open
tangtuo123 wants to merge 1 commit into
base: 2.0
Choose a base branch
from
Open

规范httpclientutil异常处理逻辑 #75

Changes from all commits
Commits
Show all changes
1 commit
Select commit
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
104 changes: 50 additions & 54 deletions src/main/java/cn/chain33/javasdk/utils/HttpUtil.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -25,15 +25,15 @@
import org.apache.http.ssl.SSLContextBuilder;

public class HttpUtil {

private static CloseableHttpClient client = null;

private static CloseableHttpClient httpsClient = null;

private static RequestConfig requestConfig = null;

private static final String DEFAULT_CHARSET = "UTF-8";

private static final int DEFAULT_TIME_OUT = 400000;
static{
client = HttpClientBuilder.create().build();
Expand All @@ -44,84 +44,80 @@ public class HttpUtil {
requestConfig = configBuilder.build();
httpsClient = createSSLInsecureClient();
}

@SuppressWarnings("deprecation")
public static CloseableHttpClient createSSLInsecureClient() {
try {
SSLContext sslContext = new SSLContextBuilder().loadTrustMaterial(null, new TrustStrategy() {
// 默认信任所有证书
public boolean isTrusted(X509Certificate[] arg0, String arg1) throws CertificateException {
return true;
}
}).build();
// AllowAllHostnameVerifier: 这种方式不对主机名进行验证，验证功能被关闭，是个空操作(域名验证)
SSLConnectionSocketFactory sslcsf = new SSLConnectionSocketFactory(sslContext,
SSLConnectionSocketFactory.ALLOW_ALL_HOSTNAME_VERIFIER);
return HttpClients.custom().setSSLSocketFactory(sslcsf).build();
} catch (KeyManagementException e) {
e.printStackTrace();
} catch (NoSuchAlgorithmException e) {
e.printStackTrace();
} catch (KeyStoreException e) {
e.printStackTrace();
}
return HttpClients.createDefault();
}

private static String getContent(HttpEntity entity,String charset){
String content = null;
if(entity != null){
try {
InputStream in = entity.getContent();
InputStreamReader inputStreamReader = new InputStreamReader(in,charset);
BufferedReader reader = new BufferedReader(inputStreamReader);
StringBuffer stringBuffer = new StringBuffer();
String line = null;
while((line = reader.readLine()) != null){
stringBuffer.append(line);
stringBuffer.append("\r\n");

@SuppressWarnings("deprecation")
public static CloseableHttpClient createSSLInsecureClient() {
try {
SSLContext sslContext = new SSLContextBuilder().loadTrustMaterial(null, new TrustStrategy() {
// 默认信任所有证书
public boolean isTrusted(X509Certificate[] arg0, String arg1) throws CertificateException {
return true;
}
content = stringBuffer.toString();
} catch (Exception e) {
e.printStackTrace();
}).build();
// AllowAllHostnameVerifier: 这种方式不对主机名进行验证，验证功能被关闭，是个空操作(域名验证)
SSLConnectionSocketFactory sslcsf = new SSLConnectionSocketFactory(sslContext,
SSLConnectionSocketFactory.ALLOW_ALL_HOSTNAME_VERIFIER);
return HttpClients.custom().setSSLSocketFactory(sslcsf).build();
} catch (KeyManagementException | NoSuchAlgorithmException | KeyStoreException e) {
e.printStackTrace();
}
return HttpClients.createDefault();
}

private static String getContent(HttpEntity entity, String charset) {
if (entity == null) {
throw new RuntimeException("请求失败");
}
try {
InputStream in = entity.getContent();
InputStreamReader inputStreamReader = new InputStreamReader(in, charset);
BufferedReader reader = new BufferedReader(inputStreamReader);
StringBuffer stringBuffer = new StringBuffer();
String line = null;
while ((line = reader.readLine()) != null) {
stringBuffer.append(line);
stringBuffer.append("\r\n");
}
return stringBuffer.toString();
} catch (Exception e) {
e.printStackTrace();
throw new RuntimeException(e);
}
return content;
}


public static String httpPostBody(String url, String jsonString) {
String content = null;
String content;
HttpPost post = new HttpPost(url);
try {
post.setConfig(requestConfig);
post.addHeader("Content-Type", "application/json");
post.setEntity(new StringEntity(jsonString,DEFAULT_CHARSET));
post.setEntity(new StringEntity(jsonString, DEFAULT_CHARSET));
HttpResponse response = client.execute(post);
HttpEntity entity = response.getEntity();
content = getContent(entity,DEFAULT_CHARSET);
content = getContent(entity, DEFAULT_CHARSET);
post.releaseConnection();
} catch (Exception e) {
e.printStackTrace();
return null;
throw new RuntimeException(e);
}
return content;
}

public static String httpsPostBody(String url, String jsonString) {
String content = null;
HttpPost post = new HttpPost(url);
try {
post.setConfig(requestConfig);
post.addHeader("Content-Type", "application/json");
post.setEntity(new StringEntity(jsonString,DEFAULT_CHARSET));
post.setEntity(new StringEntity(jsonString, DEFAULT_CHARSET));
HttpResponse response = httpsClient.execute(post);
HttpEntity entity = response.getEntity();
content = getContent(entity,DEFAULT_CHARSET);
content = getContent(entity, DEFAULT_CHARSET);
post.releaseConnection();
} catch (Exception e) {
e.printStackTrace();
return null;
throw new RuntimeException(e);
}
return content;
}
Expand Down