EmploymentSite/src/main/java/com/hz/employmentsite/webservices/ztndata_gdgov/ProxyHandler.java

package com.hz.employmentsite.webservices.ztndata_gdgov;

import com.hz.employmentsite.AppConfig;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Configurable;
import org.springframework.stereotype.Component;

import javax.servlet.ServletConfig;
import javax.servlet.ServletException;
import javax.servlet.http.HttpServlet;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import java.io.*;
import java.net.HttpURLConnection;
import java.net.URL;
import java.net.URLDecoder;
import java.net.URLEncoder;
import java.util.Arrays;
import java.util.HashMap;
import java.util.Map;

@Component
public class ProxyHandler extends HttpServlet implements Serializable {
    private static final long serialVersionUID = 3561079438115778584L;
    private final static Logger logger = LoggerFactory.getLogger(ProxyHandler.class);
    private static final String CHARSET_UTF8 = "UTF-8"; // 默认字符集常量 : UTF-8
    public static final String CONTENT_URL_NAME = "url";

    @Autowired
    private AppConfig appConfig;

    public ProxyHandler() {
    }

    /**
     * SERVELT 初始化
     */
    @Override
    public void init(ServletConfig config) throws ServletException {
        super.init();
    }

    /**
     * doGet 请求
     */
    public void doGet(HttpServletRequest req, HttpServletResponse resp)
            throws ServletException, IOException {
        noSecurityRequest(req, resp);
    }

    private void noSecurityRequest(HttpServletRequest req,
                                   HttpServletResponse resp) throws IOException {
        logger.info("ProxyHandler noSecurityRequest 请求类型: GET");
        String url0 = "";
        OutputStream out = null;
        HttpURLConnection conn = null;
        // 获取请求的类型与字符集
        String requestContent = req.getContentType();

        String requestCharset = req.getCharacterEncoding();
        StringBuffer requestContentType = new StringBuffer();
        if (null != requestContent) {
            requestContentType.append(requestContent);
            if (null != requestCharset) {
                requestContentType.append(";charset=").append(requestCharset);
            }
        }
        try {
            // 获取请求参数的字符串
            String params = req.getQueryString();
            params = params.replace("+", "%2B");
            Map<String, String> paramValues = GetParamters(params);
            url0 = URLDecoder.decode(paramValues.get("url"),"UTF-8");

            // 请求转发
            URL url = new URL(url0);

            conn = (HttpURLConnection) url.openConnection();
            conn.setRequestMethod("GET");
            if (!requestContentType
                    .toString().equals("")) {
                conn.setRequestProperty("Content-Type", requestContentType
                        .toString());
            }
            //添加请求头，paasId 与 paasToken 可从前端传递或者读取后端配置文件
            String paasId = appConfig.gdgov_paasId, paasToken = appConfig.gdgov_passToken;
            if (paramValues.containsKey("paasId")) {
                paasId = paramValues.get("paasId");
                paasToken = paramValues.get("paasToken");
            }
            HashMap<String, String> map = Signature.computeSignatureHeaders(paasId, paasToken);
            if (paramValues.containsKey("serviceCode")) {

                map.put("x-tif-signature", map.get("x-tif-signature").toUpperCase());
                map.put("x-tif-serviceId", paramValues.get("serviceCode"));
            }
            for (String key : map.keySet()) {
                conn.setRequestProperty(key, map.get(key));
            }
            logger.info("计算网关签名为:\n" + map);
            conn.setDoOutput(true);
            conn.setDoInput(true);
            conn.setUseCaches(false);
            // 获取请求的类型与字符集设置
            String contentType = conn.getContentType();
            String encoding = conn.getContentEncoding();
            out = resp.getOutputStream();
            // 设置返回的类型与字符集
            resp.setContentType(contentType);
            resp.setHeader("Content-Encoding", encoding);//正文解压缩方式
            InputStream in = null;
            if (conn.getResponseCode() == HttpURLConnection.HTTP_OK) {
                in = conn.getInputStream();
            } else {
                in = conn.getErrorStream();
            }
            out = resp.getOutputStream();
            int len = 0;
            byte[] b = new byte[1024];
            while ((len = in.read(b)) > 0) {
                out.write(b, 0, len);
            }
            out.flush();
            logger.info("\n 请求地址: " + url0 + "\n 请求成功!");
        } catch (Exception e) {
            logger.error("请求地址: " + url0 + "\n 请求失败: " + e);
        } finally {
            try {
                if (out != null) {
                    out.close();
                }
                if (conn != null) {
                    conn.disconnect();
                }
            } catch (Exception e) {
                logger.error(e.toString());
            }

        }
    }

    private Map<String, String> GetParamters(String queryString) {
        Map<String, String> pramValues = new HashMap<String, String>();
        String[] paramNames = queryString.split("&");

        for (int i = 0; i < paramNames.length; i++) {
            String[] paramName = paramNames[i].split("=");

            pramValues.put(paramName[0], paramName.length > 0 ? paramName[1] : "");
        }

        return pramValues;
    }

    public Map<String, Object> toMap(String url) {
        Map<String, Object> map = null;
        if ((url != null) && (url.indexOf("&") > -1) && (url.indexOf("=") > -1)) {
            map = new HashMap<String, Object>();
            String[] arrTemp = url.split("&");

            for (String str : arrTemp) {
                String[] qs = str.split("=", 2);
                if (qs[0].indexOf("http://") == -1) {
                    if (qs.length == 2)
                        map.put(qs[0], qs[1]);
                } else {
                    String[] temp = qs[0].split("\\?");
                    map.put(temp[(temp.length - 1)], qs[1]);
                }
            }
        }
        return map;
    }

    /**
     * doPost 请求
     */
    public void doPost(HttpServletRequest request, HttpServletResponse response)
            throws ServletException, IOException {
        logger.info("请求类型: POST");
        InputStream indoc = request.getInputStream();
        // 获取请求参数
        String url0 = request.getQueryString();

        // 对请求参数进行解码操作
        if (null != url0)
            url0 = URLDecoder.decode(url0, CHARSET_UTF8);
        // 获取请求类型与字符集
        String requestContent = request.getContentType();
        String requestCharset = request.getCharacterEncoding();
        StringBuffer requestContentType = new StringBuffer();
        if (null != requestContent) {
            requestContentType.append(requestContent);
            if (null != requestCharset) {
                requestContentType.append(";charset=").append(requestCharset);
            }
        }
        OutputStream out = response.getOutputStream();
        try {
            Map<String, String> paramValues = GetParamters(url0);
            int urlIndex = url0.indexOf("url=");
            if (urlIndex > 0) {
                url0 = url0.substring(urlIndex);
            }
            if (url0.startsWith("url=")) {
                String urlString = url0.substring(4);
                URL url = new URL(urlString);
                BufferedInputStream in = null;
                HttpURLConnection connection = null;
                byte[] bs = null;
                if (url != null) {
                    try {
                        // 转发请求
                        connection = (HttpURLConnection) url.openConnection();
                        connection.setRequestMethod("POST");
                        connection.setRequestProperty("Content-Type",
                                requestContentType.toString());
                        connection.setDoInput(true);
                        connection.setDoOutput(true);
                        //添加请求头，paasId 与 paasToken 可从前端传递或者读取后端配置文件
                        String paasId = "", paasToken = "";
                        if (paramValues.containsKey("paasId")) {
                            paasId = paramValues.get("paasId");
                            paasToken = paramValues.get("paasToken");
                        } else {
                            /*paasId = gatewayConfig.getPaasId();
                            paasToken = gatewayConfig.getPaasToken();*/
                            paasId = appConfig.gdgov_paasId;
                            paasToken = appConfig.gdgov_passToken;
                        }

                        HashMap<String, String> map = Signature.computeSignatureHeaders(paasId, paasToken);
                        if (paramValues.containsKey("serviceCode")) {
                            map.put("x-tif-signature", map.get("x-tif-signature").toUpperCase());
                            map.put("x-tif-serviceId", paramValues.get("serviceCode"));
                        }
                        for (String key : map.keySet()) {
                            connection.setRequestProperty(key, map.get(key));
                        }
                        OutputStream toserver = connection.getOutputStream();
                        int l = 0;
                        while ((l = indoc.read()) != -1) {
                            toserver.write(l);
                        }
                        toserver.flush();
                        toserver.close();
                        // 获取转发返回的类型与字符集
                        String responseContentType = connection
                                .getContentType();
                        String responseCharset = connection
                                .getContentEncoding();
                        // 将转发返回的类型与字符集设置到返回的参数中
                        response.setContentType(responseContentType);

                        response.setCharacterEncoding(responseCharset);
                        // 读取响应信息，并将响应发送到客户端
                        in = new BufferedInputStream(connection
                                .getInputStream());
                        bs = new byte[1024];
                        int startpos = 0;
                        int num = 0;
                        num = in.read(bs, startpos, 1024);
                        logger.info("返回信息:");
                        while (num != -1) {
                            out.write(bs, 0, num);
                            logger.info(new String(bs));
                            num = in.read(bs, 0, 1024);
                        }
                        logger.info("\n 请求地址: " + url0 + "\n 请求成功!");
                    } catch (IOException e) {
                        logger.error("请求地址: " + url0 + "\n 请求失败!" + e);
                    } finally {
                        if (in != null) {
                            try {
                                in.close();
                            } catch (Exception ex) {
                            }
                        }
                        if (connection != null) {
                            try {
                                connection.disconnect();
                            } catch (Exception ex) {
                            }
                        }
                    }
                }
            }
        } catch (Exception e) {
            logger.error(e.toString());
        } finally {
            if (out != null) {
                out.flush();
                out.close();
            }
        }
    }
}