B2B网络软件

标题: websocket远程停止手机接收器 [打印本页]

---

作者: YYPOST群发软件    时间: 1 小时前
标题: websocket远程停止手机接收器
websocket远程停止手机接收器


https://www.yuque.com/aiwork/nba2pr/htyaws99kck2ztr8

1. // ============================================================================
   
2. // 接入示例 - 你的业务脚本如何接入「远程停止接收器」
   
3. // ============================================================================
   
4. // 【AIWROK 加载明文 JS 的正确方式】
   
5. //   - Import("xxx.js")  ← 只能加载加密后的 JS，明文不行！
   
6. //   - thread.runJsFile("xxx.js", "线程名")  ← 可以加载明文 JS（推荐）
   
7. //
   
8. // 所以接入只需 3 行：
   
9. //   var stopThread = new thread();
   
10. //   stopThread.runJsFile("远程停止接收器.js", "stop_receiver");
    
11. //
    
12. // 子线程独立上下文，不影响主脚本业务
    
13. // 收到电脑端 STOP_ALL 指令时，子线程调用 runTime.stopAllRuning()
    
14. // 会停止所有子线程（包括它自己）和主脚本
    
15. // ============================================================================
    
16. 
    
17. // === 启动远程停止接收器（子线程）===
    
18. var stopThread = new thread();
    
19. stopThread.runJsFile("远程停止接收器.js", "stop_receiver");
    
20. 
    
21. // === 以下是你自己的业务代码（示例）===
    
22. 
    
23. printl("=== 我的业务脚本启动 ===");
    
24. 
    
25. // 模拟一个长时间运行的任务
    
26. var counter = 0;
    
27. while (true) {
    
28.     counter++;
    
29.     printl("业务执行中... 第" + counter + "次");
    
30. 
    
31.     try { sleep.second(2); } catch (e) { break; }
    
32. 
    
33.     // 演示：跑10次后自己结束（实际不需要，电脑发 STOP_ALL 指令就会全停）
    
34.     if (counter >= 10) {
    
35.         printl("业务完成");
    
36.         break;
    
37.     }
    
38. }
    
39. 
    
40. printl("=== 业务脚本结束 ===");
    
41. 
    
42. // ============================================================================
    
43. // 工作流程：
    
44. //   1. 主脚本启动 → 创建子线程 stop_receiver（连接电脑服务器）
    
45. //   2. 主脚本继续跑业务
    
46. //   3. 电脑端点「一键全停」→ 广播 STOP_ALL
    
47. //   4. 子线程收到 → runTime.stopAllRuning() → 主脚本 + 所有子线程全停
    
48. // ============================================================================
    

复制代码

1. // ============================================================================
   
2. // 远程停止接收器 v5 - 按已验证可用的 WebSocket 模式重写
   
3. // ============================================================================
   
4. // 【加载方式】在主脚本开头加 3 行：
   
5. //   var stopThread = new thread();
   
6. //   stopThread.runJsFile("远程停止接收器.js", "stop_receiver");
   
7. //
   
8. // 配置：改下方 SERVER_IP 为你电脑的局域网 IP
   
9. // ============================================================================
   
10. 
    
11. var CONFIG = {
    
12.     SERVER_IP: "192.168.10.103",
    
13.     SERVER_PORT: "8886",
    
14.     WS_PATH: "/",
    
15.     DEVICE_NAME: "",
    
16.     PING_MS: 25000,
    
17.     RECONNECT_BASE_MS: 2000
    
18. };
    
19. 
    
20. // ============================================================================
    
21. // 全局状态
    
22. // ============================================================================
    
23. var G = {
    
24.     ws: null,
    
25.     connected: false,
    
26.     deviceName: "",
    
27.     lastPongAt: 0,
    
28.     heartbeatTimer: null,
    
29.     retryCount: 0,
    
30.     running: true
    
31. };
    
32. 
    
33. function LOG(tag, msg) {
    
34.     printl("[停止接收器][" + tag + "] " + msg);
    
35. }
    
36. 
    
37. function getDeviceName() {
    
38.     if (CONFIG.DEVICE_NAME) return CONFIG.DEVICE_NAME;
    
39.     try { return device.getBrand() + "_" + device.getModel(); }
    
40.     catch (e) { return "phone_" + new Date().getTime(); }
    
41. }
    
42. 
    
43. function sendMsg(type, data) {
    
44.     if (!G.ws || !G.connected) return false;
    
45.     try {
    
46.         var obj = { type: type, ts: new Date().getTime(), data: data || {} };
    
47.         G.ws.send(JSON.stringify(obj));
    
48.         return true;
    
49.     } catch (e) {
    
50.         LOG("ERROR", "send 异常: " + e);
    
51.         return false;
    
52.     }
    
53. }
    
54. 
    
55. // ============================================================================
    
56. // 心跳（runTime.setTimeout 递归，与已验证代码一致）
    
57. // ============================================================================
    
58. function startHeartbeat() {
    
59.     stopHeartbeat();
    
60.     G.lastPongAt = new Date().getTime();
    
61.     function tick() {
    
62.         if (!G.connected) return;
    
63.         var now = new Date().getTime();
    
64.         if (now - G.lastPongAt > CONFIG.PING_MS + 10000) {
    
65.             LOG("WARN", "心跳超时，主动断开");
    
66.             try { G.ws.close(); } catch (e) {}
    
67.             return;
    
68.         }
    
69.         sendMsg("PING", { t: now });
    
70.         G.heartbeatTimer = runTime.setTimeout(tick, CONFIG.PING_MS);
    
71.     }
    
72.     G.heartbeatTimer = runTime.setTimeout(tick, CONFIG.PING_MS);
    
73. }
    
74. 
    
75. function stopHeartbeat() {
    
76.     if (G.heartbeatTimer) {
    
77.         try { runTime.stopTimeout(G.heartbeatTimer); } catch (e) {}
    
78.         G.heartbeatTimer = null;
    
79.     }
    
80. }
    
81. 
    
82. // ============================================================================
    
83. // 连接核心（完全照搬已验证的 WebSocket手机端常用实例.js 模式）
    
84. // ============================================================================
    
85. function doConnect() {
    
86.     G.connected = false;
    
87. 
    
88.     G.deviceName = getDeviceName();
    
89.     var url = "ws://" + CONFIG.SERVER_IP + ":" + CONFIG.SERVER_PORT + CONFIG.WS_PATH;
    
90.     LOG("INFO", "连接 " + url + " 设备=" + G.deviceName);
    
91. 
    
92.     var ws = new websocket();
    
93.     G.ws = ws;
    
94. 
    
95.     try { ws.setSocketID("stop_" + new Date().getTime()); } catch (e) {}
    
96. 
    
97.     // 定义四个回调
    
98.     var _onOpen = function () {
    
99.         LOG("OK", "onopen 触发！连接成功");
    
100.         G.connected = true;
     
101.         G.retryCount = 0;
     
102.         G.lastPongAt = new Date().getTime();
     
103.         // 上报设备信息
     
104.         sendMsg("REGISTER", { device: G.deviceName });
     
105.         startHeartbeat();
     
106.     };
     
107. 
     
108.     var _onMsg = function (msg) {
     
109.         try {
     
110.             var raw = "";
     
111.             try { raw = String(msg); } catch (e) { raw = "" + msg; }
     
112.             var obj = null;
     
113.             try { obj = JSON.parse(raw); } catch (e) { return; }
     
114. 
     
115.             var cmd = obj.cmd || "";
     
116.             var type = obj.type || "";
     
117. 
     
118.             if (cmd === "STOP_ALL") {
     
119.                 LOG("WARN", ">>> 收到全停指令! <<<");
     
120.                 _stopEverything();
     
121.                 return;
     
122.             }
     
123.             if (type === "PING" || cmd === "PING") {
     
124.                 sendMsg("PONG", { ts: new Date().getTime() });
     
125.                 return;
     
126.             }
     
127.             if (type === "PONG") {
     
128.                 G.lastPongAt = new Date().getTime();
     
129.                 return;
     
130.             }
     
131.         } catch (e) {
     
132.             LOG("ERROR", "处理消息异常: " + e);
     
133.         }
     
134.     };
     
135. 
     
136.     var _onErr = function (err) {
     
137.         var m = "";
     
138.         try { m = String(err); } catch (e) {}
     
139.         LOG("WARN", "onerror: " + (m || "无详情"));
     
140.         G.connected = false;
     
141.         stopHeartbeat();
     
142.     };
     
143. 
     
144.     var _onClose = function () {
     
145.         LOG("INFO", "onclose：连接断开");
     
146.         G.connected = false;
     
147.         stopHeartbeat();
     
148.     };
     
149. 
     
150.     // ① 优先尝试属性赋值（官方示例 websocket.js 用的方式）
     
151.     try {
     
152.         ws.onopen    = _onOpen;
     
153.         ws.onmessage = _onMsg;
     
154.         ws.onerror   = _onErr;
     
155.         ws.onclose   = _onClose;
     
156.         LOG("INFO", "回调注册: 属性赋值");
     
157.     } catch (eProp) {
     
158.         LOG("WARN", "属性赋值失败: " + eProp + "，尝试 event()");
     
159.         // ② 回退 event(4参数)
     
160.         try {
     
161.             ws.event(_onOpen, _onMsg, _onErr, _onClose);
     
162.             LOG("INFO", "回调注册: ws.event(4参数)");
     
163.         } catch (eEvt) {
     
164.             LOG("ERROR", "两种方式都失败: " + eEvt);
     
165.             return false;
     
166.         }
     
167.     }
     
168. 
     
169.     // 发起连接
     
170.     try {
     
171.         LOG("INFO", "调用 connet('" + url + "')...");
     
172.         ws.connet(url);
     
173.     } catch (e1) {
     
174.         try {
     
175.             LOG("WARN", "connet 抛异常: " + e1 + "，尝试 connect()");
     
176.             ws.connect(url);
     
177.         } catch (e2) {
     
178.             LOG("ERROR", "connet/connect 均失败: " + e1 + " / " + e2);
     
179.             return false;
     
180.         }
     
181.     }
     
182. 
     
183.     // 等待 onopen（最多 15 秒）
     
184.     var waitCount = 0;
     
185.     while (!G.connected && waitCount < 150) {
     
186.         sleep.millisecond(100);
     
187.         waitCount++;
     
188.     }
     
189. 
     
190.     if (G.connected) {
     
191.         LOG("OK", "已连接 服务器=" + CONFIG.SERVER_IP + ":" + CONFIG.SERVER_PORT);
     
192.     } else {
     
193.         LOG("WARN", "15 秒内 onopen 未触发");
     
194.     }
     
195. 
     
196.     return G.connected;
     
197. }
     
198. 
     
199. // ============================================================================
     
200. // 主循环：连接 → 等待断开 → 重连
     
201. // ============================================================================
     
202. function mainLoop() {
     
203.     while (G.running) {
     
204.         G.retryCount++;
     
205.         if (G.retryCount > 999) {
     
206.             LOG("ERROR", "已达最大重连次数");
     
207.             break;
     
208.         }
     
209. 
     
210.         var ok = doConnect();
     
211.         if (!ok) {
     
212.             var waitMs = CONFIG.RECONNECT_BASE_MS * Math.min(Math.pow(2, G.retryCount - 1), 5);
     
213.             waitMs = waitMs + Math.floor(Math.random() * 1000);
     
214.             LOG("WARN", (waitMs / 1000).toFixed(1) + "s 后重连 (第" + G.retryCount + "次)");
     
215.             try { G.ws.close(); } catch (e) {}
     
216.             sleep.millisecond(waitMs);
     
217.             continue;
     
218.         }
     
219. 
     
220.         // 已连接：等待断开
     
221.         while (G.running && G.connected) {
     
222.             sleep.millisecond(500);
     
223.         }
     
224.         if (!G.running) break;
     
225. 
     
226.         // 断线了
     
227.         var waitMs2 = CONFIG.RECONNECT_BASE_MS * Math.min(Math.pow(2, G.retryCount - 1), 5);
     
228.         waitMs2 = waitMs2 + Math.floor(Math.random() * 1000);
     
229.         LOG("WARN", "断线 " + (waitMs2 / 1000).toFixed(1) + "s 后重连");
     
230.         try { G.ws.close(); } catch (e) {}
     
231.         sleep.millisecond(waitMs2);
     
232.     }
     
233. 
     
234.     stopHeartbeat();
     
235.     try { G.ws.close(); } catch (e) {}
     
236.     LOG("INFO", "接收器结束");
     
237. }
     
238. 
     
239. // ============================================================================
     
240. // 全停
     
241. // ============================================================================
     
242. function _stopEverything() {
     
243.     LOG("WARN", ">>> 执行全停 <<<");
     
244.     G.running = false;
     
245.     try { runTime.stopAllRuning(); } catch (e) {}
     
246.     try { app.stopScript(); } catch (e) {}
     
247.     try { exit(); } catch (e) {}
     
248. }
     
249. 
     
250. // ============================================================================
     
251. // 启动
     
252. // ============================================================================
     
253. LOG("INFO", "远程停止接收器 v5 启动");
     
254. mainLoop();
     
255. LOG("INFO", "启动完成");
     

复制代码

---

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

Powered by Discuz! X3.2