package com.landtool.lanbase.common.utils;
|
|
import java.io.IOException;
|
import java.io.InterruptedIOException;
|
import java.io.UnsupportedEncodingException;
|
import java.net.UnknownHostException;
|
import java.util.*;
|
|
import javax.net.ssl.SSLException;
|
import javax.net.ssl.SSLHandshakeException;
|
|
import com.alibaba.fastjson.JSON;
|
import com.qiniu.util.Json;
|
import org.apache.http.HttpEntity;
|
import org.apache.http.HttpEntityEnclosingRequest;
|
import org.apache.http.HttpHost;
|
import org.apache.http.HttpRequest;
|
import org.apache.http.NameValuePair;
|
import org.apache.http.NoHttpResponseException;
|
import org.apache.http.client.HttpRequestRetryHandler;
|
import org.apache.http.client.config.RequestConfig;
|
import org.apache.http.client.entity.UrlEncodedFormEntity;
|
import org.apache.http.client.methods.CloseableHttpResponse;
|
import org.apache.http.client.methods.HttpGet;
|
import org.apache.http.client.methods.HttpPost;
|
import org.apache.http.client.methods.HttpRequestBase;
|
import org.apache.http.client.protocol.HttpClientContext;
|
import org.apache.http.config.Registry;
|
import org.apache.http.config.RegistryBuilder;
|
import org.apache.http.conn.ConnectTimeoutException;
|
import org.apache.http.conn.routing.HttpRoute;
|
import org.apache.http.conn.socket.ConnectionSocketFactory;
|
import org.apache.http.conn.socket.LayeredConnectionSocketFactory;
|
import org.apache.http.conn.socket.PlainConnectionSocketFactory;
|
import org.apache.http.conn.ssl.SSLConnectionSocketFactory;
|
import org.apache.http.impl.client.CloseableHttpClient;
|
import org.apache.http.impl.client.HttpClients;
|
import org.apache.http.impl.conn.PoolingHttpClientConnectionManager;
|
import org.apache.http.message.BasicNameValuePair;
|
import org.apache.http.protocol.HttpContext;
|
import org.apache.http.util.EntityUtils;
|
|
public class HttpClientUtils {
|
|
static final int timeOut = 10 * 1000;
|
|
private static CloseableHttpClient httpClient = null;
|
|
private final static Object syncLock = new Object();
|
|
private static void config(HttpRequestBase httpRequestBase) {
|
// 设置Header等
|
// httpRequestBase.setHeader("User-Agent", "Mozilla/5.0");
|
// httpRequestBase
|
// .setHeader("Accept",
|
// "text/html,application/xhtml+xml,application/xml;q=0.9,*/*;q=0.8");
|
// httpRequestBase.setHeader("Accept-Language",
|
// "zh-CN,zh;q=0.8,en-US;q=0.5,en;q=0.3");// "en-US,en;q=0.5");
|
// httpRequestBase.setHeader("Accept-Charset",
|
// "ISO-8859-1,utf-8,gbk,gb2312;q=0.7,*;q=0.7");
|
|
// 配置请求的超时设置
|
RequestConfig requestConfig = RequestConfig.custom()
|
.setConnectionRequestTimeout(timeOut)
|
.setConnectTimeout(timeOut).setSocketTimeout(timeOut).build();
|
httpRequestBase.setConfig(requestConfig);
|
}
|
|
/**
|
* 获取HttpClient对象
|
*
|
* @return
|
* @author SHANHY
|
* @create 2015年12月18日
|
*/
|
public static CloseableHttpClient getHttpClient(String url) {
|
String hostname = url.split("/")[2];
|
int port = 80;
|
if (hostname.contains(":")) {
|
String[] arr = hostname.split(":");
|
hostname = arr[0];
|
port = Integer.parseInt(arr[1]);
|
}
|
if (httpClient == null) {
|
synchronized (syncLock) {
|
if (httpClient == null) {
|
httpClient = createHttpClient(200, 40, 100, hostname, port);
|
}
|
}
|
}
|
return httpClient;
|
}
|
|
/**
|
* 创建HttpClient对象
|
*
|
* @return
|
* @author SHANHY
|
* @create 2015年12月18日
|
*/
|
public static CloseableHttpClient createHttpClient(int maxTotal,
|
int maxPerRoute, int maxRoute, String hostname, int port) {
|
ConnectionSocketFactory plainsf = PlainConnectionSocketFactory
|
.getSocketFactory();
|
LayeredConnectionSocketFactory sslsf = SSLConnectionSocketFactory
|
.getSocketFactory();
|
Registry<ConnectionSocketFactory> registry = RegistryBuilder
|
.<ConnectionSocketFactory> create().register("http", plainsf)
|
.register("https", sslsf).build();
|
PoolingHttpClientConnectionManager cm = new PoolingHttpClientConnectionManager(
|
registry);
|
// 将最大连接数添加
|
cm.setMaxTotal(maxTotal);
|
// 将每一个路由基础的连接添加
|
cm.setDefaultMaxPerRoute(maxPerRoute);
|
HttpHost httpHost = new HttpHost(hostname, port);
|
// 将目标主机的最大连接数添加
|
cm.setMaxPerRoute(new HttpRoute(httpHost), maxRoute);
|
|
// 请求重试处理
|
HttpRequestRetryHandler httpRequestRetryHandler = new HttpRequestRetryHandler() {
|
public boolean retryRequest(IOException exception,
|
int executionCount, HttpContext context) {
|
if (executionCount >= 2) {// 假设已经重试了2次，就放弃
|
return false;
|
}
|
if (exception instanceof NoHttpResponseException) {// 假设server丢掉了连接。那么就重试
|
return true;
|
}
|
if (exception instanceof SSLHandshakeException) {// 不要重试SSL握手异常
|
return false;
|
}
|
if (exception instanceof InterruptedIOException) {// 超时
|
return false;
|
}
|
if (exception instanceof UnknownHostException) {// 目标server不可达
|
return false;
|
}
|
if (exception instanceof ConnectTimeoutException) {// 连接被拒绝
|
return false;
|
}
|
if (exception instanceof SSLException) {// SSL握手异常
|
return false;
|
}
|
|
HttpClientContext clientContext = HttpClientContext
|
.adapt(context);
|
HttpRequest request = clientContext.getRequest();
|
// 假设请求是幂等的，就再次尝试
|
if (!(request instanceof HttpEntityEnclosingRequest)) {
|
return true;
|
}
|
return false;
|
}
|
};
|
|
CloseableHttpClient httpClient = HttpClients.custom()
|
.setConnectionManager(cm)
|
.setRetryHandler(httpRequestRetryHandler).build();
|
|
return httpClient;
|
}
|
|
private static void setPostParams(HttpPost httpost,
|
Map<String, Object> params) {
|
List<NameValuePair> nvps = new ArrayList<NameValuePair>();
|
Set<String> keySet = params.keySet();
|
for (String key : keySet) {
|
nvps.add(new BasicNameValuePair(key, params.get(key).toString()));
|
}
|
try {
|
httpost.setEntity(new UrlEncodedFormEntity(nvps, "UTF-8"));
|
} catch (UnsupportedEncodingException e) {
|
e.printStackTrace();
|
}
|
}
|
|
/**
|
* GET请求URL获取内容
|
*
|
* @param url
|
* @return
|
* @author SHANHY
|
* @throws IOException
|
* @create 2015年12月18日
|
*/
|
public static String post(String url, Map<String, Object> params) throws IOException {
|
HttpPost httppost = new HttpPost(url);
|
config(httppost);
|
setPostParams(httppost, params);
|
CloseableHttpResponse response = null;
|
try {
|
response = getHttpClient(url).execute(httppost,
|
HttpClientContext.create());
|
HttpEntity entity = response.getEntity();
|
String result = EntityUtils.toString(entity, "utf-8");
|
EntityUtils.consume(entity);
|
return result;
|
} catch (Exception e) {
|
// e.printStackTrace();
|
throw e;
|
} finally {
|
try {
|
if (response != null)
|
response.close();
|
} catch (IOException e) {
|
e.printStackTrace();
|
}
|
}
|
}
|
|
/**
|
* GET请求URL获取内容
|
*
|
* @param url
|
* @return
|
* @author SHANHY
|
* @create 2015年12月18日
|
*/
|
public static String get(String url) {
|
HttpGet httpget = new HttpGet(url);
|
config(httpget);
|
CloseableHttpResponse response = null;
|
try {
|
response = getHttpClient(url).execute(httpget,
|
HttpClientContext.create());
|
HttpEntity entity = response.getEntity();
|
String result = EntityUtils.toString(entity, "utf-8");
|
EntityUtils.consume(entity);
|
return result;
|
} catch (IOException e) {
|
e.printStackTrace();
|
} finally {
|
try {
|
if (response != null)
|
response.close();
|
} catch (IOException e) {
|
e.printStackTrace();
|
}
|
}
|
return null;
|
}
|
|
public static void main(String[] args) throws Exception {
|
String proxyUrl="http://192.168.20.106:8066/serverRegister/addArcGisServer";
|
String resourceIdStr="zyid="+12;
|
String serverUrlStr="serverUrl="+"http://gis.nmsmp.com/arcgis/rest/services/HYSW/haiyangshengwu/MapServer/4";
|
String isPublicStr= "isPublic="+1;
|
String fromsys= "fromsys=HYJGPT";
|
String enable="enable=1";
|
String s = HttpUtils.get(proxyUrl+"?"+
|
resourceIdStr+"&"+
|
serverUrlStr+"&"+
|
isPublicStr+"&"+
|
fromsys+"&"+
|
enable
|
);
|
HashMap<String,Object> result= Json.decode(s,HashMap.class);
|
proxyUrl=(String)result.get("proxyurl");
|
|
}
|
}
|
