AIWROKÈí¼þJSONÇëÇóÍêÕûʾÀý

YYPOSTȺ·¢Èí¼þ

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("¨X¨T¨T¨T¨T¨T¨T¨T¨T¨T¨T¨T¨T¨T¨T¨T¨T¨T¨T¨T¨T¨T¨T¨T¨T¨T¨T¨T¨T¨T¨T¨T¨T¨T¨T¨T¨T¨T¨T¨T¨T¨T¨T¨T¨T¨T¨T¨[");
     
177.     printl("¨U     AIWROK HTTPÇëÇóÍêÕûʾÀý - ÑÝʾ           ¨U");
     
178.     printl("¨^¨T¨T¨T¨T¨T¨T¨T¨T¨T¨T¨T¨T¨T¨T¨T¨T¨T¨T¨T¨T¨T¨T¨T¨T¨T¨T¨T¨T¨T¨T¨T¨T¨T¨T¨T¨T¨T¨T¨T¨T¨T¨T¨T¨T¨T¨T¨a");
     
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¨X¨T¨T¨T¨T¨T¨T¨T¨T¨T¨T¨T¨T¨T¨T¨T¨T¨T¨T¨T¨T¨T¨T¨T¨T¨T¨T¨T¨T¨T¨T¨T¨T¨T¨T¨T¨T¨T¨T¨T¨T¨T¨T¨T¨T¨T¨T¨[");
     
256.     printl("¨U            È«²¿ÑÝʾÍê³É£¡                     ¨U");
     
257.     printl("¨^¨T¨T¨T¨T¨T¨T¨T¨T¨T¨T¨T¨T¨T¨T¨T¨T¨T¨T¨T¨T¨T¨T¨T¨T¨T¨T¨T¨T¨T¨T¨T¨T¨T¨T¨T¨T¨T¨T¨T¨T¨T¨T¨T¨T¨T¨T¨a");
     
258. }
     
259. 
     
260. demo();
     

¸´ÖÆ´úÂë