require("./init") const osutil = require("./util/osutil") const killer = require('cross-port-killer'); const net = require('net'); const dns = require('dns').promises; /** * 模拟 telnet ，检测端口是否开放 * @param port * @param host * @param timeout * @returns {Promise} */ async function telnet(port, host, timeout=3000){ $logger.debug(`port=${port} host=${host} timeout=${timeout}`) return new Promise(function (resolve, reject){ const socket = new net.Socket(); socket.setTimeout(timeout, function() { socket.end(); reject("链接超时") }); socket.connect(port, host); socket.on('connect', function() { resolve('连接成功'); socket.end(); }); socket.on('error', function(err) { reject('连接失败'); }); }) } async function killport(port) { return killer.kill( port ); // let func = osutil.choise([ // require("./windows/net").killport, // require("./linux/net").killport, // ]) // return func && func(port); } /** * 获取端口信息 * 因为命令输出缓存问题，有缺陷。 * @param port * @returns {Promise} */ async function getport(port) { $logger.info( "暂未实现" ); } async function checkip(){ const url = "https://myip.ipip.net/json" const http = url.startsWith("https:") ? require("node:https") : require('node:http'); return new Promise((resolve, reject) => { http.get(url, (res) => { let data = ''; // A chunk of data has been recieved. res.on('data', (chunk) => { data += chunk; }); // The whole response has been received. Resolve the promise with result res.on('end', () => { resolve(JSON.parse(data)); }); }).on("error", (err) => { // In case of any error reject the promise reject(err); }); }); } /** * 内网IP端口扫描函数 * @param {string} ipAndMask - IP地址或IP段，如："192.168.1.1" 或 "192.168.1.0/24" * @param {string|null} ports - 端口，可以是：null（使用默认端口）、单个端口、多个端口逗号分隔 * @returns {Promise} - 返回扫描结果数组 */ async function scan(ipAndMask, ports) { const defaultPorts = [22, 80, 443, 3389, 8889]; let targetIps = []; let targetPorts = []; // 1. 解析端口参数 if (!ports) { targetPorts = defaultPorts; } else if (ports.includes(',')) { targetPorts = ports.split(',').map(p => parseInt(p.trim())).filter(p => p > 0 && p <= 65535); } else { targetPorts = [parseInt(ports)]; } // 2. 解析IP地址/网段 if (ipAndMask.includes('/')) { // CIDR表示法，如 192.168.1.0/24 targetIps = await parseCIDR(ipAndMask); } else if (net.isIP(ipAndMask)) { // 单个IP地址 targetIps = [ipAndMask]; } else { // 可能是主机名，尝试解析 try { const addresses = await dns.resolve4(ipAndMask); targetIps = addresses; } catch (error) { throw new Error(`无法解析主机名: ${ipAndMask}`); } } // 3. 扫描所有IP和端口 const scanPromises = targetIps.map(ip => scanPortsForIP(ip, targetPorts) ); const results = await Promise.all(scanPromises); // 4. 过滤出有开放端口的结果 return results.filter(result => result.openPorts.length > 0); } /** * 解析CIDR格式的IP段 * @param {string} cidr - CIDR格式，如 "192.168.1.0/24" * @returns {Array} - IP地址数组 */ function parseCIDR(cidr) { const [ipStr, maskStr] = cidr.split('/'); const mask = parseInt(maskStr); if (mask < 0 || mask > 32) { throw new Error('子网掩码必须在0-32之间'); } // 将IP转换为32位整数 const ipToInt = (ip) => { const parts = ip.split('.').map(Number); return (parts[0] << 24) + (parts[1] << 16) + (parts[2] << 8) + parts[3]; }; // 将32位整数转换为IP字符串 const intToIp = (int) => { return [ (int >>> 24) & 255, (int >>> 16) & 255, (int >>> 8) & 255, int & 255 ].join('.'); }; const ipInt = ipToInt(ipStr); const hostBits = 32 - mask; const networkMask = (0xFFFFFFFF << hostBits) >>> 0; // 无符号右移 const networkAddress = ipInt & networkMask; const broadcastAddress = networkAddress | ((1 << hostBits) - 1); // 排除网络地址和广播地址 const start = networkAddress + 1; const end = broadcastAddress - 1; const ips = []; for (let i = start; i <= end; i++) { ips.push(intToIp(i)); } return ips; } /** * 扫描单个IP的所有指定端口 * @param {string} ip - IP地址 * @param {Array} ports - 端口数组 * @param {number} timeout - 连接超时时间（毫秒） * @returns {Promise