B2B网络软件

标题: AIWROK软件JSON请求完整示例 [打印本页]

---

作者: YYPOST群发软件    时间: 半小时前
标题: AIWROK软件JSON请求完整示例
AIWROK软件JSON请求完整示例

1. /**
   
2. * AIWROK HTTP请求完整示例
   
3. * 功能：GET/POST请求、超时控制、自动重试、JSON解析
   
4. * 适用：安卓 Rhino ES5 引擎
   
5. */
   
6. 
   
7. importClass(java.net.HttpURLConnection);
   
8. importClass(java.net.URL);
   
9. importClass(java.io.BufferedReader);
   
10. importClass(java.io.InputStreamReader);
    
11. importClass(java.io.OutputStreamWriter);
    
12. 
    
13. // ======================== 工具函数 ========================
    
14. 
    
15. /**
    
16. * 手动构建 JSON（Rhino 环境下 JSON.stringify 可能不可用）
    
17. */
    
18. function toJson(obj) {
    
19.     var parts = [];
    
20.     for (var key in obj) {
    
21.         // Rhino ES5 下不用 hasOwnProperty（Java 包装类型没有这个方法）
    
22.         var val = "" + obj[key];
    
23.         if (typeof obj[key] === "string" || obj[key] instanceof java.lang.String) {
    
24.             val = val.replace(/\\/g, "\\\\").replace(/"/g, '\\"').replace(/\n/g, "\\n");
    
25.             parts.push('"' + key + '":"' + val + '"');
    
26.         } else {
    
27.             parts.push('"' + key + '":' + val);
    
28.         }
    
29.     }
    
30.     return "{" + parts.join(",") + "}";
    
31. }
    
32. 
    
33. /**
    
34. * 手动解析 JSON（使用 org.json.JSONObject）
    
35. */
    
36. function parseJson(jsonStr) {
    
37.     try {
    
38.         var jsonObj = new org.json.JSONObject(jsonStr);
    
39.         return jsonObj;
    
40.     } catch (e) {
    
41.         printl("[parseJson] 解析失败: " + e.message);
    
42.         return null;
    
43.     }
    
44. }
    
45. 
    
46. // ======================== HTTP 客户端 ========================
    
47. 
    
48. /**
    
49. * HTTP GET 请求
    
50. * @param {string} url - 请求地址
    
51. * @param {object} headers - 自定义请求头
    
52. * @param {number} timeout - 超时时间（毫秒）
    
53. * @returns {object} {code, body, headers, success}
    
54. */
    
55. function httpGet(url, headers, timeout) {
    
56.     headers = headers || {};
    
57.     timeout = timeout || 10000;
    
58. 
    
59.     try {
    
60.         var conn = new URL(url).openConnection();
    
61.         conn.setRequestMethod("GET");
    
62.         conn.setConnectTimeout(timeout);
    
63.         conn.setReadTimeout(timeout);
    
64.         conn.setUseCaches(false);
    
65. 
    
66.         // 设置默认 User-Agent
    
67.         conn.setRequestProperty("User-Agent", "AIWROK/1.0");
    
68.         conn.setRequestProperty("Content-Type", "application/json");
    
69. 
    
70.         // 设置自定义请求头
    
71.         for (var key in headers) {
    
72.             conn.setRequestProperty(key, headers[key]);
    
73.         }
    
74. 
    
75.         var code = conn.getResponseCode();
    
76.         var is = (code >= 200 && code < 300) ? conn.getInputStream() : conn.getErrorStream();
    
77. 
    
78.         if (!is) {
    
79.             conn.disconnect();
    
80.             return { code: code, body: "", success: false };
    
81.         }
    
82. 
    
83.         var reader = new BufferedReader(new InputStreamReader(is, "UTF-8"));
    
84.         var sb = new java.lang.StringBuilder();
    
85.         var line;
    
86.         while ((line = reader.readLine()) != null) {
    
87.             sb.append(line);
    
88.         }
    
89.         reader.close();
    
90.         conn.disconnect();
    
91. 
    
92.         return { code: code, body: sb.toString(), success: code >= 200 && code < 300 };
    
93.     } catch (e) {
    
94.         return { code: -1, body: "", success: false, error: e.message };
    
95.     }
    
96. }
    
97. 
    
98. /**
    
99. * HTTP POST 请求
    
100. * @param {string} url - 请求地址
     
101. * @param {object} data - POST 数据对象
     
102. * @param {object} headers - 自定义请求头
     
103. * @param {number} timeout - 超时时间（毫秒）
     
104. * @returns {object} {code, body, headers, success}
     
105. */
     
106. function httpPost(url, data, headers, timeout) {
     
107.     headers = headers || {};
     
108.     timeout = timeout || 10000;
     
109. 
     
110.     try {
     
111.         var jsonStr = toJson(data);
     
112.         var bodyBytes = new java.lang.String(jsonStr).getBytes("UTF-8");
     
113. 
     
114.         var conn = new URL(url).openConnection();
     
115.         conn.setRequestMethod("POST");
     
116.         conn.setDoOutput(true);
     
117.         conn.setDoInput(true);
     
118.         conn.setConnectTimeout(timeout);
     
119.         conn.setReadTimeout(timeout);
     
120.         conn.setUseCaches(false);
     
121. 
     
122.         conn.setRequestProperty("User-Agent", "AIWROK/1.0");
     
123.         conn.setRequestProperty("Content-Type", "application/json;charset=UTF-8");
     
124.         conn.setRequestProperty("Content-Length", "" + bodyBytes.length);
     
125. 
     
126.         for (var key in headers) {
     
127.             conn.setRequestProperty(key, headers[key]);
     
128.         }
     
129. 
     
130.         var os = conn.getOutputStream();
     
131.         os.write(bodyBytes);
     
132.         os.flush();
     
133.         os.close();
     
134. 
     
135.         var code = conn.getResponseCode();
     
136.         var is = (code >= 200 && code < 300) ? conn.getInputStream() : conn.getErrorStream();
     
137. 
     
138.         if (!is) {
     
139.             conn.disconnect();
     
140.             return { code: code, body: "", success: false };
     
141.         }
     
142. 
     
143.         var reader = new BufferedReader(new InputStreamReader(is, "UTF-8"));
     
144.         var sb = new java.lang.StringBuilder();
     
145.         var line;
     
146.         while ((line = reader.readLine()) != null) {
     
147.             sb.append(line);
     
148.         }
     
149.         reader.close();
     
150.         conn.disconnect();
     
151. 
     
152.         return { code: code, body: sb.toString(), success: code >= 200 && code < 300 };
     
153.     } catch (e) {
     
154.         return { code: -1, body: "", success: false, error: e.message };
     
155.     }
     
156. }
     
157. 
     
158. /**
     
159. * 带重试的请求（自动重试失败的请求）
     
160. */
     
161. function httpGetWithRetry(url, headers, timeout, retryCount) {
     
162.     retryCount = retryCount || 3;
     
163.     for (var i = 0; i < retryCount; i++) {
     
164.         printl("[重试 " + (i + 1) + "/" + retryCount + "] GET " + url);
     
165.         var result = httpGet(url, headers, timeout);
     
166.         if (result.success) return result;
     
167.         sleep.millisecond(1000 * (i + 1)); // 递增等待
     
168.     }
     
169.     printl("[重试失败] " + url);
     
170.     return null;
     
171. }
     
172. 
     
173. // ======================== 演示 ========================
     
174. 
     
175. function demo() {
     
176.     printl("╔══════════════════════════════════════════════╗");
     
177.     printl("║     AIWROK HTTP请求完整示例 - 演示           ║");
     
178.     printl("╚══════════════════════════════════════════════╝");
     
179.     sleep.millisecond(600);
     
180. 
     
181.     // ---- 演示 1: GET 请求 ----
     
182.     printl("\n&#127760; [1/5] GET 请求");
     
183.     sleep.millisecond(400);
     
184.     printl("  请求: https://httpbin.org/get?name=AIWROK&version=1.0");
     
185.     var getStart = new Date().getTime();
     
186.     var getResult = httpGet("https://httpbin.org/get?name=AIWROK&version=1.0");
     
187.     var getCost = new Date().getTime() - getStart;
     
188.     printl("  状态码: " + getResult.code);
     
189.     sleep.millisecond(150);
     
190.     printl("  成功: " + getResult.success + "  (用时 " + getCost + "ms)");
     
191.     sleep.millisecond(150);
     
192.     if (getResult.body) {
     
193.         printl("  响应: " + getResult.body.substring(0, Math.min(180, getResult.body.length())) + "...");
     
194.     }
     
195.     sleep.millisecond(1200);
     
196. 
     
197.     // ---- 演示 2: POST 请求 ----
     
198.     printl("\n&#128228; [2/5] POST 请求");
     
199.     sleep.millisecond(400);
     
200.     var postData = { name: "AIWROK", type: "automation", version: "1.0" };
     
201.     printl("  提交数据: " + toJson(postData));
     
202.     var postStart = new Date().getTime();
     
203.     var postResult = httpPost("https://httpbin.org/post", postData);
     
204.     var postCost = new Date().getTime() - postStart;
     
205.     printl("  状态码: " + postResult.code);
     
206.     sleep.millisecond(150);
     
207.     printl("  成功: " + postResult.success + "  (用时 " + postCost + "ms)");
     
208.     sleep.millisecond(150);
     
209.     if (postResult.body) {
     
210.         printl("  响应: " + postResult.body.substring(0, Math.min(180, postResult.body.length())) + "...");
     
211.     }
     
212.     sleep.millisecond(1200);
     
213. 
     
214.     // ---- 演示 3: 带自定义请求头 ----
     
215.     printl("\n&#127991;️  [3/5] 带自定义请求头");
     
216.     sleep.millisecond(400);
     
217.     var customHeaders = { "Authorization": "Bearer test-token-12345", "X-Custom-Header": "my-custom-value" };
     
218.     printl("  请求头: Authorization + X-Custom-Header");
     
219.     var headerStart = new Date().getTime();
     
220.     var headerResult = httpGet("https://httpbin.org/headers", customHeaders);
     
221.     var headerCost = new Date().getTime() - headerStart;
     
222.     printl("  状态码: " + headerResult.code + "  (用时 " + headerCost + "ms)");
     
223.     sleep.millisecond(1200);
     
224. 
     
225.     // ---- 演示 4: 错误请求处理 ----
     
226.     printl("\n⚠️  [4/5] 错误请求处理");
     
227.     sleep.millisecond(400);
     
228.     printl("  请求一个不存在的页面...");
     
229.     var errorStart = new Date().getTime();
     
230.     var errorResult = httpGet("https://httpbin.org/status/404");
     
231.     var errorCost = new Date().getTime() - errorStart;
     
232.     printl("  状态码: " + errorResult.code);
     
233.     sleep.millisecond(150);
     
234.     printl("  成功: " + errorResult.success + "  (用时 " + errorCost + "ms)");
     
235.     sleep.millisecond(1200);
     
236. 
     
237.     // ---- 演示 5: 超时控制 ----
     
238.     printl("\n⏱️  [5/5] 超时控制 (3秒)");
     
239.     sleep.millisecond(400);
     
240.     printl("  请求会延迟 5 秒的接口，超时设置 3 秒...");
     
241.     var timeoutStart = new Date().getTime();
     
242.     var timeoutResult = httpGet("https://httpbin.org/delay/5", null, 3000);
     
243.     var timeoutCost = new Date().getTime() - timeoutStart;
     
244.     printl("  用时: " + timeoutCost + " ms");
     
245.     sleep.millisecond(150);
     
246.     if (timeoutResult && timeoutResult.success) {
     
247.         printl("  ✓ 请求成功  状态码: " + timeoutResult.code);
     
248.     } else if (timeoutResult && timeoutResult.code === -1 && timeoutCost >= 3000) {
     
249.         printl("  ⏱️ 触发超时（预期行为）  状态码: -1");
     
250.     } else {
     
251.         printl("  ✗ 请求失败  状态码: " + (timeoutResult ? timeoutResult.code : "-1"));
     
252.     }
     
253.     sleep.millisecond(600);
     
254. 
     
255.     printl("\n╔══════════════════════════════════════════════╗");
     
256.     printl("║            全部演示完成！                     ║");
     
257.     printl("╚══════════════════════════════════════════════╝");
     
258. }
     
259. 
     
260. demo();
     

复制代码

---

欢迎光临 B2B网络软件 (http://bbs.niubt.cn/)

Powered by Discuz! X3.2