JAVA发送HttpClient请求

た 入场券 2022-04-11 09:15 450阅读 0赞 
  1. //测试例子：
  2. public static JSONObject test() {
  3.         String urlstr = "http://xxx:8080/test/test.do";
  4.         String Authorization = "test:test";
  6.         JSONObject result = HttpRequestUtils.httpPost(urlstr, null, Authorization);
  7.                 return result;
  8.                }
  10. public class HttpRequestUtils {
  11.     protected final Logger logger = LoggerFactory.getLogger(HttpRequestUtils.class); // 日志记录
  13.     // 表示请求器是否已经做了初始化工作
  14.     private static boolean hasInit = false;
  16.     // 连接超时时间，默认10秒
  17.     private static int socketTimeout = 10000;
  19.     // 传输超时时间，默认30秒
  20.     private static int connectTimeout = 30000;
  22.     // 请求器的配置
  23.     private static RequestConfig requestConfig;
  25.     public static void init() {
  26.         if (!hasInit) {
  27.             requestConfig = RequestConfig.custom().setSocketTimeout(socketTimeout).setConnectTimeout(connectTimeout).build();
  28.         }
  29.     }
  31.     public static JSONObject httpPost(String url, JSONObject param, String Authorization) {
  32.         init();
  34.         // post请求返回结果
  35.         CloseableHttpClient httpClient = HttpClients.createDefault();
  36.         JSONObject result = null;
  37.         HttpPost httpPost = new HttpPost();
  38.         if (param != null) {
  39.             // 解决中文乱码问题
  40.             StringEntity entity = new StringEntity(param.toString(), "UTF-8");
  41.             entity.setContentEncoding("UTF-8");
  42.             entity.setContentType("application/json");
  43.             httpPost.setEntity(entity);
  45.         }
  46.         // 增加http basic authenticate认证
  47.         if (!Tools.isEmpty(Authorization)) {
  48.             String encoding;
  49.             try {
  50.                 encoding = Base64.encode(Authorization.getBytes("UTF-8"));
  51.                 httpPost.setHeader("Authorization", String.format("Basic %s", encoding));
  52.             } catch (UnsupportedEncodingException e) {
  53.                 e.printStackTrace();
  54.             }
  55.         }
  56.         // 设置请求器的配置
  57.         httpPost.setConfig(requestConfig);
  59.         try {
  60.             HttpResponse response = httpClient.execute(httpPost);
  62.             // 请求发送成功，得到响应
  63.             int responseCode = response.getStatusLine().getStatusCode();
  64.             if (response.getStatusLine().getStatusCode() == 200) {
  65.                 String str = EntityUtils.toString(response.getEntity(),"UTF-8");
  66.                 try {
  67.                     result = new JSONObject(str);
  68.                 } catch (org.json.JSONException e) {
  69.                     result = new JSONObject();
  70.                     result.put("str", str);
  71.                 }
  72.             } else {
  73.                 result = new JSONObject();
  74.                 result.put("responseCode", responseCode);
  75.             }
  76.         } catch (ClientProtocolException e) {
  77.             e.printStackTrace();
  78.         } catch (IOException e) {
  79.             e.printStackTrace();
  80.         } finally {
  81.             try {
  82.                 httpPost.releaseConnection();
  83.                 httpPost.abort();
  84.                 httpClient.close();
  85.             } catch (IOException e) {
  86.                 e.printStackTrace();
  87.             }
  88.         }
  89.         return result;
  90.     }
  92.     public static JSONObject httpGet(String url, String Authorization) {
  93.         init();
  95.         // get请求返回结果
  96.         JSONObject result = null;
  97.         CloseableHttpClient httpClient = HttpClients.createDefault();
  99.         // 发送get请求
  100.         HttpGet httpGet = new HttpGet(url);
  101.         // 增加http basic authenticate认证
  102.         if (!Tools.isEmpty(Authorization)) {
  103.             String encoding;
  104.             try {
  105.                 encoding = Base64.encode(Authorization.getBytes("UTF-8"));
  106.                 httpGet.setHeader("Authorization", String.format("Basic %s", encoding));
  107.             } catch (UnsupportedEncodingException e) {
  108.                 e.printStackTrace();
  109.             }
  110.         }
  111.         // 设置请求器的配置
  112.         httpGet.setConfig(requestConfig);
  113.         try {
  114.             HttpResponse response = httpClient.execute(httpGet);
  115.             // 请求发送成功，得到响应
  116.             int responseCode = response.getStatusLine().getStatusCode();
  117.             if (responseCode == 200) {
  118.                 String str = EntityUtils.toString(response.getEntity(),"UTF-8");
  119.                 try {
  120.                     result = new JSONObject(str);
  121.                 } catch (org.json.JSONException e) {
  122.                     result = new JSONObject();
  123.                     result.put("responseCode", responseCode);
  124.                 }
  125.             }
  126.         } catch (ClientProtocolException e) {
  127.             e.printStackTrace();
  128.         } catch (IOException e) {
  129.             e.printStackTrace();
  130.         } finally {
  131.             try {
  132.                 httpGet.releaseConnection();
  133.                 httpGet.abort();
  134.                 httpClient.close();
  135.             } catch (IOException e) {
  136.                 e.printStackTrace();
  137.             }
  138.         }
  140.         return result;
  141.     }
  142. }

发表评论

表情：
评论列表 （有 0 条评论，450人围观）

还没有评论，来说两句吧...

相关阅读