描述： http通讯基础类

Posted 2021-01-23 wangchuanfu

package com.founder.ec.web.util.payments.payeco.http;


import com.founder.ec.web.util.payments.payeco.http.ssl.SslConnection;

import java.io.BufferedReader;
import java.io.DataOutputStream;
import java.io.InputStreamReader;
import java.net.HttpURLConnection;
import java.net.URL;
import java.util.Iterator;
import java.util.SortedMap;

/**
 * 描述： http通讯基础类
 * 
 */
public class HttpClient {
    
    private int status;

    public int getStatus() {
        return status;
    }

    public void setStatus(int status) {
        this.status = status;
    }
    
    
    public static String REQUEST_METHOD_GET = "GET";
    public static String REQUEST_METHOD_POST = "POST";
    
    public  String send(String postURL, String requestBody,
            String sendCharset, String readCharset) {
        return send(postURL,requestBody,sendCharset,readCharset,300,300);
    }
    
    
    public  String send(String postURL, String requestBody,
            String sendCharset, String readCharset,String RequestMethod) {
        return send(postURL,requestBody,sendCharset,readCharset,300,300,RequestMethod);
    }
    
    /**
     * @param postURL  访问地址
     * @param requestBody  paramName1=paramValue1&paramName2=paramValue2
     * @param sendCharset  发送字符编码
     * @param readCharset  返回字符编码
     * @param connectTimeout  连接主机的超时时间 单位:秒
     * @param readTimeout 从主机读取数据的超时时间 单位:秒
     * @return 通讯返回
     */
    public  String send(String url, String requestBody,
            String sendCharset, String readCharset,int connectTimeout,int readTimeout) {
        try {
            return connection(url,requestBody,sendCharset,readCharset,connectTimeout,readTimeout,REQUEST_METHOD_POST);
        } catch (Exception ex) {
            ex.printStackTrace();
            System.out.print("发送请求[" + url + "]失败，" + ex.getMessage());
            return null;
        } 
    }
    
    /**
     * @param postURL  访问地址
     * @param requestBody  paramName1=paramValue1&paramName2=paramValue2
     * @param sendCharset  发送字符编码
     * @param readCharset  返回字符编码
     * @param connectTimeout  连接主机的超时时间 单位:秒
     * @param readTimeout 从主机读取数据的超时时间 单位:秒
     * @param RequestMethod GET或POST
     * @return 通讯返回
     */
    public  String send(String url, String requestBody,
            String sendCharset, String readCharset,int connectTimeout,int readTimeout,String RequestMethod) {
        try {
            return connection(url,requestBody,sendCharset,readCharset,connectTimeout,readTimeout,RequestMethod);
        } catch (Exception ex) {
            ex.printStackTrace();
            System.out.print("发送请求[" + url + "]失败，" + ex.getMessage());
            return null;
        } 
    }
    
    public  String connection(String postURL, String requestBody,
            String sendCharset, String readCharset,int connectTimeout,int readTimeout,String RequestMethod)throws Exception {
        if(REQUEST_METHOD_POST.equals(RequestMethod)){
            return postConnection(postURL,requestBody,sendCharset,readCharset,connectTimeout,readTimeout,null);
        }else if(REQUEST_METHOD_GET.equals(RequestMethod)){
            return getConnection(postURL,requestBody,sendCharset,readCharset,connectTimeout,readTimeout,null);
        }else{
            return "";
        }
         
    }
    
    @SuppressWarnings("rawtypes")
    public  String getConnection(String url, String requestBody,
            String sendCharset, String readCharset,int connectTimeout,int readTimeout,SortedMap reqHead)throws Exception {
        // Post请求的url，与get不同的是不需要带参数
        HttpURLConnection httpConn = null;
        try {
            
            if (!url.contains("https:")) {
                URL postUrl = new URL(url);
                // 打开连接
                httpConn = (HttpURLConnection) postUrl.openConnection();
            } else {
                SslConnection urlConnect = new SslConnection();
                httpConn = (HttpURLConnection) urlConnect.openConnection(url);
            }
            
            httpConn.setRequestProperty("Content-Type",
                    "application/x-www-form-urlencoded; charset=" + sendCharset);
            
            if(reqHead!=null&&reqHead.size()>0){
                Iterator iterator =reqHead.keySet().iterator();
                while (iterator.hasNext()) {
                    String key = (String) iterator.next();
                    String val = (String)reqHead.get(key);
                    httpConn.setRequestProperty(key,val);
                }
            }
            
            // 设定传送的内容类型是可序列化的java对象 
            // (如果不设此项,在传送序列化对象时,当WEB服务默认的不是这种类型时可能抛java.io.EOFException) httpUrlConnection.setRequestProperty("Content-type", "application/x-java-serialized-object"); 
//            连接主机的超时时间（单位：毫秒）
            httpConn.setConnectTimeout(1000 * connectTimeout);
//            从主机读取数据的超时时间（单位：毫秒） 
            httpConn.setReadTimeout(1000 * readTimeout);
            // 连接，从postUrl.openConnection()至此的配置必须要在 connect之前完成，
            // 要注意的是connection.getOutputStream会隐含的进行 connect。
            httpConn.connect();
        
            int status = httpConn.getResponseCode();
            setStatus(status);
            if (status != HttpURLConnection.HTTP_OK) {
                System.out.print("发送请求失败，状态码：[" + status + "] 返回信息："
                        + httpConn.getResponseMessage());
                return null;
            }
            BufferedReader reader = new BufferedReader(new InputStreamReader(httpConn
                    .getInputStream(), readCharset));
            StringBuffer responseSb = new StringBuffer();
            String line = null;
            while ((line = reader.readLine()) != null) {
                responseSb.append(line.trim());
            }
            reader.close();
            return responseSb.toString().trim();
        } finally {
            httpConn.disconnect();
        }
    }
    
    
    @SuppressWarnings("rawtypes")
    public  String postConnection(String postURL, String requestBody,
            String sendCharset, String readCharset,int connectTimeout,int readTimeout,SortedMap reqHead)throws Exception {
        // Post请求的url，与get不同的是不需要带参数
        HttpURLConnection httpConn = null;
        try {
            
            if (!postURL.contains("https:")) {
                URL postUrl = new URL(postURL);
                // 打开连接
                httpConn = (HttpURLConnection) postUrl.openConnection();
            } else {
                SslConnection urlConnect = new SslConnection();
                httpConn = (HttpURLConnection) urlConnect.openConnection(postURL);
            }
            
//             设置是否向httpUrlConnection输出，因为这个是post请求，参数要放在 
//             http正文内，因此需要设为true, 默认情况下是false; 
            httpConn.setDoOutput(true);
            // 设置是否从httpUrlConnection读入，默认情况下是true; 
            httpConn.setDoInput(true);
            // 设定请求的方法为"POST"，默认是GET 
            httpConn.setRequestMethod("POST");
            // Post 请求不能使用缓存 
            httpConn.setUseCaches(false);
            //进行跳转
            httpConn.setInstanceFollowRedirects(true);
            httpConn.setRequestProperty("Content-Type",
                    "application/x-www-form-urlencoded; charset=" + sendCharset);
            
            if(reqHead!=null&&reqHead.size()>0){
                Iterator iterator =reqHead.keySet().iterator();
                while (iterator.hasNext()) {
                    String key = (String) iterator.next();
                    String val = (String)reqHead.get(key);
                    httpConn.setRequestProperty(key,val);
                }
            }
            
            // 设定传送的内容类型是可序列化的java对象 
            // (如果不设此项,在传送序列化对象时,当WEB服务默认的不是这种类型时可能抛java.io.EOFException) httpUrlConnection.setRequestProperty("Content-type", "application/x-java-serialized-object"); 
//            连接主机的超时时间（单位：毫秒）
            httpConn.setConnectTimeout(1000 * connectTimeout);
//            从主机读取数据的超时时间（单位：毫秒） 
            httpConn.setReadTimeout(1000 * readTimeout);
            // 连接，从postUrl.openConnection()至此的配置必须要在 connect之前完成，
            // 要注意的是connection.getOutputStream会隐含的进行 connect。
            httpConn.connect();
            DataOutputStream out = new DataOutputStream(httpConn.getOutputStream());
            out.write(requestBody.getBytes(sendCharset));
            out.flush();
            out.close();
            int status = httpConn.getResponseCode();
            setStatus(status);
            if (status != HttpURLConnection.HTTP_OK) {
                System.out.print("发送请求失败，状态码：[" + status + "] 返回信息："
                        + httpConn.getResponseMessage());
                return null;
            }
            BufferedReader reader = new BufferedReader(new InputStreamReader(httpConn
                    .getInputStream(), readCharset));
            StringBuffer responseSb = new StringBuffer();
            String line = null;
            while ((line = reader.readLine()) != null) {
                responseSb.append(line.trim());
            }
            reader.close();
            return responseSb.toString().trim();
        } finally {
            httpConn.disconnect();
        }
    }
    
    public static void main(String[] args) {
    
        
    }

}