1、http请求发送-工具类

  1. /**
  2.  *  http请求发送
  3.  */
  4. @Slf4j
  5. public class HttpClientUtil {
  6.     public static String sendGet(String uri, String headerName, String headerValue)
  7.             throws IOException {
  8.         Content content = Request.Get(uri).setHeader(headerName, headerValue)
  9.                 .execute().returnContent();
  10.         return content.asString();
  11.     }
  13.     public static String sendPost(String url, String body, String contentType, String headerName, String headerValue)
  14.             throws IOException {
  15.         Content content = Request.Post(url)
  16.                 .setHeader(headerName, headerValue)
  17.                 .bodyString(body, ContentType.create(contentType))
  18.                 .execute().returnContent();
  19.         return content.asString();
  20.     }
  22.     public static String toGMTString(Date date) {
  23.         SimpleDateFormat df = new SimpleDateFormat("E, dd MMM yyyy HH:mm:ss z", Locale.UK);
  24.         df.setTimeZone(new java.util.SimpleTimeZone(0, "GMT"));
  25.         return df.format(date);
  26.     }
  28.     public static String sendPost(String url, String body, String akId, String akSecret) {
  29.         return sendPostOrPut(url, "POST", body, akId, akSecret);
  30.     }
  32.     public static String sendPut(String url, String body, String akId, String akSecret) {
  33.         return sendPostOrPut(url, "PUT", body, akId, akSecret);
  34.     }
  36.     private static String sendPostOrPut(String url, String method, String body, String akId, String akSecret) {
  37.         PrintWriter out = null;
  38.         BufferedReader in = null;
  39.         String result = "";
  40.         try {
  41.             URL realUrl = new URL(url);
  42.             String accept = "json";
  43.             String contentType = "application/json";
  44.             String path = realUrl.getFile();
  45.             String date = toGMTString(new Date());
  46.             String bodyMd5 = DigestUtil.md5Base64(body);
  47.             String stringToSign = method + "\n" + accept + "\n" + bodyMd5 + "\n" + contentType + "\n" + date + "\n"
  48.                     + path;
  49.             String signature = DigestUtil.hmacsha1(stringToSign, akSecret);
  50.             String authHeader = "dtboost-proxy " + akId + ":" + signature;
  51.             HttpURLConnection conn = (HttpURLConnection) realUrl.openConnection();
  52.             conn.setRequestMethod(method);
  54.             conn.setRequestProperty("accept", accept);
  55.             conn.setRequestProperty("content-type", contentType);
  56.             conn.setRequestProperty("date", date);
  57.             conn.setRequestProperty("Authorization", authHeader);
  58.             conn.setRequestProperty("Content-MD5", bodyMd5);
  59.             conn.setDoOutput(true);
  60.             conn.setDoInput(true);
  61.             out = new PrintWriter(conn.getOutputStream());
  62.             out.print(body);
  63.             out.flush();
  64.             if (conn.getResponseCode() != 200) {
  65.                 in = new BufferedReader(new InputStreamReader(conn.getErrorStream()));
  66.             } else {
  67.                 in = new BufferedReader(new InputStreamReader(conn.getInputStream()));
  68.             }
  69.             String line;
  70.             while ((line = in.readLine()) != null) {
  71.                 result += line;
  72.             }
  73.         } catch (Exception e) {
  74.             e.printStackTrace();
  75.         } finally {
  76.             try {
  77.                 if (out != null) {
  78.                     out.close();
  79.                 }
  80.                 if (in != null) {
  81.                     in.close();
  82.                 }
  83.             } catch (IOException ex) {
  84.                 ex.printStackTrace();
  85.             }
  86.         }
  87.         return result;
  88.     }
  90.     public static String sendAKGet(String url, String akId, String akSecret) {
  91.         String result = "";
  92.         BufferedReader in = null;
  93.         try {
  94.             URL realUrl = new URL(url);
  95.             String method = "GET";
  96.             String accept = "json";
  97.             String contentType = "application/json";
  98.             String path = realUrl.getFile();
  99.             String date = toGMTString(new Date());
  100.             String stringToSign = method + "\n" + accept + "\n" + "" + "\n" + contentType + "\n" + date + "\n" + path;
  101.             String signature = DigestUtil.hmacsha1(stringToSign, akSecret);
  102.             String authHeader = "dtboost-proxy " + akId + ":" + signature;
  103.             HttpURLConnection connection = (HttpURLConnection) realUrl.openConnection();
  104.             connection.setRequestProperty("accept", accept);
  105.             connection.setRequestProperty("content-type", contentType);
  106.             connection.setRequestProperty("date", date);
  107.             connection.setRequestProperty("Authorization", authHeader);
  108.             connection.connect();
  109.             if (connection.getResponseCode() != 200) {
  110.                 in = new BufferedReader(new InputStreamReader(connection.getErrorStream()));
  111.             } else {
  112.                 in = new BufferedReader(new InputStreamReader(connection.getInputStream()));
  113.             }
  114.             String line;
  115.             while ((line = in.readLine()) != null) {
  116.                 result += line;
  117.             }
  118.         } catch (Exception e) {
  119.             e.printStackTrace();
  120.         } finally {
  121.             try {
  122.                 if (in != null) {
  123.                     in.close();
  125.                 }
  126.             } catch (Exception e) {
  127.                 e.printStackTrace();
  128.             }
  129.         }
  130.         return result;
  131.     }
  133.     /**
  134.      * http head请求
  135.      * @throws Exception
  136.      */
  137.     public static String sendHeadGet(String path, Long projectId) throws Exception{
  138.         String value = "{'extraInfo':{'projectId':'"+projectId+"'}}";
  139.         try {
  140.             URL url = new URL(path);
  141.             HttpURLConnection connection = (HttpURLConnection) url.openConnection();
  142.             //connection.setRequestProperty("设置请求头key", "请求头value");
  143.             connection.addRequestProperty("CityBrain-User-Profile", value);
  144.             //连接会话
  145.             connection.connect();
  146.             // 获取输入流
  147.             BufferedReader br = new BufferedReader(new InputStreamReader(connection.getInputStream(), "UTF-8"));
  148.             String line;
  149.             StringBuilder sb = new StringBuilder();
  150.             while (Objects.nonNull((line = br.readLine()))) {
  151.                 sb.append(line);
  152.             }
  153.             br.close();
  154.             connection.disconnect();
  155.             String result = sb.toString();
  156.             return result;
  157.         } catch (Exception e) {
  158.             log.error("请求失败,url:{}", path);
  159.             throw e;
  160.         }
  161.     }
  162. }