注册 登录
发贴工具
自动发帖软件»群发软件 › 群发软件公告教程 › AIWORK源码分享 › 本地调试版原生websocket版
返回列表 发帖
查看: 5|回复: 0
打印 上一主题 下一主题

[24小时收录超级好的网站] 本地调试版原生websocket版

[复制链接]

2608

主题

2656

帖子

1万

积分

积分
15826
跳转到指定楼层
楼主
发帖软件 发表于 4 小时前 | 只看该作者 |只看大图 回帖奖励 |正序浏览 |阅读模式

本地调试版原生websocket版


本地调试版原生websocket版 群发软件发帖工具
本地调试版原生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. */


  16. print.log("===== WebSocket 屏幕截图传输（AIWROK 原生版）开始 =====");

  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. };

  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;

  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. }

  72. // ========== 核心：用 AIWROK 原生 5 API 建立连接 ==========
  73. function initWebSocket() {
  74.     // 重置状态
  75.     state.connected = false;
  76.     state.err = null;
  77.     state.closed = false;

  79.     // ① 创建
  80.     ws = new websocket();

  82.     // ② setSocketID
  83.     try { ws.setSocketID("screen_" + (new Date().getTime())); }
  84.     catch (e) { printl("  ⚠️  setSocketID 忽略异常: " + e.message); }

  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);

  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.     }

  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.     }

  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. }

  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);

  186.     // 先关旧连接
  187.     try { if (ws) ws.close(); } catch (e) {}
  188.     ws = null;

  190.     setTimeout(function () {
  191.         initWebSocket();
  192.     }, config.reconnectInterval);
  193. }

  195. // ========== 截图并发送 ==========
  196. function sendScreenshot() {
  197.     if (!ws || !state.connected) {
  198.         print.log("跳过截图：未连接");
  199.         return;
  200.     }
  201.     try {
  202.         print.log("&#128248; 截取屏幕...");
  203.         printl("&#128248; 截图中...");

  205.         var screenshot = screen.screenShotFull();
  206.         if (!screenshot) { printl("❌ 截图失败"); return; }

  208.         print.log("&#128260; 转 Base64...");
  209.         var base64Data = "" + screenshot.toBase64();   // 强转成 JS 字符串

  211.         var sizeChars = base64Data.length;
  212.         var sizeKB = Math.round((sizeChars * 0.75) / 1024);   // 粗略估算真实字节
  213.         printl("&#128230; 图片大小: " + sizeChars + " 字符（约 " + sizeKB + " KB）");

  215.         try { screenshot.recycle(); } catch (e) {}   // 释放 Java Bitmap 内存

  217.         state.totalSent++;
  218.         printl("&#128228; 发送图片 #" + state.totalSent + " ...");
  219.         ws.send(base64Data);
  220.         state.imgCount++;
  221.         printl("✅ 已发送图片 #" + state.totalSent + "（" + sizeKB + " KB）");

  223.     } catch (e) {
  224.         printl("❌ 发送截图出错: " + e.message);
  225.         print.log("sendScreenshot 异常: " + e.message);
  226.     }
  227. }

  229. // ========== 定时截图定时器 ==========
  230. function startScreenshotTimer() {
  231.     if (screenshotTimer) { try { clearInterval(screenshotTimer); } catch (e) {} }

  233.     print.log("启动定时截图，间隔 " + config.screenshotInterval + " 毫秒");
  234.     printl("⏰ 定时截图已启动（间隔 " + (config.screenshotInterval / 1000) + " 秒）");

  236.     // 立即发第一张
  237.     setTimeout(function () { sendScreenshot(); }, 300);

  239.     screenshotTimer = setInterval(function () {
  240.         if (state.connected) sendScreenshot();
  241.     }, config.screenshotInterval);
  242. }

  244. function stopScreenshotTimer() {
  245.     if (screenshotTimer) {
  246.         try { clearInterval(screenshotTimer); } catch (e) {}
  247.         screenshotTimer = null;
  248.         print.log("停止定时截图");
  249.     }
  250. }

  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. }

  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测试服务器");

  275.         // 启动连接（带异步重试）
  276.         initWebSocket();

  278.         // 总运行时长倒计时
  279.         print.log("运行 " + (config.runDuration / 1000) + " 秒后自动结束");
  280.         printl("⏳ 运行 " + (config.runDuration / 1000) + " 秒后自动结束");
  281.         sleep.millisecond(config.runDuration);

  283.         // 结束
  284.         disconnectWebSocket();

  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 + " 张 =====");

  293.     } catch (e) {
  294.         print.log("主程序异常: " + e.message);
  295.         printl("❌ 程序错误: " + e.message);
  296.         try { disconnectWebSocket(); } catch (e2) {}
  297.     }
  298. }

  300. main();
复制代码



AIWROK, AIWROK软件
楼主新帖
楼主热帖
unto无障碍方式双指向中间滑动放大缩小完整示例nextnocontent

相关帖子
回复

使用道具 举报

返回列表 发帖
高级模式
B Color Image Link Quote Code Smilies
您需要登录后才可以回帖 登录 | 立即注册

本版积分规则

相关导读了
    采集亚马逊正版群发工具有没有？
    Apr.20旅行X心语今天来说说YYPOST新功能的一个灵活用法，采集亚马逊商品信息，并且获得排名的软件，亚马逊现在越来越多客户做，淘宝的水是越来越清了，以前做电商的客户，现在都转战到外国，最赚钱的要数一些客户往亚马逊里堆了吧，拿我这个YYPOST的客户，最多的是采集，分析排名，刷价格，刷数量，改价，刷访问量等等技术
    企业发展B2B网站有什么东东软件可以发呢
    标题企业发展网B2B软件，现在虽然B2B网站收录不错，可愁的是心急的人们，他们太想一口吃撑胖子了，发帖宣传虽然不能像佛系那样淡定，但也不能像跑火车那般急躁对待，自己内容不收录，完全是自己操作内容问题，可以参考一下别人的内容是怎么弄的，然后自己要试着转变，而且收录这个内容，常常会变化的，不是一种规则就吃到老
    搜房天下房聊软件哪一个好呢
    本帖最后由 发帖软件 于 2019-5-22 16:15 编辑 2搜房天下群发房聊信息软件，开始本来打算做58同城的，但发一个就要一次点触验证码，这就让人没有感觉到存在的价值了吧，都是卖二手房和新房的搜房天下倒是可以发即时聊天信息，也没有发现他这个网站有啥子限制，登陆一个搜房天下账号，然后采集回来分类列表的网址，然后就一
    大家坛有没有好用的群发工具下载呢
    当你的笑容给我礼貌的招呼，大家坛全自动发帖软件，宣传推广是一场持久战，总是有一些人把软件用了一天，或是几个小时，就觉得自己付出太多了，那加进来的粉丝，或是流量，应该是和宣传多少成正比的，其实没有这么便宜的事，就像很多阅读量超过一百万的视频，或是电影，真正会在屏幕打赏的人不会超过三千，真正大额打赏给主
    群发正版软件中国塑料网
    中国塑料网群发软件YYPOST脚本下载地址，这个网站会有一个很奇怪的问题就是你在首页登陆无半个验证码，但在登陆网址登陆就会有一个验证码，所以我们灵活一些，在首页登陆就不用输入验证码了哈。网站秒收录比较高，但发的都是五金和建筑行业，先前有很多人都是发土建工程的大公司操作的，现在这个网站专为那个行业诞生的吧。
    OpenStreetMap网站正版2019年发帖工具下载
    本帖最后由 发帖软件 于 2019-5-21 11:13 编辑 OpenStreetMap网站全自动群发，OpenStreetMapOpenStreetMap（简称OSM，中文是公开地图）是一个网上地图协作计划，目标是创造一个内容自由且能让所有人编辑的世界地图。有的人编辑地图然后等收录，有的人发日志等收录，我们这里也是利用地图日志做为宣传的目标，简单的脚本理
    搜房天下全自动收短信全自动识别验证码注册账号软件
    房天下自动注册机，这个脚本是前几天发房聊的脚本廷伸品种，这个脚本能做到自动注册账号，自动保存账号，自动发房聊的效果，不过今天我们主要说一说怎么注册账号写脚本吧，这个搜房天天下的账号，可以发提问，可以发房聊，发论坛，发博客，还有发个人中心页都是有秒收的效果的，这样就省去了去买号，去乱花钱的效果了吧，而
    企业邮箱安卓端有什么APP软件可以发的呢
    请输入标题企业邮箱安卓发发送邮箱脚本，这个脚本是利用企业邮箱进行群发的，全程是一种模拟手工操作的过程，所以封号是很少的，而且企业邮箱群发到普通QQ邮箱不容易进垃圾箱中的，所以这个脚本也是这样的原理，不过最好是利用一些多开器，登陆多点的QQ邮箱账号会比较流畅一些，然后用软件一个一个的切换APP进行群发邮件会
    头条留评论软件有没有好用的呢？
    今天整一个今日头条留言软件，对于留言YYPOST是优势是比较大的存在，因为他往往专注一些下拉定位的优点，像今日头条这样，还是需要一些特殊下拉定位的，因为他新闻有长有短，有图有视频的，所以综合起来定位是比较难的，如果用POST也不是很轻松可以破解他的加密参数。这个脚本也是有一个不好的地方就是换号会比较麻烦，您电
    单网页生成神器
    最近新技术，网页生成机占领了整个网络的半壁江山，效果很疯狂，虽然不知道能持续多久，作为开发软件的领头者，一直在找收录的方法，一直在努力创新着，一直被人模仿，却从没有被超越过，这个网页生成机，已经出来有一段时间了，一直没有拿出来分享，醉过醉过，它是利用的一些小小收录漏洞整的，您最好用一些老站域名，进行
关闭
本站开发自动发帖软件是目前效果最好的发贴工具，软件可以兼容所有的论坛，进行群发贴子，可以对各大论坛自主录制操作流程，自动识别 验证码，自动注册账号，自动群发贴子，还可以设置成自动抢沙发，是推广宣传的神级软件，软件可以兼容任何IE能顶贴发贴论坛，完全可以 做成论坛发贴软件，生成脚本，对各大论坛程序完美支持的。软件不但发的贴子收录快，而且只用法简单，使用方便，价格便宜，软件客服16 小时在线全程协助，为您的宣传保驾护航。用最少的投资，实现最大的收益，用最简单的方式，完全最复杂的操作。 QQ

Copyright © 2014 ( 京ICP备09078825号 )

Powered by Discuz! X3.2

群发软件发帖工具
快速回复 返回列表 返回顶部
本站自动发贴软件，是现在最流行的做脚本软件，这种发贴工具，不但发贴收录快，而且抢占好的先机，完全自由编辑，实现针对性群发模拟操作，软件可以顶贴，也可以发贴，可以兼容支持Discuz、PHPWind、Dvbbs三大主流论坛，有手机验证码收件，邮件收发的功能，支持验证码识别，注册问题识别，多线程任务，自动上传头像，自动激活注册邮件，兼容防注册插件，本站软件原创正版，更新效率最快的原创软件。 『网络推广软件』『自动发帖软件』『 自动发帖』