download：Spark+ES+ClickHouse 构建DMP用户画像

package wzh.Http;

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.PrintWriter;
import java.net.URL;
import java.net.URLConnection;
import java.util.List;
import java.util.Map;

public class HttpRequest {

/**  * 向指定URL发送GET办法的申请  *   * @param url  *            发送申请的URL  * @param param  *            申请参数，申请参数应该是 name1=value1&name2=value2 的模式。  * @return URL 所代表近程资源的响应后果  */ public static String sendGet(String url, String param) {      String result = "";      BufferedReader in = null;      try {          String urlNameString = url + "?" + param;          URL realUrl = new URL(urlNameString);          // 关上和URL之间的连贯          URLConnection connection = realUrl.openConnection();          // 设置通用的申请属性          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));          }          // 定义 BufferedReader输出流来读取URL的响应          in = new BufferedReader(new InputStreamReader(                  connection.getInputStream()));          String line;          while ((line = in.readLine()) != null) {              result += line;          }      } catch (Exception e) {          System.out.println("发送GET申请出现异常！" + e);          e.printStackTrace();      }      // 应用finally块来敞开输出流      finally {          try {              if (in != null) {                  in.close();              }          } catch (Exception e2) {              e2.printStackTrace();          }      }      return result;  }  /**   * 向指定 URL 发送POST办法的申请   *    * @param url   *            发送申请的 URL   * @param param   *            申请参数，申请参数应该是 name1=value1&name2=value2 的模式。   * @return 所代表近程资源的响应后果   */  public static String sendPost(String url, String param) {      PrintWriter out = null;      BufferedReader in = null;      String result = "";      try {          URL realUrl = new URL(url);          // 关上和URL之间的连贯          URLConnection conn = realUrl.openConnection();          // 设置通用的申请属性          conn.setRequestProperty("accept", "*/*");          conn.setRequestProperty("connection", "Keep-Alive");          conn.setRequestProperty("user-agent",                  "Mozilla/4.0 (compatible; MSIE 6.0; Windows NT 5.1;SV1)");          // 发送POST申请必须设置如下两行          conn.setDoOutput(true);          conn.setDoInput(true);          // 获取URLConnection对象对应的输入流          out = new PrintWriter(conn.getOutputStream());          // 发送申请参数          out.print(param);          // flush输入流的缓冲          out.flush();          // 定义BufferedReader输出流来读取URL的响应          in = new BufferedReader(                  new InputStreamReader(conn.getInputStream()));          String line;          while ((line = in.readLine()) != null) {              result += line;          }      } catch (Exception e) {          System.out.println("发送 POST 申请出现异常！"+e);          e.printStackTrace();      }      //应用finally块来敞开输入流、输出流      finally{          try{              if(out!=null){                  out.close();              }              if(in!=null){                  in.close();              }          }          catch(IOException ex){              ex.printStackTrace();          }      }      return result;  }      

}