package com.bx.util;

import java.io.IOException;
import java.io.UnsupportedEncodingException;
import java.util.ArrayList;
import java.util.List;
import java.util.Map;
import java.util.Map.Entry;

import org.apache.commons.io.IOUtils;
import org.apache.http.HttpEntity;
import org.apache.http.NameValuePair;
import org.apache.http.client.ClientProtocolException;
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.HttpDelete;
import org.apache.http.client.methods.HttpGet;
import org.apache.http.client.methods.HttpPost;
import org.apache.http.client.methods.HttpPut;
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;
/**
 * 基於HttpClient第三方工具的http工具類
 * @author Administrator
 *
 */
public class HttpClientUtil {
	
	public static final String BASEURL = "http://127.0.0.1:8080/xxPlatform/";
	//統一配置
	private static PoolingHttpClientConnectionManager connMgr;
	private static RequestConfig requestConfig;
	private static final int MAX_TIMEOUT = 7000;
	static {
		// 設定連線池
		connMgr = new PoolingHttpClientConnectionManager();
		// 設定連線池大小
		connMgr.setMaxTotal(100);
		connMgr.setDefaultMaxPerRoute(connMgr.getMaxTotal());

		RequestConfig.Builder configBuilder = RequestConfig.custom();
		// 設定連線超時
		configBuilder.setConnectTimeout(MAX_TIMEOUT);
		// 設定讀取超時
		configBuilder.setSocketTimeout(MAX_TIMEOUT);
		// 設定從連線池獲取連線例項的超時
		configBuilder.setConnectionRequestTimeout(MAX_TIMEOUT);
		// 在提交請求之前 測試連線是否可用
		configBuilder.setStaleConnectionCheckEnabled(true);
		requestConfig = configBuilder.build();
	}
	/**
	 * 傳送get請求不帶引數
	 * @param url
	 * @return
	 */
	public static String sendGet(String url){
		
		return sendGet(BASEURL+url, null);
	}
	/**
	 * 傳送get請求
	 * @param url
	 * @param map
	 * @return
	 */
	public static String sendGet(String url,Map<String, String> map){
		
		String resulrStr = null;
		StringBuffer parms = null;
		url = BASEURL + url;
		//建立HttpClient物件
		CloseableHttpClient httpClient = HttpClients.createDefault();
		//設定請求引數
		if(null != map && !map.isEmpty()){
			//遍歷map
			parms = new StringBuffer();
			for(Entry<String , String> entry:map.entrySet()){
				parms.append("&"+entry.getKey()+"="+entry.getValue());
			}
			url = url + parms.toString();
 		}
		//建立GET請求方法的例項，並填充url
		HttpGet httpGet = new HttpGet(url);
		httpGet.setConfig(requestConfig);
		try {
			//傳送（執行）請求
			CloseableHttpResponse response = httpClient.execute(httpGet);
			//獲取響應頭、內容
			int statusCode =  response.getStatusLine().getStatusCode();
			//列印狀態碼
			System.out.println("執行狀態碼："+statusCode);
			HttpEntity entity = response.getEntity();
			resulrStr = IOUtils.toString(entity.getContent(),"UTF-8");
			response.close();
		} catch (ClientProtocolException e) {
			e.printStackTrace();
		} catch (IOException e) {
			e.printStackTrace();
		}finally {
			//關閉連線釋放資源
			try {
				httpClient.close();
			} catch (IOException e) {
				e.printStackTrace();
			}
		}
		return resulrStr;
	}
	
	/**
	 * 傳送post請求
	 * @param url
	 * @param map
	 * @return
	 */
	public static String sendPost(String url,Map<String, String> map){
		
		String resultStr = null;
		url = BASEURL + url;
		//建立HttpClient物件
		CloseableHttpClient httpClient = HttpClients.createDefault();
		//建立請求方法例項，填充url
		HttpPost httpPost = new HttpPost(url);
		httpPost.setConfig(requestConfig);
		//設定請求引數（構造引數佇列）
		List<NameValuePair> parmsForm = new ArrayList<NameValuePair>();
		for(Entry<String, String> entry : map.entrySet()){
			parmsForm.add(new BasicNameValuePair(entry.getKey(), entry.getValue()));
		}
		UrlEncodedFormEntity entity; 
		try {
			entity = new UrlEncodedFormEntity(parmsForm,"UTF-8");
			//為方法例項設定引數佇列實體
			httpPost.setEntity(entity);
			//傳送（執行）
			CloseableHttpResponse response = httpClient.execute(httpPost);
			//獲取狀態碼
			int statusCode = response.getStatusLine().getStatusCode();
			System.out.println("執行狀態碼："+statusCode);
			//獲取響應內容
			HttpEntity httpEntity = response.getEntity();
			resultStr = IOUtils.toString(httpEntity.getContent(), "UTF-8");
			response.close();
		} catch (UnsupportedEncodingException e) {
			e.printStackTrace();
		} catch (ClientProtocolException e) {
			e.printStackTrace();
		} catch (IOException e) {
			e.printStackTrace();
		}finally {
			try {
				httpClient.close();
			} catch (IOException e) {
				e.printStackTrace();
			}
		}
		return resultStr;
	}
	
	/**
	 * 傳送put請求
	 * @param url
	 * @param map
	 * @return
	 */
	public static String sendPut(String url,Map<String, String> map){
		
		String resultStr = null;
		url = url + BASEURL;
		//新建httpClient物件
		CloseableHttpClient httpClient = HttpClients.createDefault();
		//建立請求方法例項並填充url
		HttpPut httpPut = new HttpPut(url);
		httpPut.setConfig(requestConfig);
		//建立引數佇列
		List<NameValuePair> parmsForm = new ArrayList<NameValuePair>();
		for(Entry<String, String> entry : map.entrySet()){
			parmsForm.add(new BasicNameValuePair(entry.getKey(), entry.getValue()));
		}
		UrlEncodedFormEntity entity;
		try {
			entity = new UrlEncodedFormEntity(parmsForm);
			//將引數加入方法例項
			httpPut.setEntity(entity);
			//傳送
			CloseableHttpResponse response = httpClient.execute(httpPut);
			//獲取狀態碼
			int statusCode =  response.getStatusLine().getStatusCode();
			System.out.println(statusCode);
			//獲取響應內容
			HttpEntity httpEntity = response.getEntity();
			resultStr = IOUtils.toString(httpEntity.getContent(), "UTF-8");
			//關閉響應
			response.close();
		} catch (UnsupportedEncodingException e) {
			e.printStackTrace();
		} catch (ClientProtocolException e) {
			e.printStackTrace();
		} catch (IOException e) {
			e.printStackTrace();
		}finally {
			try {
				httpClient.close();
			} catch (IOException e) {
				e.printStackTrace();
			}
		}
		return resultStr;
	}
	
	/**
	 * 傳送delete請求
	 * @param url
	 * @return
	 */
	public static String sendDelete(String url){
		
		String resultStr = null;
		url = url + BASEURL;
		//建立httpClient物件
		CloseableHttpClient httpClient = HttpClients.createDefault();
		//建立方法例項
		HttpDelete httpDelete = new HttpDelete(url);
		httpDelete.setConfig(requestConfig);
		//執行
		try {
			CloseableHttpResponse response = httpClient.execute(httpDelete);
			//獲取響應狀態碼
			int statusCode = response.getStatusLine().getStatusCode();
			System.out.println(statusCode);
			//獲取響應內容
			HttpEntity entity = response.getEntity();
			resultStr = IOUtils.toString(entity.getContent(), "UTF-8");
			response.close();
		} catch (ClientProtocolException e) {
			e.printStackTrace();
		} catch (IOException e) {
			e.printStackTrace();
		}finally {
			try {
				httpClient.close();
			} catch (IOException e) {
				e.printStackTrace();
			}
		}
		return resultStr;
	}
	
}