java 使用URLConnection 进行HTTP接口调用

绝地灬酷狼 2022-07-15 05:38 251阅读 0赞

java 使用URLConnection 进行HTTP接口调用 传递所需要的参数对象param url中的{参数}跟实体类中的属性命名一直会自动映射
    //例如
     public class Parameter{
        public static String operatorID="";
        public static String basic = "";
        public static String operatorPassword = "";
        public static String testFiled="";
    
        static {
            String projectType = PropertiesHander.getPropertiesValue("project.type");
            operatorID =  PropertiesHander.getPropertiesValue(projectType + ".av.operatorID");
            basic = PropertiesHander.getPropertiesValue(projectType + ".av.basic");
            operatorPassword = MD5Util.getMD5One((basic+operatorID).getBytes());
        }
    
    } String url="http://baidu.com/API/getUserInfoList?operatorID=${operatorID}&operatorPassword=${operatorPassword}";
    
    package com.ig.gapi.common;import org.apache.log4j.Logger;import javax.xml.bind.JAXBContext;import javax.xml.bind.Unmarshaller;import java.io.BufferedReader;import java.io.InputStream;import java.io.InputStreamReader;import java.io.StringReader;import java.lang.reflect.Field;import java.net.URL;import java.net.URLConnection;import java.util.List;import java.util.Map;import java.util.concurrent.ConcurrentHashMap;import java.util.concurrent.ConcurrentMap;import java.util.regex.Matcher;import java.util.regex.Pattern;
    
     public class CoreExecuteHttp {    private static final Logger logger = Logger.getLogger(CoreExecuteAV.class);    final static ConcurrentMap<Class,JAXBContext> contextCache = new ConcurrentHashMap<Class,JAXBContext>();    final static ConcurrentMap<Class,Field[]> fieldsCache = new ConcurrentHashMap<Class,Field[]>();    public static <T> T sendGet(Object parameter,Class<T> clazz,String url) {        String result = "";        BufferedReader in = null;        InputStreamReader inputStreamReader = null;        InputStream inputStream = null;        try {
                  Field[] fields = fieldsCache.get(parameter.getClass());            if(fields == null){                fields = parameter.getClass().getFields();                fieldsCache.put(clazz,fields);            }            for (int i = 0; i < fields.length; i++) {                Field filed = fields[i];                String filedName = filed.getName();                Object value = null;                try {                    value = filed.get(parameter);                } catch (IllegalAccessException e) {                    e.printStackTrace();                }                if(value != null){                    url = url.replace("${"+filedName+"}", value.toString());                }            }            url = url.replaceAll("&[^\\&]*=\\$\\{.*?\\}", "");            Pattern pattern = Pattern.compile("\\?.*?\\$\\{.*?\\}");            Matcher matcher = pattern.matcher(url);            if(matcher.find()){                String matchUrl = matcher.group(0);                url = url.replace(matchUrl.substring(1), "");            }                          System.out.println(url);            URL realUrl = new URL(url.trim());            URLConnection connection = realUrl.openConnection();            connection.setConnectTimeout(20000);            connection.setReadTimeout(20000);            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();            Map<String, List<String>> map = connection.getHeaderFields();            for (String key : map.keySet()) {                System.out.println(key + "--->" + map.get(key));            }            inputStream = connection.getInputStream();            inputStreamReader = new InputStreamReader(inputStream);            in = new BufferedReader(inputStreamReader);            String line;            while ((line = in.readLine()) != null) {                result += line;            }            JAXBContext context = contextCache.get(clazz);            if(context == null){                context = JAXBContext.newInstance(clazz);                contextCache.put(clazz,context);            }            Unmarshaller jaxbUnmarshaller = context.createUnmarshaller();            StringReader stringReader = new StringReader(result);            return (T) jaxbUnmarshaller.unmarshal(stringReader);        } catch (Exception e) {            System.out.println("aa链接请求 " + e);            e.printStackTrace();        }        finally {            try {                if (in != null) {                    in.close();                }                if(inputStreamReader!=null){                    inputStreamReader.close();                }                if(inputStream!=null){                    inputStream.close();                }            } catch (Exception e2) {                e2.printStackTrace();            }        }        return null;    }}