B2B网络软件

标题: 本地调试版原生websocket版 [打印本页]

---

作者: YYPOST群发软件    时间: 2 小时前
标题: 本地调试版原生websocket版
本地调试版原生websocket版

1. /**
   
2. * WebSocket 屏幕截图传输 - 本地调试版（AIWROK 原生 websocket 版）
   
3. *
   
4. * 👉 参考 AIWROK IDE 文档，5 个原生 API 正确签名：
   
5. *    void setSocketID(String arg0)
   
6. *    void event(Function arg0=连接成功, Function arg1=接收消息,
   
7. *               Function arg2=连接失败, Function arg3=断开连接)
   
8. *    void connet(String wsUrl)      ← 注意拼写：connet（双n少c，不是 connect）
   
9. *    void send(Object msg)
   
10. *    void close()
    
11. *
    
12. * 配合 WebSocket测试服务器 使用
    
13. */
    
14. 
    
15. 
    
16. print.log("===== WebSocket 屏幕截图传输（AIWROK 原生版）开始 =====");
    
17. 
    
18. // ========== 配置 ==========
    
19. var config = {
    
20.     serverUrl: "192.168.10.103:8886",   // ← 改成 PC 的局域网 IP:端口
    
21.     screenshotInterval: 5000,            // 截图间隔（毫秒）
    
22.     reconnectInterval: 2500,             // 重连间隔（毫秒）
    
23.     maxReconnectAttempts: 10,            // 最大重连次数
    
24.     connectWaitSec: 15,                  // 单次连接等待秒数
    
25.     runDuration: 30000                   // 总运行时长（毫秒）
    
26. };
    
27. 
    
28. // ========== 连接状态 ==========
    
29. var ws = null;          // websocket 实例
    
30. var state = {
    
31.     connected: false,
    
32.     err: null,
    
33.     closed: false,
    
34.     saveDir: "",
    
35.     saveUrlPrefix: "",
    
36.     imgCount: 0,
    
37.     reconnectAttempts: 0,
    
38.     totalSent: 0
    
39. };
    
40. var screenshotTimer = null;
    
41. 
    
42. // ========== 服务器消息解析 ==========
    
43. function parseServerMessage(raw) {
    
44.     if (typeof raw !== "string") {
    
45.         try { raw = String(raw); } catch (e) { raw = "" + raw; }
    
46.     }
    
47.     var out = { type: "UNKNOWN", raw: raw };
    
48.     if (raw.indexOf("WELCOME|") === 0) {
    
49.         out.type = "WELCOME";
    
50.         var parts = raw.split("|");
    
51.         out.id = parts[1] || "";
    
52.         for (var i = 2; i < parts.length; i++) {
    
53.             var eqIdx = parts[i].indexOf("=");
    
54.             if (eqIdx > 0) out[parts[i].substring(0, eqIdx)] = parts[i].substring(eqIdx + 1);
    
55.         }
    
56.     } else if (raw.indexOf("IMG_SAVED|") === 0) {
    
57.         out.type = "IMG_SAVED";
    
58.         var p = raw.split("|");
    
59.         out.seq = p[1] || "";
    
60.         out.sizeTxt = p[2] || "";
    
61.         out.absPath = p[3] || "";
    
62.         out.fileUrl = p[4] || "";
    
63.     } else if (raw.indexOf("IMG_FAIL|") === 0) {
    
64.         out.type = "IMG_FAIL";
    
65.     } else if (raw.indexOf("ECHO|") === 0) {
    
66.         out.type = "ECHO";
    
67.         out.text = raw.substring("ECHO|".length);
    
68.     }
    
69.     return out;
    
70. }
    
71. 
    
72. // ========== 核心：用 AIWROK 原生 5 API 建立连接 ==========
    
73. function initWebSocket() {
    
74.     // 重置状态
    
75.     state.connected = false;
    
76.     state.err = null;
    
77.     state.closed = false;
    
78. 
    
79.     // ① 创建
    
80.     ws = new websocket();
    
81. 
    
82.     // ② setSocketID
    
83.     try { ws.setSocketID("screen_" + (new Date().getTime())); }
    
84.     catch (e) { printl("  ⚠️  setSocketID 忽略异常: " + e.message); }
    
85. 
    
86.     // ③ event(4 个位置回调，顺序不能错！)
    
87.     //   arg0 = 连接成功   arg1 = 接收消息   arg2 = 连接失败   arg3 = 断开
    
88.     try {
    
89.         ws.event(
    
90.             function () {                              // arg0 连接成功
    
91.                 state.connected = true;
    
92.                 state.err = null;
    
93.                 state.reconnectAttempts = 0;
    
94.                 print.log("WS: onopen");
    
95.                 printl("✅ 连接成功（onopen）");
    
96.                 startScreenshotTimer();
    
97.             },
    
98.             function (msg) {                           // arg1 接收消息
    
99.                 var raw;
    
100.                 try { raw = String(msg); } catch (e) { raw = ""; }
     
101.                 print.log("WS: onmessage len=" + raw.length);
     
102.                 var parsed = parseServerMessage(raw);
     
103. 
     
104.                 if (parsed.type === "WELCOME") {
     
105.                     state.saveDir = parsed.save_dir || "";
     
106.                     state.saveUrlPrefix = parsed.save_file_url || "";
     
107.                     printl("&#128233; WELCOME " + parsed.id);
     
108.                     if (state.saveDir) {
     
109.                         printl("&#128193; 保存目录: " + state.saveDir);
     
110.                         printl("&#128279; 目录URL: " + state.saveUrlPrefix);
     
111.                     }
     
112.                 } else if (parsed.type === "IMG_SAVED") {
     
113.                     printl("&#128190; PC 已保存图片 " + parsed.seq);
     
114.                     printl("    大小: " + parsed.sizeTxt);
     
115.                     printl("    路径: " + parsed.absPath);
     
116.                     printl("    � " + parsed.fileUrl);
     
117.                 } else if (parsed.type === "IMG_FAIL") {
     
118.                     printl("&#128308; 服务器保存失败: " + raw);
     
119.                 } else if (parsed.type === "ECHO") {
     
120.                     printl("&#128233; 回显: " + parsed.text.substring(0, 150));
     
121.                 } else {
     
122.                     printl("&#128233; 收到: " + raw.substring(0, 200) + (raw.length > 200 ? "..." : ""));
     
123.                 }
     
124.             },
     
125.             function (err) {                           // arg2 连接失败
     
126.                 var msg = "";
     
127.                 try { msg = String(err); } catch (e) {}
     
128.                 state.err = msg || "连接失败";
     
129.                 state.connected = false;
     
130.                 print.log("WS: onerror " + msg);
     
131.                 printl("❌ 连接失败（onerror）: " + msg);
     
132.                 stopScreenshotTimer();
     
133.                 reconnectWebSocket();
     
134.             },
     
135.             function () {                              // arg3 断开
     
136.                 state.closed = true;
     
137.                 state.connected = false;
     
138.                 print.log("WS: onclose");
     
139.                 printl("⚪ 连接断开（onclose）");
     
140.                 stopScreenshotTimer();
     
141.                 reconnectWebSocket();
     
142.             }
     
143.         );
     
144.     } catch (e) {
     
145.         printl("❌ event(4回调) 注册失败: " + e.message);
     
146.         reconnectWebSocket();
     
147.         return;
     
148.     }
     
149. 
     
150.     // ④ connet（双 n 少 c，千万别写成 connect）
     
151.     try {
     
152.         var url = "ws://" + config.serverUrl;
     
153.         printl("正在连接: " + url + "（" + config.connectWaitSec + " 秒超时）");
     
154.         print.log("调用 connet(" + url + ")");
     
155.         ws.connet(url);
     
156.     } catch (e) {
     
157.         printl("❌ connet 抛异常: " + e.message);
     
158.         state.err = e.message;
     
159.         reconnectWebSocket();
     
160.         return;
     
161.     }
     
162. 
     
163.     // 同步等待：如果在 connectWaitSec 秒内既没触发 onopen 也没 onerror，就当作失败
     
164.     var waited = 0;
     
165.     while (!state.connected && !state.err && waited < config.connectWaitSec * 1000) {
     
166.         sleep.millisecond(100);
     
167.         waited += 100;
     
168.     }
     
169.     if (!state.connected && !state.err) {
     
170.         state.err = "连接超时（" + config.connectWaitSec + " 秒内没有 onopen/onerror）";
     
171.         printl("❌ " + state.err);
     
172.         reconnectWebSocket();
     
173.     }
     
174. }
     
175. 
     
176. // ========== 断线重连 ==========
     
177. function reconnectWebSocket() {
     
178.     if (state.reconnectAttempts >= config.maxReconnectAttempts) {
     
179.         printl("&#128721; 已达到最大重连次数 " + config.maxReconnectAttempts + "，停止重连");
     
180.         return;
     
181.     }
     
182.     state.reconnectAttempts++;
     
183.     printl("⏱️  重连 " + state.reconnectAttempts + "/" + config.maxReconnectAttempts + "，" + (config.reconnectInterval / 1000) + " 秒后重试...");
     
184.     printl("重连 " + state.reconnectAttempts + "/" + config.maxReconnectAttempts);
     
185. 
     
186.     // 先关旧连接
     
187.     try { if (ws) ws.close(); } catch (e) {}
     
188.     ws = null;
     
189. 
     
190.     setTimeout(function () {
     
191.         initWebSocket();
     
192.     }, config.reconnectInterval);
     
193. }
     
194. 
     
195. // ========== 截图并发送 ==========
     
196. function sendScreenshot() {
     
197.     if (!ws || !state.connected) {
     
198.         print.log("跳过截图：未连接");
     
199.         return;
     
200.     }
     
201.     try {
     
202.         print.log("&#128248; 截取屏幕...");
     
203.         printl("&#128248; 截图中...");
     
204. 
     
205.         var screenshot = screen.screenShotFull();
     
206.         if (!screenshot) { printl("❌ 截图失败"); return; }
     
207. 
     
208.         print.log("&#128260; 转 Base64...");
     
209.         var base64Data = "" + screenshot.toBase64();   // 强转成 JS 字符串
     
210. 
     
211.         var sizeChars = base64Data.length;
     
212.         var sizeKB = Math.round((sizeChars * 0.75) / 1024);   // 粗略估算真实字节
     
213.         printl("&#128230; 图片大小: " + sizeChars + " 字符（约 " + sizeKB + " KB）");
     
214. 
     
215.         try { screenshot.recycle(); } catch (e) {}   // 释放 Java Bitmap 内存
     
216. 
     
217.         state.totalSent++;
     
218.         printl("&#128228; 发送图片 #" + state.totalSent + " ...");
     
219.         ws.send(base64Data);
     
220.         state.imgCount++;
     
221.         printl("✅ 已发送图片 #" + state.totalSent + "（" + sizeKB + " KB）");
     
222. 
     
223.     } catch (e) {
     
224.         printl("❌ 发送截图出错: " + e.message);
     
225.         print.log("sendScreenshot 异常: " + e.message);
     
226.     }
     
227. }
     
228. 
     
229. // ========== 定时截图定时器 ==========
     
230. function startScreenshotTimer() {
     
231.     if (screenshotTimer) { try { clearInterval(screenshotTimer); } catch (e) {} }
     
232. 
     
233.     print.log("启动定时截图，间隔 " + config.screenshotInterval + " 毫秒");
     
234.     printl("⏰ 定时截图已启动（间隔 " + (config.screenshotInterval / 1000) + " 秒）");
     
235. 
     
236.     // 立即发第一张
     
237.     setTimeout(function () { sendScreenshot(); }, 300);
     
238. 
     
239.     screenshotTimer = setInterval(function () {
     
240.         if (state.connected) sendScreenshot();
     
241.     }, config.screenshotInterval);
     
242. }
     
243. 
     
244. function stopScreenshotTimer() {
     
245.     if (screenshotTimer) {
     
246.         try { clearInterval(screenshotTimer); } catch (e) {}
     
247.         screenshotTimer = null;
     
248.         print.log("停止定时截图");
     
249.     }
     
250. }
     
251. 
     
252. // ========== 关闭连接 ==========
     
253. function disconnectWebSocket() {
     
254.     stopScreenshotTimer();
     
255.     if (ws) {
     
256.         try { ws.close(); } catch (e) {}
     
257.         ws = null;
     
258.     }
     
259.     state.connected = false;
     
260.     state.closed = true;
     
261.     printl("&#128268; 已关闭连接");
     
262. }
     
263. 
     
264. // ========== 主程序入口 ==========
     
265. function main() {
     
266.     try {
     
267.         printl("========================================");
     
268.         printl("  WebSocket 屏幕截图传输 - 原生版");
     
269.         printl("  服务器: " + config.serverUrl);
     
270.         printl("  总运行: " + (config.runDuration / 1000) + " 秒    截图间隔: " + (config.screenshotInterval / 1000) + " 秒");
     
271.         printl("  连接API: setSocketID → event(4回调) → connet → send → close");
     
272.         printl("========================================");
     
273.         printl("ℹ️ 确保 PC 已运行: python WebSocket测试服务器");
     
274. 
     
275.         // 启动连接（带异步重试）
     
276.         initWebSocket();
     
277. 
     
278.         // 总运行时长倒计时
     
279.         print.log("运行 " + (config.runDuration / 1000) + " 秒后自动结束");
     
280.         printl("⏳ 运行 " + (config.runDuration / 1000) + " 秒后自动结束");
     
281.         sleep.millisecond(config.runDuration);
     
282. 
     
283.         // 结束
     
284.         disconnectWebSocket();
     
285. 
     
286.         printl("");
     
287.         printl("===== 执行结束 =====");
     
288.         printl("  尝试发送: " + state.totalSent + " 张");
     
289.         printl("  计数显示: " + state.imgCount + " 张");
     
290.         if (state.saveDir) printl("  PC 保存目录: " + state.saveDir);
     
291.         print.log("===== 屏幕截图传输结束，发送 " + state.totalSent + " 张 =====");
     
292. 
     
293.     } catch (e) {
     
294.         print.log("主程序异常: " + e.message);
     
295.         printl("❌ 程序错误: " + e.message);
     
296.         try { disconnectWebSocket(); } catch (e2) {}
     
297.     }
     
298. }
     
299. 
     
300. main();
     

复制代码

---

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

Powered by Discuz! X3.2