package com.superb.httpclient;

import java.io.BufferedReader;
import java.io.ByteArrayOutputStream;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.security.cert.CertificateException;
import java.security.cert.X509Certificate;
import java.util.ArrayList;
import java.util.List;
import java.util.Map;

import javax.net.ssl.SSLContext;
import javax.net.ssl.TrustManager;
import javax.net.ssl.X509TrustManager;

import org.apache.http.HttpEntity;
import org.apache.http.HttpResponse;
import org.apache.http.HttpVersion;
import org.apache.http.NameValuePair;
import org.apache.http.client.HttpClient;
import org.apache.http.client.entity.UrlEncodedFormEntity;
import org.apache.http.client.methods.HttpGet;
import org.apache.http.client.methods.HttpPost;
import org.apache.http.conn.scheme.PlainSocketFactory;
import org.apache.http.conn.scheme.Scheme;
import org.apache.http.conn.scheme.SchemeRegistry;
import org.apache.http.conn.ssl.SSLSocketFactory;
import org.apache.http.impl.client.DefaultHttpClient;
import org.apache.http.impl.conn.tsccm.ThreadSafeClientConnManager;
import org.apache.http.message.BasicNameValuePair;
import org.apache.http.params.BasicHttpParams;
import org.apache.http.params.CoreConnectionPNames;
import org.apache.http.params.CoreProtocolPNames;
import org.apache.http.params.HttpParams;
import org.apache.log4j.Logger;

public class HttpUtil {
	private final static Logger logger = Logger.getLogger(HttpUtil.class);

	private static ThreadSafeClientConnManager cm = null;
	static {
		try {
			SSLContext ctx = SSLContext.getInstance("TLS");
			X509TrustManager tm = new X509TrustManager() {
				public void checkClientTrusted(X509Certificate[] chain, String authType) throws CertificateException {

				}
                          
				public void checkServerTrusted(X509Certificate[] chain, String authType) throws CertificateException {

				}

				public X509Certificate[] getAcceptedIssuers() {
					return null;
				}
			};
			ctx.init(null, new TrustManager[] { tm }, null);
			SSLSocketFactory ssf = new SSLSocketFactory(ctx, SSLSocketFactory.ALLOW_ALL_HOSTNAME_VERIFIER);
			SchemeRegistry schemeRegistry = new SchemeRegistry();
			schemeRegistry.register(new Scheme("http", 80, PlainSocketFactory.getSocketFactory()));
			schemeRegistry.register(new Scheme("https", 443, ssf));
			cm = new ThreadSafeClientConnManager(schemeRegistry);
			cm.setMaxTotal(400);
			cm.setDefaultMaxPerRoute(40);
		} catch (Exception e) {
			e.printStackTrace();
		}
	}

	/**
	 * @description 獲取 HTTP Client
	 * @return
	 */
	private static HttpClient getHttpClient() {
		HttpParams params = new BasicHttpParams();
		params.setParameter(CoreProtocolPNames.PROTOCOL_VERSION, HttpVersion.HTTP_1_1);
		params.setParameter(CoreConnectionPNames.CONNECTION_TIMEOUT, 5000);
		return new DefaultHttpClient(cm, params);
	}

	/**
	 * @description HTTP POST
	 * @param url
	 * @param msg
	 * @return
	 */
	public static String post(String url, Map params) {
		logger.info("URLInvoke.post#request message : ");

		List list = new ArrayList();
		if (params != null && !params.isEmpty()) {
			for (Map.Entry entry : params.entrySet()) {
				list.add(new BasicNameValuePair(entry.getKey(), entry.getValue()));
			}
		}
		try {
			// 實現將請求的引數封裝到表單中，即請求體中
			UrlEncodedFormEntity entity = new UrlEncodedFormEntity(list, "UTF-8");
			// 使用post方式提交資料
			HttpPost httpPost = new HttpPost(url);
			httpPost.setEntity(entity);
			// 執行post請求，並獲取伺服器端的響應HttpResponse
			HttpClient client = getHttpClient();
			HttpResponse httpResponse = client.execute(httpPost);

			// 獲取伺服器端返回的狀態碼和輸入流，將輸入流轉換成字串
			if (httpResponse.getStatusLine().getStatusCode() == 200) {
				InputStream inputStream = httpResponse.getEntity().getContent();
				return changeInputStream(inputStream, "UTF-8");
			}
		} catch (Exception e) {
			e.printStackTrace();
		}
		return "";
	}

	/*
	 * // 把從輸入流InputStream按指定編碼格式encode變成字串String
	 */
	public static String changeInputStream(InputStream inputStream, String encode) {
		// ByteArrayOutputStream 一般叫做記憶體流
		ByteArrayOutputStream byteArrayOutputStream = new ByteArrayOutputStream();
		byte[] data = new byte[1024];
		int len = 0;
		String result = "";
		if (inputStream != null) {
			try {
				while ((len = inputStream.read(data)) != -1) {
					byteArrayOutputStream.write(data, 0, len);
				}
				result = new String(byteArrayOutputStream.toByteArray(), encode);
			} catch (IOException e) {
				e.printStackTrace();
			}
		}
		logger.info("URLInvoke.post#response message : " + result);
		return result;
	}

	/**
	 * HTTP GET
	 * 
	 * @param url
	 * @return
	 */
	public static String get(String url) {
		logger.info("URLInvoke.get#response url : " + url);
		HttpResponse httpResponse = null;
		InputStream inputStream = null;
		String result = "";
		// 生成一個請求物件
		HttpGet httpGet = new HttpGet(url);
		// 生成一個http客戶端
		HttpClient httpClient = new DefaultHttpClient();
		// 使用Http客戶端傳送請求物件
		// httpResponse是伺服器返回給我們的響應httpentity是響應的內容
		try {
			httpResponse = httpClient.execute(httpGet);
			HttpEntity httpEntity = httpResponse.getEntity();
			inputStream = httpEntity.getContent();
			BufferedReader br = new BufferedReader(new InputStreamReader(inputStream));

			String line = "";
			while ((line = br.readLine()) != null) {
				result += "\n" + line;
			}
		} catch (Exception e) {
			e.printStackTrace();
		} finally {
			try {
				if (inputStream != null) {
					inputStream.close();
				}
			} catch (IOException e) {
				e.printStackTrace();
			}
		}
		logger.info("URLInvoke.get#response result : " + result);
		return result;
	}
}
4.0.0com.superbmaven-120160720jarmaven-1http://maven.apache.orgUTF-8junitjunit3.8.1testcommons-loggingcommons-logging1.1.1commons-codeccommons-codec1.4commons-httpclientcommons-httpclient3.0.1org.slf4jslf4j-log4j121.7.2org.apache.httpcomponentshttpclient4.3.5