wwy_wy/websrc/com/kingdee/eas/custom/wamke/syncdata/utils/HttpUtils.java

package com.kingdee.eas.custom.wamke.syncdata.utils;

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.UnsupportedEncodingException;
import java.net.URL;
import java.net.URLConnection;
import java.util.Map;

import org.apache.http.HttpEntity;
import org.apache.http.client.ClientProtocolException;
import org.apache.http.client.methods.CloseableHttpResponse;
import org.apache.http.client.methods.HttpPost;
import org.apache.http.entity.StringEntity;
import org.apache.http.impl.client.CloseableHttpClient;
import org.apache.http.impl.client.HttpClientBuilder;
import org.apache.http.impl.client.HttpClients;
import org.apache.http.message.BasicHeader;
import org.apache.http.protocol.HTTP;
import org.apache.http.util.EntityUtils;
import org.apache.log4j.Logger;

import com.kingdee.bos.BOSException;
import com.kingdee.eas.custom.constants.Constants;
import com.kingdee.eas.custom.utils.ObjectUtils;
import com.kingdee.eas.custom.utils.StringUtils;


public class HttpUtils {

    private static Logger logger =
        Logger.getLogger("com.kingdee.eas.custom.wamke.utils.HttpUtils");
	
    private static final int MAX_CONNECT_TIMEOUT = 10000;
    private static final int MAX_SOCKET_TIMEOUT = 60000;
    
    public static String sendGet(String url, String param){
    	return sendGet(url,param, "UTF_8");
    }
    
	 /**
	 * 向指定 URL 发送GET方法的请求
	 *
	 * @param url         发送请求的 URL
	 * @param param       请求参数，请求参数应该是 name1=value1&name2=value2 的形式。
	 * @param contentType 编码类型
	 * @return 所代表远程资源的响应结果
     * @throws BOSException 
	 */
	public static String sendGet(String url, String param, String contentType) {
		StringBuilder result = new StringBuilder();
		BufferedReader in = null;
		try {
			String urlNameString = (param!=null&&param!="") ? url + "?" + param : url;
			URL realUrl = new URL(urlNameString);
			System.out.println("请求URL:"+realUrl);
			URLConnection connection = realUrl.openConnection();
			connection.setRequestProperty("accept", "*/*");
			connection.setRequestProperty("connection", "Keep-Alive");
			connection.setRequestProperty("user-agent", "Mozilla/4.0 (compatible; MSIE 6.0; Windows NT 5.1;SV1)");
			connection.connect();
			in = new BufferedReader(new InputStreamReader(connection.getInputStream(), contentType));
			String line;
			while ((line = in.readLine()) != null) {
				result.append(line);
			}
		} catch (Exception e) {
			logger.error(e.getMessage());
			e.printStackTrace();
		} finally {
			try {
				if (in != null) {
					in.close();
				}
			} catch (Exception ex) {
				logger.error(ex.getMessage());				
			}
		}
		return result.toString();
	}
	
	/**
	 * @param url
	 * @param paramMap
	 * @param contentType
	 * @return
	 */
	public static String sendGet(String url, Map<String, String> paramMap, String contentType) {
		StringBuilder sb = new StringBuilder();
		if (null != paramMap && !paramMap.isEmpty()) {
			for (Map.Entry<String,String> entry : paramMap.entrySet()) {
				if (sb.length() > 0) {
					sb.append("&");
				}
				sb.append(entry.getKey()).append("=").append(entry.getValue());
			}
		}
		if (StringUtils.isBlank(contentType)) {
			contentType = Constants.UTF8;
		}
		return sendGet(url, sb.toString(), contentType);
	}
	
	
	
	/**
	 * 发送post请求
	 * @param uri
	 * @param paramStr
	 * @return
	 */
	public static String sendPost(String uri, String paramStr){
		 return sendPost(uri,paramStr,null);
	}
	
	/**
	 * 发送post请求
	 * @param uri 请求地址
	 * @param paramStr 请求的JSON数据
	 * @param token 头部token
	 * @return
	 */
	public static String sendPost(String uri, String paramStr, String token) {
		// 创建默认的httpClient实例.
		CloseableHttpClient httpclient = HttpClients.createDefault();
		// 创建httpPost
		HttpPost httppost = new HttpPost(uri);
		// 创建参数队列
		StringEntity uefEntity = null;
		String result = null;
		try {
			String reqJson = paramStr; // JSON.toJSONString(paramsMap);
			uefEntity = new StringEntity(reqJson,  "UTF-8");
			uefEntity.setContentType("text/json");
			uefEntity.setContentEncoding(new BasicHeader(HTTP.CONTENT_TYPE, "application/json"));
			httppost.setEntity(uefEntity);
			httppost.setHeader("Content-Type", "application/json");
			if (ObjectUtils.isNotEmpty(token)) {
				httppost.setHeader("Authorization", token);
			}
			CloseableHttpResponse response = httpclient.execute(httppost);
			if (response.getStatusLine().getStatusCode() != 200) {
				String msg = "http请求处理异常.";
				msg += response.toString();
				
			}
			try {
				HttpEntity entity = response.getEntity();
				if (entity != null) {
					result = EntityUtils.toString(entity, "UTF-8");
				}
			} finally {
				response.close();
			}
		} catch (ClientProtocolException e) {
			logger.error(e.getMessage(), e);
		} catch (UnsupportedEncodingException e1) {
			logger.error(e1.getMessage(), e1);
		} catch (IOException e) {
			logger.error(e.getMessage(), e);
		} finally {
			// 关闭连接,释放资源
			try {
				httpclient.close();
			} catch (IOException e) {
				logger.error(e.getMessage(), e);
			}
		}
		return result;
	}
	
	
	/**
     * XML/JSON入参的HTTP交互
     * @param url
     * @param contentType
     * @param headers
     * @param content   XML/JSON数据
     * @param httpConnectTimeout
     * @param httpSocketTimeout
     * @param httpSocketTimeout
     * @return outLogs  输出全量日志
     * @Author KangLG<2 0 2 2 年8月11日>
     */
    public static String postRemote(String url, String contentType, Map<String, String> headers, String content, int httpConnectTimeout, int httpSocketTimeout, boolean outLogs) {
        String result = null;
        try {
            HttpPost post = new HttpPost(url.trim());
            post.setEntity(new StringEntity(content, "UTF-8"));
            post.setHeader("Content-Type", null != contentType ? contentType : "application/json");
            if (null != headers && !headers.isEmpty()) {
                for (Map.Entry<String, String> item : headers.entrySet()) {
                    post.setHeader(item.getKey(), item.getValue());
                }
            }

            //设置请求和传输超时时间  
//            RequestConfig requestConfig = RequestConfig.custom()
//                    .setConnectTimeout(httpConnectTimeout > 0 ? httpConnectTimeout : MAX_CONNECT_TIMEOUT)
//                    .setSocketTimeout(httpSocketTimeout > 0 ? httpSocketTimeout : MAX_SOCKET_TIMEOUT)
//                    .build();
//            post. (requestConfig);
            
            CloseableHttpClient httpclient = HttpClientBuilder.create().build();
            CloseableHttpResponse response = httpclient.execute(post);
            HttpEntity responseEntity = response.getEntity();
            System.out.println(String.format("[%s]响应信息: ContentType=%s, 状态=%s", url, null != responseEntity ? responseEntity.getContentType() : "null", response.getStatusLine()));
            if (null == responseEntity) {
                return null;
            }
            result = EntityUtils.toString(responseEntity);
            if(outLogs){
                logger.info(String.format("[%s]响应内容: %s", url, result));
                System.out.println(String.format("[%s]响应内容: %s", url, result));
            }
            return result;
        } catch (Exception e) {
        	e.printStackTrace();
            logger.error("推送异常/" + e.toString() + ": " + content);
            return null;
        }
    }
}