AIWROK软件安卓脚本FTP上传下载例子

群发软件

	AIWROK软件安卓脚本FTP上传下载例子 /** * AIWROK 简易FTP工具 - 纯Java Socket实现 * 交流QQ群: 711841924 (群一) / 528816639 (苹果脚本内测群)s */ // ==================== FTP配置 ==================== // 配置FTP服务器连接信息 var FTPConfig = {     host: "38.67.75.157",      // FTP服务器地址     port: 21,                   // FTP端口(默认21)     username: "fghgdfhfdh",           // 登录用户名     password: "aH6CEtK6X77J",   // 登录密码     timeout: 60000,             // 连接超时时间(毫秒)     encoding: "UTF-8"           // 字符编码 }; // ==================== FTP客户端 ==================== // 使用IIFE(立即执行函数)创建FTPClient对象 // 封装所有FTP操作，保持全局命名空间清洁 var FTPClient = (function() {     // 私有变量 - FTP连接状态     var controlSocket = null;   // 控制通道Socket(发送命令)     var dataSocket = null;      // 数据通道Socket(传输文件)     var reader = null;          // 控制通道读取器     var writer = null;          // 控制通道写入器     var isConnected = false;    // 连接状态标志     /**      * 读取FTP服务器响应      * 从控制通道读取一行文本      * @returns {string|null} 服务器响应的文本，失败返回null      */     function readResponse() {         try {             var line = reader.readLine();             if (line) console.log("FTP: " + line);             return line;         } catch (e) {             return null;         }     }     /**      * 发送FTP命令并等待响应      * @param {string} cmd - FTP命令(如 USER, PASS, PASV等)      * @returns {string|null} 服务器响应，失败返回null      */     function sendCommand(cmd) {         try {             writer.write(cmd + "\r\n");  // FTP命令以\r\n结尾             writer.flush();              // 立即发送             sleep.second(0.5);           // 等待服务器响应             return readResponse();       // 读取响应         } catch (e) {             return null;         }     }     /**      * 连接FTP服务器并登录      * 建立控制通道，完成用户认证      * @param {Object} config - FTP配置对象(host, port, username, password等)      * @returns {boolean} 连接成功返回true，失败返回false      */     function connect(config) {         try {             console.log("连接FTP: " + config.host);                          // 1. 创建控制通道Socket连接             controlSocket = new java.net.Socket(config.host, config.port);             controlSocket.setSoTimeout(config.timeout);  // 设置超时                          // 2. 创建输入输出流(使用指定编码)             var InputStreamReader = java.io.InputStreamReader;             var OutputStreamWriter = java.io.OutputStreamWriter;             var BufferedReader = java.io.BufferedReader;             var BufferedWriter = java.io.BufferedWriter;                          reader = new BufferedReader(new InputStreamReader(controlSocket.getInputStream(), config.encoding));             writer = new BufferedWriter(new OutputStreamWriter(controlSocket.getOutputStream(), config.encoding));                          // 3. 读取服务器欢迎消息(220开头)             var welcome = readResponse();             if (!welcome || !welcome.startsWith("220")) {                 disconnect();                 return false;             }                          // 4. 读取所有多行欢迎消息(Pure-FTPd会发送多条220-开头的消息)             sleep.second(0.3);             var line;             while ((line = reader.readLine()) !== null) {                 if (!line.startsWith("220-")) break;  // 遇到非220-的行就停止             }                          // 5. 发送用户名(USER命令)             var resp = sendCommand("USER " + config.username);             if (!resp || !resp.startsWith("331")) {  // 331表示需要密码                 disconnect();                 return false;             }                          // 6. 发送密码(PASS命令)             resp = sendCommand("PASS " + config.password);             if (!resp || !resp.startsWith("230")) {  // 230表示登录成功                 disconnect();                 return false;             }                          console.log("✓ 登录成功");             isConnected = true;             return true;                      } catch (e) {             console.log("连接失败: " + e.message);             disconnect();             return false;         }     }     /**      * 设置被动模式(PASV)      * FTP被动模式：服务器开启数据端口，客户端连接      * 自动处理内网IP映射(将10.x.x.x替换为公网IP)      * @returns {boolean} 设置成功返回true，失败返回false      */     function setupPassiveMode() {         try {             // 关闭旧的数据通道             if (dataSocket) {                 try { dataSocket.close(); } catch(e) {}                 dataSocket = null;             }                          // 发送PASV命令，获取服务器数据端口             var resp = sendCommand("PASV");             if (!resp || !resp.startsWith("227")) return false;  // 227表示进入被动模式                          // 解析PASV响应: 227 Entering Passive Mode (h1,h2,h3,h4,p1,p2)             var match = resp.match(/\(([^)]+)\)/);             if (!match) return false;                          var parts = match[1].split(",");             var port = parseInt(parts[4]) * 256 + parseInt(parts[5]);  // 计算端口号             var ip = parts[0] + "." + parts[1] + "." + parts[2] + "." + parts[3];                          // 重要：如果服务器返回内网IP，替换为配置的公网IP             // 这是因为FTP服务器在NAT后面，会返回内网地址             if (ip.startsWith("10.") || ip.startsWith("192.168.")) {                 console.log("检测到内网IP: " + ip + "，使用服务器地址: " + FTPConfig.host);                 ip = FTPConfig.host;             }                          // 创建数据通道Socket连接             dataSocket = new java.net.Socket(ip, port);             dataSocket.setSoTimeout(60000);  // 数据传输超时60秒             return true;         } catch (e) {             console.log("被动模式设置失败: " + e.message);             return false;         }     }     /**      * 上传文件到FTP服务器      * 使用被动模式传输，支持二进制文件      * @param {string} localPath - 本地文件路径(如 /sdcard/test.txt)      * @param {string} remotePath - 远程文件路径(如 /test.txt)      * @returns {boolean} 上传成功返回true，失败返回false      */     function upload(localPath, remotePath) {         if (!isConnected) return false;                  console.log("上传: " + localPath + " -> " + remotePath);                  // 检查本地文件是否存在         var file = new java.io.File(localPath);         if (!file.exists()) {             console.log("文件不存在: " + localPath);             return false;         }                  // 设置被动模式，建立数据通道         if (!setupPassiveMode()) return false;                  // 发送STOR命令，准备接收文件         var resp = sendCommand("STOR " + remotePath);         if (!resp || !resp.startsWith("150")) return false;  // 150表示准备接收                  // 读取本地文件并发送到数据通道         var fis = new java.io.BufferedInputStream(new java.io.FileInputStream(file));         var out = dataSocket.getOutputStream();         var buffer = java.lang.reflect.Array.newInstance(java.lang.Byte.TYPE, 4096);  // 4KB缓冲区         var len;                  while ((len = fis.read(buffer)) !== -1) {             out.write(buffer, 0, len);  // 写入数据通道         }                  // 关闭流和Socket         fis.close();         out.close();         dataSocket.close();         dataSocket = null;                  // 读取最终响应(226表示传输完成)         sleep.second(0.5);         var finalResp;         while ((finalResp = readResponse()) !== null) {             if (finalResp.startsWith("226 ")) {  // 226表示文件传输成功                 console.log("✓ 上传成功");                 return true;             }         }                  return false;     }     /**      * 从FTP服务器下载文件      * 使用被动模式传输，支持二进制文件      * @param {string} remotePath - 远程文件路径(如 /test.txt)      * @param {string} localPath - 本地保存路径(如 /sdcard/test.txt)      * @returns {boolean} 下载成功返回true，失败返回false      */     function download(remotePath, localPath) {         if (!isConnected) return false;                  console.log("下载: " + remotePath + " -> " + localPath);                  // 设置被动模式，建立数据通道         if (!setupPassiveMode()) return false;                  // 发送RETR命令，请求下载文件         var resp = sendCommand("RETR " + remotePath);         if (!resp || !resp.startsWith("150")) return false;  // 150表示准备发送                  // 从数据通道接收数据并保存到本地文件         var fos = new java.io.BufferedOutputStream(new java.io.FileOutputStream(new java.io.File(localPath)));         var input = dataSocket.getInputStream();         var buffer = java.lang.reflect.Array.newInstance(java.lang.Byte.TYPE, 4096);  // 4KB缓冲区         var len;         var total = 0;                  console.log("开始接收...");         try {             var startTime = new Date().getTime();             var timeout = 30000;  // 30秒超时保护                          while ((len = input.read(buffer)) !== -1) {                 fos.write(buffer, 0, len);  // 写入本地文件                 total += len;                                 // 检查是否超时                 var elapsed = new Date().getTime() - startTime;                 if (elapsed > timeout) {                     console.log("超时: 已接收 " + total + " 字节");                     break;                 }             }             console.log("接收完成: " + total + " 字节");         } catch (e) {             console.log("接收出错: " + e.message);         }                  // 关闭流和Socket         fos.close();         input.close();         dataSocket.close();         dataSocket = null;                  // 读取最终响应(226表示传输完成)         sleep.second(0.5);         var finalResp;         while ((finalResp = readResponse()) !== null) {             if (finalResp.startsWith("226 ")) {  // 226表示文件传输成功                 console.log("✓ 下载成功");                 return true;             }         }                  return false;     }     /**      * 获取FTP目录列表      * 使用LIST命令获取指定目录的文件列表      * @param {string} remotePath - 远程目录路径(如 /)      * @returns {Array} 文件列表数组，每个元素是一行LIST输出      */     function listDir(remotePath) {         if (!isConnected) return [];                  console.log("列出目录: " + remotePath);                  // 设置被动模式         if (!setupPassiveMode()) return [];                  // 发送LIST命令         var resp = sendCommand("LIST " + remotePath);         if (!resp || !resp.startsWith("150")) return [];  // 150表示准备发送数据                  // 从数据通道读取目录列表         var dirReader = new java.io.BufferedReader(             new java.io.InputStreamReader(dataSocket.getInputStream(), "UTF-8")         );                  var files = [];         var line;         while ((line = dirReader.readLine()) !== null) {             if (line.trim()) files.push(line);  // 跳过空行         }                  // 关闭读取器和Socket         dirReader.close();         dataSocket.close();         dataSocket = null;                  // 读取最终响应(226表示传输完成)         sleep.second(0.5);         var finalResp;         while ((finalResp = readResponse()) !== null) {             if (finalResp.startsWith("226 ")) break;  // 找到最终的226响应         }                  console.log("找到 " + files.length + " 个条目");         return files;     }     /**      * 断开FTP连接      * 关闭所有Socket和流，释放资源      */     function disconnect() {         try {             // 关闭数据通道             if (dataSocket) {                 try { dataSocket.close(); } catch(e) {}                 dataSocket = null;             }                          // 关闭控制通道             if (controlSocket) {                 try {                     writer.write("QUIT\r\n");  // 发送QUIT命令                     writer.flush();                 } catch(e) {}                 try { controlSocket.close(); } catch(e) {}                 controlSocket = null;             }                          // 关闭流             if (reader) { try { reader.close(); } catch(e) {} reader = null; }             if (writer) { try { writer.close(); } catch(e) {} writer = null; }                          isConnected = false;             console.log("已断开");         } catch (e) {             // 忽略断开时的错误         }     }     // 公开API - 只暴露这5个方法     return {         connect: connect,       // 连接FTP服务器         disconnect: disconnect, // 断开连接         upload: upload,         // 上传文件         download: download,     // 下载文件         listDir: listDir        // 获取目录列表     }; })(); // ==================== 测试代码 ==================== /** * 主函数 - 演示FTP工具的三个核心功能 * 1. 连接FTP服务器 * 2. 查看目录列表 * 3. 上传文件 * 4. 下载文件 * 5. 断开连接 */ function main() {     console.log("========== FTP简易工具 ==========\n");         // 1. 连接FTP服务器     if (!FTPClient.connect(FTPConfig)) {         console.log("连接失败");         return;     }         sleep.second(1);  // 等待1秒         // 2. 查看根目录文件列表     console.log("\n--- 查看根目录 ---");     var files = FTPClient.listDir("/");     for (var i = 0; i < files.length; i++) {         console.log("  " + files[i]);     }         sleep.second(1);  // 等待1秒         // 3. 上传文件测试     console.log("\n--- 上传测试 ---");     FTPClient.upload("/sdcard/test.txt", "/test_upload.txt");         sleep.second(1);  // 等待1秒         // 4. 下载文件测试     console.log("\n--- 下载测试 ---");     FTPClient.download("/2.txt", "/sdcard/2_downloaded.txt");         sleep.second(1);  // 等待1秒         // 5. 断开连接     FTPClient.disconnect();         console.log("\n========== 完成 =========="); } // 执行主函数 main(); 复制代码