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

[24小时收录超级好的网站] WebSocket调试okhttp版

[复制链接]

2605

主题

2653

帖子

1万

积分

积分
15806
跳转到指定楼层
楼主
发帖软件 发表于 昨天 06:52 | 只看该作者 |只看大图 回帖奖励 |倒序浏览 |阅读模式
WebSocket调试okhttp版
WebSocket调试okhttp版 群发软件发帖工具
  1. /**
  2. * WebSocket 屏幕截图传输 - 本地调试版（okhttp3 版）
  3. *
  4. * 配套 WebSocket测试服务器.py 使用
  5. *
  6. * 使用方法：
  7. *   
  8. *    确认下面 serverUrl 里的 IP 是 PC 的局域网 IP
  9. *  手机和 PC 在同一 WiFi 局域网
  10. *  AIWROK 里运行本脚本
  11. *
  12. * 本次使用 okhttp3 的 WebSocketListener（非 AIWROK 原生 websocket 对象）
  13. * 已在 AIWROK v3.7.81 实际跑通
  14. */

  16. // ========== 导入 okhttp3（AIWROK 自带这些 Java 类） ==========
  17. importClass(Packages.okhttp3.OkHttpClient);
  18. importClass(Packages.okhttp3.Request);
  19. importClass(Packages.okhttp3.WebSocketListener);
  20. importClass(Packages.java.util.concurrent.TimeUnit);



  24. print.log("===== WebSocket 屏幕截图传输（okhttp3 版）开始 =====");

  26. // ========== 配置 ==========
  27. var config = {
  28.     serverUrl: "192.168.10.107:8886",   // ← 改成 PC 局域网 IP:端口
  29.     screenshotInterval: 5000,            // 截图间隔（毫秒）
  30.     reconnectInterval: 2500,              // 断线重试间隔（毫秒）
  31.     maxReconnectAttempts: 12,             // 最多重试次数
  32.     connectTimeoutSec: 15,                // 握手超时（秒）
  33.     readTimeoutSec: 30,                   // 读超时（秒）
  34.     runDuration: 30000                    // 脚本总运行时长（毫秒）
  35. };

  37. // ========== 全局状态 ==========
  38. var okHttpClient = null;     // OkHttpClient
  39. var webSocket = null;        // 当前 WebSocket 对象
  40. var timer = null;            // 定时器
  41. var state = {
  42.     connected: false,        // 是否已连接
  43.     err: null,              // 最近错误
  44.     closeReason: null,      // 关闭原因
  45.     reconnectCount: 0,       // 已重连次数
  46.     saveDir: "",            // 由服务器 WELCOME 带出
  47.     saveUrlPrefix: "",      // file:/// 前缀
  48.     totalSent: 0,           // 已尝试发送的图片数
  49.     totalConfirmed: 0       // 服务器确认收到的图片数
  50. };

  52. // ========== 工具：解析服务器结构化消息 ==========
  53. function parseServerMessage(rawStr) {
  54.     if (typeof rawStr !== "string") { try { rawStr = String(rawStr); } catch (e) { rawStr = "" + rawStr; } }
  55.     var result = { type: "UNKNOWN", raw: rawStr };
  56.     if (rawStr.indexOf("WELCOME|") === 0) {
  57.         result.type = "WELCOME";
  58.         var parts = rawStr.split("|");
  59.         result.id = parts[1] || "";
  60.         for (var i = 2; i < parts.length; i++) {
  61.             var idx = parts[i].indexOf("=");
  62.             if (idx > 0) result[parts[i].substring(0, idx)] = parts[i].substring(idx + 1);
  63.         }
  64.     } else if (rawStr.indexOf("IMG_SAVED|") === 0) {
  65.         result.type = "IMG_SAVED";
  66.         var p = rawStr.split("|");
  67.         result.seq = p[1] || "";
  68.         result.sizeTxt = p[2] || "";
  69.         result.absPath = p[3] || "";
  70.         result.fileUrl = p[4] || "";
  71.     } else if (rawStr.indexOf("IMG_FAIL|") === 0) {
  72.         result.type = "IMG_FAIL";
  73.     } else if (rawStr.indexOf("ECHO|") === 0) {
  74.         result.type = "ECHO";
  75.         result.text = rawStr.substring("ECHO|".length);
  76.     }
  77.     return result;
  78. }

  80. // ========== 释放资源（每次重连前清理旧 client） ==========
  81. function shutdownClient() {
  82.     if (webSocket) {
  83.         try { webSocket.close(1000, "shutdown"); } catch (e) {}
  84.         webSocket = null;
  85.     }
  86.     if (okHttpClient) {
  87.         try { okHttpClient.dispatcher().executorService().shutdownNow(); } catch (e) {}
  88.         okHttpClient = null;
  89.     }
  90. }

  92. // ========== 建立连接（okhttp3 方案） ==========
  93. function connect() {
  94.     // 先清旧资源
  95.     shutdownClient();

  97.     state.connected = false;
  98.     state.err = null;

  100.     // 构造新 OkHttpClient
  101.     okHttpClient = new OkHttpClient.Builder()
  102.         .pingInterval(10, TimeUnit.SECONDS)
  103.         .connectTimeout(config.connectTimeoutSec, TimeUnit.SECONDS)
  104.         .readTimeout(config.readTimeoutSec, TimeUnit.SECONDS)
  105.         .build();

  107.     // 构造 listener
  108.     var listener = new WebSocketListener({
  109.         onOpen: function (wsObj, response) {
  110.             state.connected = true;
  111.             state.err = null;
  112.             state.reconnectCount = 0;
  113.             print.log("WS: onOpen");
  114.             printl("✅ 连接成功（onOpen）");
  115.             startScreenshotLoop();
  116.         },
  117.         onMessage: function (wsObj, message) {
  118.             var raw;
  119.             try { raw = String(message); } catch (e) { raw = ""; }
  120.             print.log("WS: onMessage len=" + raw.length);

  122.             var parsed = parseServerMessage(raw);

  124.             if (parsed.type === "WELCOME") {
  125.                 state.saveDir = parsed.save_dir || "";
  126.                 state.saveUrlPrefix = parsed.save_file_url || "";
  127.                 printl("&#128233; WELCOME 客户端" + parsed.id);
  128.                 if (state.saveDir) {
  129.                     printl("&#128193; 保存目录: " + state.saveDir);
  130.                     printl("&#128279; 目录URL: " + state.saveUrlPrefix);
  131.                 }
  132.             } else if (parsed.type === "IMG_SAVED") {
  133.                 state.totalConfirmed++;
  134.                 printl("&#128190; 服务器已保存图片 " + parsed.seq);
  135.                 printl("    大小: " + parsed.sizeTxt);
  136.                 printl("    路径: " + parsed.absPath);
  137.                 printl("    &#128279; " + parsed.fileUrl);
  138.             } else if (parsed.type === "IMG_FAIL") {
  139.                 printl("&#128308; 服务器保存图片失败: " + parsed.raw);
  140.             } else if (parsed.type === "ECHO") {
  141.                 printl("&#128233; 回显: " + parsed.text.substring(0, 150));
  142.             } else {
  143.                 // 未知格式（旧版服务器返回）
  144.                 printl("&#128233; 收到: " + raw.substring(0, 200) + (raw.length > 200 ? "..." : ""));
  145.             }
  146.         },
  147.         onClosed: function (wsObj, code, reason) {
  148.             state.connected = false;
  149.             state.closeReason = reason || "closed";
  150.             print.log("WS: onClosed code=" + code + " reason=" + reason);
  151.             printl("&#128268; 连接关闭（onClosed code=" + code + "）");
  152.             stopScreenshotLoop();
  153.             scheduleReconnect();
  154.         },
  155.         onFailure: function (wsObj, throwable, response) {
  156.             state.connected = false;
  157.             state.err = (throwable ? String(throwable.getMessage()) : "unknown_failure");
  158.             print.log("WS: onFailure " + state.err);
  159.             printl("❌ 连接错误（onFailure）: " + state.err);
  160.             stopScreenshotLoop();
  161.             scheduleReconnect();
  162.         }
  163.     });

  165.     // 发起连接
  166.     var url = "ws://" + config.serverUrl;
  167.     printl("正在连接: " + url + "（" + config.connectTimeoutSec + " 秒超时）");

  169.     try {
  170.         var request = new Request.Builder().url(url).build();
  171.         webSocket = okHttpClient.newWebSocket(request, listener);
  172.     } catch (e) {
  173.         state.err = String(e.message);
  174.         printl("❌ newWebSocket 抛异常: " + state.err);
  175.         scheduleReconnect();
  176.     }

  178.     // 同步等最多 connectTimeoutSec + 5 秒看事件
  179.     var waited = 0;
  180.     while (!state.connected && !state.err && waited < (config.connectTimeoutSec + 5) * 1000) {
  181.         sleep.millisecond(100);
  182.         waited += 100;
  183.     }
  184.     if (!state.connected && !state.err) {
  185.         state.err = "连接超时（" + (config.connectTimeoutSec + 5) + " 秒内无 onOpen/onFailure）";
  186.         printl("❌ " + state.err);
  187.         scheduleReconnect();
  188.     }
  189. }

  191. // ========== 重连调度 ==========
  192. function scheduleReconnect() {
  193.     if (state.reconnectCount >= config.maxReconnectAttempts) {
  194.         printl("&#128721; 已达到最大重连次数 " + config.maxReconnectAttempts + "，停止");
  195.         return;
  196.     }
  197.     state.reconnectCount++;
  198.     printl("⏱️  重连 " + state.reconnectCount + "/" + config.maxReconnectAttempts + "，" + (config.reconnectInterval / 1000).toFixed(1) + " 秒后...");

  200.     shutdownClient();

  202.     setTimeout(function () {
  203.         connect();
  204.     }, config.reconnectInterval);
  205. }

  207. // ========== 截一张图并发送 ==========
  208. function sendOne() {
  209.     if (!state.connected || !webSocket) {
  210.         print.log("跳过截图：未连接");
  211.         return;
  212.     }
  213.     try {
  214.         print.log("截取屏幕...");
  215.         printl("&#128248; 截图中...");

  217.         var bitmap = screen.screenShotFull();
  218.         if (!bitmap) { printl("❌ 截图失败（返回 null）"); return; }

  220.         print.log("转 Base64...");
  221.         var base64 = "" + bitmap.toBase64();   // Java ByteString → JS 字符串，必须用 ""+

  223.         if (!base64) { printl("❌ Base64 为空"); return; }

  225.         var chars = base64.length;
  226.         var estKB = Math.round(chars * 0.75 / 1024);
  227.         printl("&#128230; 图片大小: " + chars + " 字符（约 " + estKB + " KB）");

  229.         try { bitmap.recycle(); } catch (e) {}

  231.         state.totalSent++;
  232.         printl("&#128228; 发送图片 #" + state.totalSent + " ...");
  233.         webSocket.send(base64);

  235.         printl("✅ 图片 #" + state.totalSent + " 已投递（" + estKB + " KB）");

  237.     } catch (e) {
  238.         printl("❌ sendOne 异常: " + e.message);
  239.         print.log("sendOne: " + e.message);
  240.     }
  241. }

  243. // ========== 定时截图循环 ==========
  244. function startScreenshotLoop() {
  245.     if (timer) { try { clearInterval(timer); } catch (e) {} timer = null; }

  247.     print.log("定时截图循环启动, 间隔 " + config.screenshotInterval + "ms");
  248.     printl("⏰ 定时截图已启动（间隔 " + (config.screenshotInterval / 1000) + " 秒）");

  250.     // 首张立即来
  251.     setTimeout(function () { sendOne(); }, 300);

  253.     timer = setInterval(function () {
  254.         if (state.connected && webSocket) sendOne();
  255.     }, config.screenshotInterval);
  256. }

  258. function stopScreenshotLoop() {
  259.     if (timer) {
  260.         try { clearInterval(timer); } catch (e) {}
  261.         timer = null;
  262.         print.log("停止定时截图循环");
  263.     }
  264. }

  266. // ========== 关闭清理 ==========
  267. function cleanup() {
  268.     stopScreenshotLoop();
  269.     shutdownClient();
  270.     state.connected = false;
  271.     printl("&#128268; 资源已清理");
  272. }

  274. // ========== 主程序 ==========
  275. function main() {
  276.     try {
  277.         printl("========================================");
  278.         printl("  WebSocket 屏幕截图传输 - okhttp3 版");
  279.         printl("  服务器: " + config.serverUrl);
  280.         printl("  截图间隔: " + (config.screenshotInterval / 1000) + " 秒");
  281.         printl("  总运行: " + (config.runDuration / 1000) + " 秒");
  282.         printl("  最大重连: " + config.maxReconnectAttempts + " 次");
  283.         printl("========================================");
  284.         printl("ℹ️ 请确认 PC 已运行: python WebSocket测试服务器.py");

  286.         connect();

  288.         print.log("倒计时 " + (config.runDuration / 1000) + " 秒...");
  289.         printl("⏳ 运行 " + (config.runDuration / 1000) + " 秒后自动结束");
  290.         sleep.millisecond(config.runDuration);

  292.         cleanup();

  294.         printl("");
  295.         printl("===== 执行结束 =====");
  296.         printl("  尝试发送: " + state.totalSent + " 张");
  297.         printl("  服务器确认: " + state.totalConfirmed + " 张");
  298.         if (state.saveDir) printl("  PC 保存目录: " + state.saveDir);
  299.         print.log("===== 屏幕截图传输结束, 发送 " + state.totalSent + " 张 =====");

  301.     } catch (e) {
  302.         print.log("主程序异常: " + e.message);
  303.         printl("❌ 程序错误: " + e.message);
  304.         try { cleanup(); } catch (e2) {}
  305.     }
  306. }

  308. main();
复制代码



AIWROK, AIWROK软件
楼主新帖
楼主热帖
unto快手极速版自动刷视频next实战使用桌面控制WebSocket

相关帖子
回复

使用道具 举报

返回列表 发帖
高级模式
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三大主流论坛，有手机验证码收件，邮件收发的功能，支持验证码识别，注册问题识别，多线程任务，自动上传头像，自动激活注册邮件，兼容防注册插件，本站软件原创正版，更新效率最快的原创软件。 『网络推广软件』『自动发帖软件』『 自动发帖』