HttpClient发送get请求和post请求及文件上传下载

叁歲伎倆 2023-06-27 13:59 28阅读 0赞

package com.alibaba.dingtalk.openapi.demo.utils;
    
    import java.io.File;
    import java.io.IOException;
    import java.net.URI;
    
    import org.apache.commons.io.FileUtils;
    import org.apache.http.HttpEntity;
    import org.apache.http.client.config.RequestConfig;
    import org.apache.http.client.methods.CloseableHttpResponse;
    import org.apache.http.client.methods.HttpGet;
    import org.apache.http.client.methods.HttpPost;
    import org.apache.http.client.protocol.HttpClientContext;
    import org.apache.http.entity.StringEntity;
    import org.apache.http.entity.mime.MultipartEntityBuilder;
    import org.apache.http.entity.mime.content.FileBody;
    import org.apache.http.entity.ContentType;
    import org.apache.http.impl.client.CloseableHttpClient;
    import org.apache.http.impl.client.HttpClients;
    import org.apache.http.impl.client.RedirectLocations;
    import org.apache.http.protocol.BasicHttpContext;
    import org.apache.http.protocol.HttpContext;
    import org.apache.http.util.EntityUtils;
    
    import com.alibaba.dingtalk.openapi.demo.OApiException;
    import com.alibaba.fastjson.JSON;
    import com.alibaba.fastjson.JSONObject;
    
    
    public class HttpHelper {
    
    	public static JSONObject httpGet(String url) throws OApiException{
            HttpGet httpGet = new HttpGet(url);
            CloseableHttpResponse response = null;
            CloseableHttpClient httpClient = HttpClients.createDefault();
            RequestConfig requestConfig = RequestConfig.custom().
            		setSocketTimeout(2000).setConnectTimeout(2000).build();
            httpGet.setConfig(requestConfig);
    
            try {
                response = httpClient.execute(httpGet, new BasicHttpContext());
    
                if (response.getStatusLine().getStatusCode() != 200) {
    
                    System.out.println("request url failed, http code=" + response.getStatusLine().getStatusCode()
                                       + ", url=" + url);
                    return null;
                }
                HttpEntity entity = response.getEntity();
                if (entity != null) {
                    String resultStr = EntityUtils.toString(entity, "utf-8");
    
                    JSONObject result = JSON.parseObject(resultStr);
                    if (result.getInteger("errcode") == 0) {
    //                	result.remove("errcode");
    //                	result.remove("errmsg");
                        return result;
                    } else {
                        System.out.println("request url=" + url + ",return value=");
                        System.out.println(resultStr);
                        int errCode = result.getInteger("errcode");
                        String errMsg = result.getString("errmsg");
                        throw new OApiException(errCode, errMsg);
                    }
                }
            } catch (IOException e) {
                System.out.println("request url=" + url + ", exception, msg=" + e.getMessage());
                e.printStackTrace();
            } finally {
                if (response != null) try {
                    response.close();
                } catch (IOException e) {
                    e.printStackTrace();
                }
            }
    
            return null;
        }
    	
    	
    	public static JSONObject httpPost(String url, Object data) throws OApiException {
            HttpPost httpPost = new HttpPost(url);
            CloseableHttpResponse response = null;
            CloseableHttpClient httpClient = HttpClients.createDefault();
            RequestConfig requestConfig = RequestConfig.custom().
            		setSocketTimeout(2000).setConnectTimeout(2000).build();
            httpPost.setConfig(requestConfig);
            httpPost.addHeader("Content-Type", "application/json");
    
            try {
            	StringEntity requestEntity = new StringEntity(JSON.toJSONString(data), "utf-8");
                httpPost.setEntity(requestEntity);
                
                response = httpClient.execute(httpPost, new BasicHttpContext());
    
                if (response.getStatusLine().getStatusCode() != 200) {
    
                    System.out.println("request url failed, http code=" + response.getStatusLine().getStatusCode()
                                       + ", url=" + url);
                    return null;
                }
                HttpEntity entity = response.getEntity();
                if (entity != null) {
                    String resultStr = EntityUtils.toString(entity, "utf-8");
    
                    JSONObject result = JSON.parseObject(resultStr);
                    if (result.getInteger("errcode") == 0) {
                    	result.remove("errcode");
                    	result.remove("errmsg");
                        return result;
                    } else {
                        System.out.println("request url=" + url + ",return value=");
                        System.out.println(resultStr);
                        int errCode = result.getInteger("errcode");
                        String errMsg = result.getString("errmsg");
                        throw new OApiException(errCode, errMsg);
                    }
                }
            } catch (IOException e) {
                System.out.println("request url=" + url + ", exception, msg=" + e.getMessage());
                e.printStackTrace();
            } finally {
                if (response != null) try {
                    response.close();
                } catch (IOException e) {
                    e.printStackTrace();
                }
            }
    
            return null;
        }
    	
    	
    	public static JSONObject uploadMedia(String url, File file) throws OApiException {
            HttpPost httpPost = new HttpPost(url);
            CloseableHttpResponse response = null;
            CloseableHttpClient httpClient = HttpClients.createDefault();
            RequestConfig requestConfig = RequestConfig.custom().setSocketTimeout(2000).setConnectTimeout(2000).build();
            httpPost.setConfig(requestConfig);
    
            HttpEntity requestEntity = MultipartEntityBuilder.create().addPart("media",
            		new FileBody(file, ContentType.APPLICATION_OCTET_STREAM, file.getName())).build();
            httpPost.setEntity(requestEntity);
    
            try {
                response = httpClient.execute(httpPost, new BasicHttpContext());
    
                if (response.getStatusLine().getStatusCode() != 200) {
    
                    System.out.println("request url failed, http code=" + response.getStatusLine().getStatusCode()
                                       + ", url=" + url);
                    return null;
                }
                HttpEntity entity = response.getEntity();
                if (entity != null) {
                    String resultStr = EntityUtils.toString(entity, "utf-8");
    
                    JSONObject result = JSON.parseObject(resultStr);
                    if (result.getInteger("errcode") == 0) {
                        // 成功
                    	result.remove("errcode");
                    	result.remove("errmsg");
                        return result;
                    } else {
                        System.out.println("request url=" + url + ",return value=");
                        System.out.println(resultStr);
                        int errCode = result.getInteger("errcode");
                        String errMsg = result.getString("errmsg");
                        throw new OApiException(errCode, errMsg);
                    }
                }
            } catch (IOException e) {
                System.out.println("request url=" + url + ", exception, msg=" + e.getMessage());
                e.printStackTrace();
            } finally {
                if (response != null) try {
                    response.close();
                } catch (IOException e) {
                    e.printStackTrace();
                }
            }
    
            return null;
        }
    	
    	
    	public static JSONObject downloadMedia(String url, String fileDir) throws OApiException {
            HttpGet httpGet = new HttpGet(url);
            CloseableHttpResponse response = null;
            CloseableHttpClient httpClient = HttpClients.createDefault();
            RequestConfig requestConfig = RequestConfig.custom().setSocketTimeout(2000).setConnectTimeout(2000).build();
            httpGet.setConfig(requestConfig);
    
            try {
                HttpContext localContext = new BasicHttpContext();
    
                response = httpClient.execute(httpGet, localContext);
    
                RedirectLocations locations = (RedirectLocations) localContext.getAttribute(HttpClientContext.REDIRECT_LOCATIONS);
                if (locations != null) {
                    URI downloadUrl = locations.getAll().get(0);
                    String filename = downloadUrl.toURL().getFile();
                    System.out.println("downloadUrl=" + downloadUrl);
                    File downloadFile = new File(fileDir + File.separator + filename);
                    FileUtils.writeByteArrayToFile(downloadFile, EntityUtils.toByteArray(response.getEntity()));
                    JSONObject obj = new JSONObject();
                    obj.put("downloadFilePath", downloadFile.getAbsolutePath());
                    obj.put("httpcode", response.getStatusLine().getStatusCode());
                    
                   
                    
                    return obj;
                } else {
                    if (response.getStatusLine().getStatusCode() != 200) {
    
                        System.out.println("request url failed, http code=" + response.getStatusLine().getStatusCode()
                                           + ", url=" + url);
                        return null;
                    }
                    HttpEntity entity = response.getEntity();
                    if (entity != null) {
                        String resultStr = EntityUtils.toString(entity, "utf-8");
    
                        JSONObject result = JSON.parseObject(resultStr);
                        if (result.getInteger("errcode") == 0) {
                            // 成功
                        	result.remove("errcode");
                        	result.remove("errmsg");
                            return result;
                        } else {
                            System.out.println("request url=" + url + ",return value=");
                            System.out.println(resultStr);
                            int errCode = result.getInteger("errcode");
                            String errMsg = result.getString("errmsg");
                            throw new OApiException(errCode, errMsg);
                        }
                    }
                }
            } catch (IOException e) {
                System.out.println("request url=" + url + ", exception, msg=" + e.getMessage());
                e.printStackTrace();
            } finally {
                if (response != null) try {
                    response.close();
                } catch (IOException e) {
                    e.printStackTrace();
                }
            }
    
            return null;
        }
    }

调用方式

public static String getSuiteToken(String suite_key, String suite_secret,String suite_ticket){
    		String url = Env.OAPI_HOST + "/service/get_suite_token";
    		JSONObject json = new JSONObject();
    		json.put("suite_key", suite_key);
    		json.put("suite_secret", suite_secret);
    		json.put("suite_ticket", suite_ticket);
    		JSONObject reponseJson = null;
    		String suiteAccessToken = null;
    		try {
    			reponseJson = HttpHelper.httpPost(url,json);
    			suiteAccessToken = reponseJson.getString("suite_access_token");
    		} catch (OApiException e) {
    			e.printStackTrace();
    		}
    		return suiteAccessToken;
    	}

public static JSONObject getAgentUserInfo(String ssoToken, String code) throws OApiException  {
    		
    		String url = Env.OAPI_HOST + "/sso/getuserinfo?" + "access_token=" + ssoToken + "&code=" + code;
    		JSONObject response = HttpHelper.httpGet(url);
    		return response;
    	}