通过httpClient调用外部系统接口并返回数据解析

/**
 * 调用外部登录接口，返回数据（json解析成对应的实体类）
 */
public static String callExterLogon(String phone, String password){
    String uri = "http://test.fortune-net.cn:8777/a/x!invalidPhoneAndPassword.ql";
    List<NameValuePair> nvps = new ArrayList<NameValuePair>();
    nvps.add(new BasicNameValuePair("phone", phone));
    nvps.add(new BasicNameValuePair("password", password));
    String content = "";
    try {
        content = CallExternalInterfaceUtils.officPost(uri,nvps);
    } catch (Exception e) {
        e.printStackTrace();
        return null;
    }
    return content;
}

/***
/**　　返回数据解析成实体类
/*
/

String content = callExterLogon(phone,password);
if(content!=null) callBackStatus=true;
if(callBackStatus){
    //接受返回数据
    System.out.println("success");
    System.out.println(jsonToAdmin(content));
    //保存
    //xyBind = xyBindLogicInterface.saveOrUpdateQuickLiveAccount(admin.getOrganId(),phone,password);
}

//************************

********************************************************************************************************************

//泛型改良版。如果有必要！！！！！！！！！！

System.out.println(jsonToAdmin(content,Admin.class));

/**
 * 转换成对象
 */
private <T> T jsonToAdmin(String jsonData,Class<T> clazz){
    ObjectMapper objectMapper;
    JSONObject jsonObject = JSONObject.fromObject(jsonData);
    Object object = jsonObject.get("admin");
    T t = null;
    if(jsonData!=null){
        objectMapper = new ObjectMapper();
        objectMapper.configure(DeserializationConfig.Feature.FAIL_ON_UNKNOWN_PROPERTIES, false);
        try {
            t = objectMapper.readValue(object.toString(),clazz);
        } catch (IOException e) {
            e.printStackTrace();
            log.debug("信息获取失败");
        }
    }
    return t;
}

/************************************************************************************************************************

/**
 * 官方推荐post
 * "http://targethost/login"
 */
public static String officPost(String uri,List<NameValuePair> nvps) throws Exception{
    CloseableHttpClient httpclient = HttpClients.createDefault();
    HttpPost httpPost = new HttpPost(uri);

    CloseableHttpResponse response = null;
    HttpEntity entity2 = null;
    JSONObject content = null;
    String result = "";
    try {
        httpPost.setEntity(new UrlEncodedFormEntity(nvps));
        response = httpclient.execute(httpPost);
　　　　//响应结果
        if(response.getStatusLine().getStatusCode() == HttpStatus.SC_OK){
            entity2 = response.getEntity();
            result = EntityUtils.toString(entity2, "UTF-8");
        }
        //关闭流
        EntityUtils.consume(entity2);
    } catch (Exception e) {
        e.printStackTrace();
    }finally {
        if(response!=null){
            response.close();
        }
        InputStream instream = entity2.getContent();
        if (instream != null) {
            instream.close();
        }
    }
    return result;
}


/****
/***
/**　　外部系统数据形式 ，springMvc用responseBody 返回 toString（）的json数据
/*
/

/**
 * 测试验证参数
 * @return
 */
public String invalidPhoneAndPassword(){
    Admin admin = new Admin();
    admin.setPhone(phone);
    admin.setPassword(password);
    admin.setName("yxb");
    jsonMap.put("admin",admin);
    return "invalidPhoneAndPassword";
}

/**
/*    下面的方法需要修改之后应用于项目
/

  private static Logger logger = Logger.getLogger(CallExternalInterfaceUtils.class);

        /**
         * get请求
         * @return
         */
        public static String doGet(String url) {
            try {
                /*HttpClient client = new DefaultHttpClient();
                //发送get请求
                HttpGet request = new HttpGet(url);
                HttpResponse response = client.execute(request);
*/
                CloseableHttpClient httpclient = HttpClients.createDefault();
                HttpGet httpGet = new HttpGet("http://targethost/homepage");
                CloseableHttpResponse response = httpclient.execute(httpGet);

                /**请求发送成功，并得到响应**/
                if (response.getStatusLine().getStatusCode() == HttpStatus.SC_OK) {
                    /**读取服务器返回过来的json字符串数据**/
                    String strResult = EntityUtils.toString(response.getEntity());

                    return strResult;
                }
            }
            catch (IOException e) {
                e.printStackTrace();
            }

            return null;
        }

        /**
         * post请求(用于key-value格式的参数)
         * @param url
         * @param params
         * @return
         */
        public static String doPost(String url, Map params){

            BufferedReader in = null;
            try {
                // 定义HttpClient
                HttpClient client = new DefaultHttpClient();
                // 实例化HTTP方法
                HttpPost request = new HttpPost();
                request.setURI(new URI(url));

                //设置参数
                List<NameValuePair> nvps = new ArrayList<NameValuePair>();
                for (Iterator iter = params.keySet().iterator(); iter.hasNext();) {
                    String name = (String) iter.next();
                    String value = String.valueOf(params.get(name));
                    nvps.add(new BasicNameValuePair(name, value));

                    //System.out.println(name +"-"+value);
                }
                request.setEntity(new UrlEncodedFormEntity(nvps,HTTP.UTF_8));

                HttpResponse response = client.execute(request);
                int code = response.getStatusLine().getStatusCode();
                if(code == 200){    //请求成功
                    in = new BufferedReader(new InputStreamReader(response.getEntity()
                            .getContent(),"utf-8"));
                    StringBuffer sb = new StringBuffer("");
                    String line = "";
                    String NL = System.getProperty("line.separator");
                    while ((line = in.readLine()) != null) {
                        sb.append(line + NL);
                    }

                    in.close();

                    return sb.toString();
                }
                else{   //
                    System.out.println("状态码：" + code);
                    return null;
                }
            }
            catch(Exception e){
                e.printStackTrace();

                return null;
            }
        }

        /**
         * post请求（用于请求json格式的参数）
         * @param url
         * @param params
         * @return
         */
        public static String doPost(String url, String params) throws Exception {
            CloseableHttpClient httpclient = HttpClients.createDefault();
            HttpPost httpPost = new HttpPost(url);// 创建httpPost
            httpPost.setHeader("Accept", "application/json");
            httpPost.setHeader("Content-Type", "application/json");
            String charSet = "UTF-8";
            StringEntity entity = new StringEntity(params, charSet);
            httpPost.setEntity(entity);
            CloseableHttpResponse response = null;

            try {

                response = httpclient.execute(httpPost);
                StatusLine status = response.getStatusLine();
                int state = status.getStatusCode();
                if (state == HttpStatus.SC_OK) {
                    HttpEntity responseEntity = response.getEntity();
                    String jsonString = EntityUtils.toString(responseEntity);
                    return jsonString;
                }
                else{
                    logger.error("请求返回:"+state+"("+url+")");
                }
            }
            finally {
                if (response != null) {
                    try {
                        response.close();
                    } catch (IOException e) {
                        e.printStackTrace();
                    }
                }
                try {
                    httpclient.close();
                } catch (IOException e) {
                    e.printStackTrace();
                }
            }
            return null;
        }