java发送Http请求

使用java 11添加的HttpClient新API发送Http(Https)请求
HTTP客户端是在Java 11中添加的。它可以用于通过网络请求HTTP资源。它支持 HTTP / 1.1和HTTP / 2（同步和异步编程模型），将请求和响应主体作为反应流处理，并遵循熟悉的构建器模式。
参考文章：https://blog.csdn.net/allway2/article/details/112725692
Maven

1. <dependency>
2.     <groupId>com.alibaba</groupId>
3.     <artifactId>fastjson</artifactId>
4.     <version>1.2.83</version>
5. </dependency>

复制代码

实例代码

1. package org.example;
3. import com.alibaba.fastjson.JSONArray;
4. import com.alibaba.fastjson.JSONObject;
6. import javax.net.ssl.SSLContext;
7. import javax.net.ssl.TrustManager;
8. import javax.net.ssl.X509TrustManager;
9. import java.io.IOException;
10. import java.io.Serializable;
11. import java.net.URI;
12. import java.net.http.HttpClient;
13. import java.net.http.HttpRequest;
14. import java.net.http.HttpResponse;
15. import java.security.KeyManagementException;
16. import java.security.NoSuchAlgorithmException;
17. import java.security.SecureRandom;
18. import java.util.*;
20. public class Main {
21.     private static final TrustManager[] trustAllCerts = new TrustManager[]{
22.             new X509TrustManager() {
23.                 public java.security.cert.X509Certificate[] getAcceptedIssuers() {
24.                     return null;
25.                 }
27.                 public void checkClientTrusted(java.security.cert.X509Certificate[] certs, String authType) {
28.                 }
30.                 public void checkServerTrusted(java.security.cert.X509Certificate[] certs, String authType) {
31.                 }
32.             }
33.     };
34.     private static final HttpClient client;
36.     static {
37.         // 允许不安全SSL连接
38.         final Properties props = System.getProperties();
39.         props.setProperty("jdk.internal.httpclient.disableHostnameVerification", Boolean.TRUE.toString());
40.         SSLContext sslContext = null;
41.         try {
42.             sslContext = SSLContext.getInstance("TLS");
43.             sslContext.init(null, trustAllCerts, new SecureRandom());
44.             // 构建client实例
45.             client = HttpClient.newBuilder()
46.                     .sslContext(sslContext)
47.                     .build();
48.         } catch (NoSuchAlgorithmException | KeyManagementException e) {
49.             throw new RuntimeException(e);
50.         }
51.     }
53.     /**
54.      * 发送get请求
55.      * @param url url
56.      * @param params path参数
57.      * @return 响应体
58.      */
59.     public static JSONObject get(String url, Map<String, Object> params) {
60.         // 拼接url
61.         URI uri = disposeUrl(url, params);
62.         // 构造get请求
63.         HttpRequest req = HttpRequest.newBuilder(uri)
64.                 .GET()
65.                 .build();
66.         try {
67.             // 发送get请求
68.             HttpResponse<String> res = client.send(req, HttpResponse.BodyHandlers.ofString());
69.             return JSONObject.parseObject(res.body());
70.         } catch (IOException | InterruptedException e) {
71.             throw new RuntimeException(e);
72.         }
73.     }
75.     /**
76.      * 拼接url请求低质
77.      * @param url url
78.      * @param params 参数
79.      * @return 完整url
80.      */
81.     private static URI disposeUrl(String url, Map<String, Object> params) {
82.         StringBuilder sb = new StringBuilder(url);
83.         if (params == null || params.keySet().size() == 0) return URI.create(url);
84.         Set<String> keys = params.keySet();
85.         sb.append("?");
86.         keys.forEach(key -> sb.append(key).append("=").append(params.get(key)).append("&"));
87.         return URI.create(sb.substring(0, sb.length() - 1));
88.     }
90.     /**
91.      * 发送post请求
92.      * @param url url
93.      * @param data 参数
94.      * @return 响应体
95.      */
96.     public static JSONObject post(String url, JSONObject data) {
97.         return post(url, null, data);
98.     }
100.     /**
101.      * 发送post请求
102.      * @param url url
103.      * @param params path参数
104.      * @param data 请求体中的参数
105.      * @return 响应体
106.      */
107.     public static JSONObject post(String url, Map<String, Object> params, JSONObject data) {
108.         // 拼接uri
109.         URI uri = disposeUrl(url, params);
110.         // 构造post请求
111.         HttpRequest req = HttpRequest.newBuilder(uri)
112.                 .POST(HttpRequest.BodyPublishers.ofString(data.toString()))
113.                 .build();
114.         try {
115.             // 发送post请求
116.             HttpResponse<String> res = client.send(req, HttpResponse.BodyHandlers.ofString());
117.             return JSONObject.parseObject(res.body());
118.         } catch (IOException | InterruptedException e) {
119.             throw new RuntimeException(e);
120.         }
121.     }
123.     public static class keyValueRecord implements Serializable {
124.         private String key;
125.         private String value;
127.         public keyValueRecord(String key, String value) {
128.             this.key = key;
129.             this.value = value;
130.         }
132.         public String getKey() {
133.             return key;
134.         }
136.         public void setKey(String key) {
137.             this.key = key;
138.         }
140.         public String getValue() {
141.             return value;
142.         }
144.         public void setValue(String value) {
145.             this.value = value;
146.         }
147.     }
149.     public static void main(String[] args) {
150.         // 获取token
151.         Map<String, Object> params = new HashMap<>();
152.         params.put("corpid", "xxx");
153.         params.put("corpsecret", "xxx");
154.         JSONObject json = get("https://qyapi.weixin.qq.com/cgi-bin/gettoken", params);
155.         String access_token = json.getString("access_token");
157.         // 获取审批单号
158.         JSONObject data = new JSONObject();
159.         Calendar cal = Calendar.getInstance();
160.         cal.setTimeInMillis(System.currentTimeMillis());
161.         cal.add(Calendar.DATE, -15);
162.         data.put("starttime", String.valueOf(cal.getTime().getTime() / 1000));
163.         data.put("endtime", String.valueOf(System.currentTimeMillis() / 1000));
164.         data.put("cursor", 0);
165.         data.put("size", 100);
166.         JSONArray arr = new JSONArray();
167.         arr.add(0, new keyValueRecord("sp_status", "1"));
168.         arr.add(0, new keyValueRecord("template_id", "1970325103043160_1688851905330597_909052414_1534723908"));
169.         data.put("filters", arr);
170.         params = new HashMap<>();
171.         params.put("access_token", access_token);
172.         json = post("https://qyapi.weixin.qq.com/cgi-bin/oa/getapprovalinfo", params, data);
173.         JSONArray list = json.getJSONArray("sp_no_list");
175.         // 获取审批单详细信息
176.         for (int i = 0; i < list.size(); i++) {
177.             String item = list.getString(i);
178.             data = new JSONObject();
179.             data.put("sp_no",item);
180.             json = post("https://qyapi.weixin.qq.com/cgi-bin/oa/getapprovaldetail", params, data);
181.             System.out.println(json.toString());
182.         }
183.     }
184. }

复制代码

免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！