Spaces:

jljiu
/

proxy

Runtime error

App Files Files Community

jljiu commited on Dec 16, 2024

Commit

5b3d1af

verified ·

1 Parent(s): 2e8ec84

Update proxy/main.ts

Browse files

Files changed (1) hide show

proxy/main.ts +231 -231

proxy/main.ts CHANGED Viewed

@@ -1,267 +1,267 @@
-const CONFIG = {
-  port: parseInt(Deno.env.get("PORT") || "7860"),
-  host: "0.0.0.0",
-  timeout: 5000
-};
-// 添加连接计数和限制
-const connectionTracker = new Map<string, {
-  count: number,
-  lastTime: number
-}>();
-// 清理过期的连接记录
-setInterval(() => {
-  const now = Date.now();
-  for (const [ip, data] of connectionTracker) {
-    if (now - data.lastTime > 60000*1000) { // 60秒后清理
-      connectionTracker.delete(ip);
-    }
-  }
-}, 60000);
-// 检查连接频率
-function checkConnectionLimit(ip: string): boolean {
-  const now = Date.now();
-  const data = connectionTracker.get(ip) || { count: 0, lastTime: now };
-  // 如果是新的一分钟，重置计数
-  if (now - data.lastTime > 60000) {
-    data.count = 1;
-    data.lastTime = now;
-  } else {
-    data.count++;
-  }
-  connectionTracker.set(ip, data);
-  // 每分钟允许最多10次连接
-  return data.count <= 10;
-}
-async function handleConnection(conn: Deno.Conn) {
-  const clientAddr = conn.remoteAddr as Deno.NetAddr;
-  const clientIP = clientAddr.hostname;
-  try {
-    const buf = new Uint8Array(256);
-    console.log(`等待读取来自 ${clientIP} 的数据...`);
-    const n = await Promise.race([
-      conn.read(buf),
-      new Promise((_, reject) =>
-        setTimeout(() => reject(new Error("读取超时")), 3000)
-      )
-    ]);
-    if (!n) {
-      console.log(`空连接来自: ${clientIP}`);
-      return;
-    }
-    console.log(`收到数据 ${n} 字节, 首字节: 0x${buf[0].toString(16)}`);
-    // SOCKS5 处理逻辑
-    if (buf[0] === 0x05) {
-      console.log("开始处理 SOCKS5 请求");
-      // 发送认证方法响应
-      await conn.write(new Uint8Array([0x05, 0x00]));
-      console.log("已发送认证响应");
-      // 读取连接请求
-      console.log("等待连接请求...");
-      const n2 = await conn.read(buf);
-      if (!n2) {
-        console.log("未收到连接请求");
-        return;
-      }
-      console.log(`收到连接请求 ${n2} 字节`);
-      const cmd = buf[1];
-      const atyp = buf[3];
-      console.log(`命令类型: ${cmd}, 地址类型: ${atyp}`);
-      if (cmd !== 0x01) {
-        console.log(`不支持的命令类型: ${cmd}`);
-        await conn.write(new Uint8Array([0x05, 0x07, 0x00, 0x01, 0, 0, 0, 0, 0, 0]));
-        return;
-      }
-      // 解析目标地址和端口
-      let targetHost = "";
-      let addrLen = 0;
-      let targetPort = 0;
-      try {
-        switch (atyp) {
-          case 0x01: // IPv4
-            targetHost = Array.from(buf.slice(4, 8)).join(".");
-            addrLen = 4;
-            break;
-          case 0x03: // Domain
-            addrLen = buf[4];
-            targetHost = new TextDecoder().decode(buf.slice(5, 5 + addrLen));
-            break;
-          case 0x04: // IPv6
-            targetHost = Array.from(buf.slice(4, 20))
-              .map(x => x.toString(16).padStart(2, '0'))
-              .join(":");
-            addrLen = 16;
-            break;
-        }
-        targetPort = (buf[addrLen + (atyp === 0x03 ? 5 : 4)] << 8) |
-                     buf[addrLen + (atyp === 0x03 ? 6 : 5)];
-        console.log(`目标地址: ${targetHost}:${targetPort}`);
-        // 连接目标服务器
-        console.log(`尝试连接到 ${targetHost}:${targetPort}`);
-        const target = await Deno.connect({
-          hostname: targetHost,
-          port: targetPort,
-        });
-        console.log("目标连接成功");
-        // 发送连接成功响应
-        await conn.write(new Uint8Array([
-          0x05, 0x00, 0x00, 0x01,
-          0, 0, 0, 0,
-          0, 0
-        ]));
-        console.log("已发送成功响应");
-        // 设置更大的缓冲区
-        const bufSize = 64 * 1024;
-        // 双向转发数据
-        console.log("开始数据转发");
-        await Promise.all([
-          (async () => {
-            const buf = new Uint8Array(bufSize);
-            try {
-              while (true) {
-                const n = await conn.read(buf);
-                if (!n) break;
-                console.log(`客户端 -> 目标: ${n} 字节`);
-                await target.write(buf.subarray(0, n));
-              }
-            } catch (e) {
-              console.log("客户端->目标 传输错误:", e.message);
-            }
-          })(),
-          (async () => {
-            const buf = new Uint8Array(bufSize);
-            try {
-              while (true) {
-                const n = await target.read(buf);
-                if (!n) break;
-                console.log(`目标 -> 客户端: ${n} 字节`);
-                await conn.write(buf.subarray(0, n));
-              }
-            } catch (e) {
-              console.log("目标->客户端 传输错误:", e.message);
-            }
-          })()
-        ]);
-        console.log(`${targetHost}:${targetPort} 连接完成`);
-        target.close();
-      } catch (e) {
-        console.error(`连接目标失败: ${e.message}`);
-        await conn.write(new Uint8Array([0x05, 0x04, 0x00, 0x01, 0, 0, 0, 0, 0, 0]));
-      }
-    } else {
-      console.log(`非 SOCKS5 请求: 0x${buf[0].toString(16)}`);
-    }
-  } catch (err) {
-    console.error(`处理错误: ${err.message}`);
-  } finally {
-    console.log(`关闭连接: ${clientIP}`);
-    conn.close();
-  }
-}
-// 生成Clash配置
-function generateClashConfig(spaceDomain: string) {
-  return `
-port: 7890
-socks-port: 7891
-mixed-port: 7890
-allow-lan: true
-mode: Rule
-log-level: info
-external-controller: 127.0.0.1:9090
-proxies:
-  - name: "HFProxy"
-    type: socks5
-    server: ${spaceDomain}
-    port: ${CONFIG.port}
-    skip-cert-verify: true
-proxy-groups:
-  - name: "PROXY"
-    type: select
-    proxies:
-      - HFProxy
-      - DIRECT
-rules:
-  - DOMAIN-SUFFIX,google.com,PROXY
-  - DOMAIN-SUFFIX,github.com,PROXY
-  - DOMAIN-SUFFIX,githubusercontent.com,PROXY
-  - MATCH,DIRECT
-`;
-}
-// HTTP服务器处理函数
-async function handleHttp(req: Request): Promise<Response> {
-  const url = new URL(req.url);
-  const spaceDomain = url.hostname;
-  if (url.pathname === "/config") {
-    return new Response(generateClashConfig(spaceDomain), {
-      headers: {
-        "content-type": "text/yaml",
-        "content-disposition": "attachment; filename=config.yaml",
-        "Access-Control-Allow-Origin": "*"
-      }
-    });
-  }
-  return new Response(`
-    代理服务器运行中
-    HTTP端口: ${CONFIG.port}
-    SOCKS5端口: ${CONFIG.port + 1}
-    访问 /config 获取配置
-  `, {
-    headers: {
-      "content-type": "text/plain;charset=utf-8",
-      "Access-Control-Allow-Origin": "*"
-    }
-  });
-}
-// 启动服务器
-async function main() {
-  try {
-    const listener = Deno.listen({ port: CONFIG.port, hostname: CONFIG.host });
-    console.log(`代理服务器启动于 ${CONFIG.host}:${CONFIG.port}`);
-    console.log("等待连接...");
-    for await (const conn of listener) {
-      handleConnection(conn).catch(err => {
-        console.error("连接处理错误:", err.message);
-      });
-    }
-  } catch (err) {
-    console.error("服务器启动错误:", err.message);
-  }
-}
-if (import.meta.main) {
-  main().catch(console.error);
-}

+// const CONFIG = {
+//   port: parseInt(Deno.env.get("PORT") || "7860"),
+//   host: "0.0.0.0",
+//   timeout: 5000
+// };
+// // 添加连接计数和限制
+// const connectionTracker = new Map<string, {
+//   count: number,
+//   lastTime: number
+// }>();
+// // 清理过期的连接记录
+// setInterval(() => {
+//   const now = Date.now();
+//   for (const [ip, data] of connectionTracker) {
+//     if (now - data.lastTime > 60000*1000) { // 60秒后清理
+//       connectionTracker.delete(ip);
+//     }
+//   }
+// }, 60000);
+// // 检查连接频率
+// function checkConnectionLimit(ip: string): boolean {
+//   const now = Date.now();
+//   const data = connectionTracker.get(ip) || { count: 0, lastTime: now };
+//   // 如果是新的一分钟，重置计数
+//   if (now - data.lastTime > 60000) {
+//     data.count = 1;
+//     data.lastTime = now;
+//   } else {
+//     data.count++;
+//   }
+//   connectionTracker.set(ip, data);
+//   // 每分钟允许最多10次连接
+//   return data.count <= 10;
+// }
+// async function handleConnection(conn: Deno.Conn) {
+//   const clientAddr = conn.remoteAddr as Deno.NetAddr;
+//   const clientIP = clientAddr.hostname;
+//   try {
+//     const buf = new Uint8Array(256);
+//     console.log(`等待读取来自 ${clientIP} 的数据...`);
+//     const n = await Promise.race([
+//       conn.read(buf),
+//       new Promise((_, reject) =>
+//         setTimeout(() => reject(new Error("读取超时")), 3000)
+//       )
+//     ]);
+//     if (!n) {
+//       console.log(`空连接来自: ${clientIP}`);
+//       return;
+//     }
+//     console.log(`收到数据 ${n} 字节, 首字节: 0x${buf[0].toString(16)}`);
+//     // SOCKS5 处理逻辑
+//     if (buf[0] === 0x05) {
+//       console.log("开始处理 SOCKS5 请求");
+//       // 发送认证方法响应
+//       await conn.write(new Uint8Array([0x05, 0x00]));
+//       console.log("已发送认证响应");
+//       // 读取连接请求
+//       console.log("等待连接请求...");
+//       const n2 = await conn.read(buf);
+//       if (!n2) {
+//         console.log("未收到连接请求");
+//         return;
+//       }
+//       console.log(`收到连接请求 ${n2} 字节`);
+//       const cmd = buf[1];
+//       const atyp = buf[3];
+//       console.log(`命令类型: ${cmd}, 地址类型: ${atyp}`);
+//       if (cmd !== 0x01) {
+//         console.log(`不支持的命令类型: ${cmd}`);
+//         await conn.write(new Uint8Array([0x05, 0x07, 0x00, 0x01, 0, 0, 0, 0, 0, 0]));
+//         return;
+//       }
+//       // 解析目标地址和端口
+//       let targetHost = "";
+//       let addrLen = 0;
+//       let targetPort = 0;
+//       try {
+//         switch (atyp) {
+//           case 0x01: // IPv4
+//             targetHost = Array.from(buf.slice(4, 8)).join(".");
+//             addrLen = 4;
+//             break;
+//           case 0x03: // Domain
+//             addrLen = buf[4];
+//             targetHost = new TextDecoder().decode(buf.slice(5, 5 + addrLen));
+//             break;
+//           case 0x04: // IPv6
+//             targetHost = Array.from(buf.slice(4, 20))
+//               .map(x => x.toString(16).padStart(2, '0'))
+//               .join(":");
+//             addrLen = 16;
+//             break;
+//         }
+//         targetPort = (buf[addrLen + (atyp === 0x03 ? 5 : 4)] << 8) |
+//                      buf[addrLen + (atyp === 0x03 ? 6 : 5)];
+//         console.log(`目标地址: ${targetHost}:${targetPort}`);
+//         // 连接目标服务器
+//         console.log(`尝试连接到 ${targetHost}:${targetPort}`);
+//         const target = await Deno.connect({
+//           hostname: targetHost,
+//           port: targetPort,
+//         });
+//         console.log("目标连接成功");
+//         // 发送连接成功响应
+//         await conn.write(new Uint8Array([
+//           0x05, 0x00, 0x00, 0x01,
+//           0, 0, 0, 0,
+//           0, 0
+//         ]));
+//         console.log("已发送成功响应");
+//         // 设置更大的缓冲区
+//         const bufSize = 64 * 1024;
+//         // 双向转发数据
+//         console.log("开始数据转发");
+//         await Promise.all([
+//           (async () => {
+//             const buf = new Uint8Array(bufSize);
+//             try {
+//               while (true) {
+//                 const n = await conn.read(buf);
+//                 if (!n) break;
+//                 console.log(`客户端 -> 目标: ${n} 字节`);
+//                 await target.write(buf.subarray(0, n));
+//               }
+//             } catch (e) {
+//               console.log("客户端->目标 传输错误:", e.message);
+//             }
+//           })(),
+//           (async () => {
+//             const buf = new Uint8Array(bufSize);
+//             try {
+//               while (true) {
+//                 const n = await target.read(buf);
+//                 if (!n) break;
+//                 console.log(`目标 -> 客户端: ${n} 字节`);
+//                 await conn.write(buf.subarray(0, n));
+//               }
+//             } catch (e) {
+//               console.log("目标->客户端 传输错误:", e.message);
+//             }
+//           })()
+//         ]);
+//         console.log(`${targetHost}:${targetPort} 连接完成`);
+//         target.close();
+//       } catch (e) {
+//         console.error(`连接目标失败: ${e.message}`);
+//         await conn.write(new Uint8Array([0x05, 0x04, 0x00, 0x01, 0, 0, 0, 0, 0, 0]));
+//       }
+//     } else {
+//       console.log(`非 SOCKS5 请求: 0x${buf[0].toString(16)}`);
+//     }
+//   } catch (err) {
+//     console.error(`处理错误: ${err.message}`);
+//   } finally {
+//     console.log(`关闭连接: ${clientIP}`);
+//     conn.close();
+//   }
+// }
+// // 生成Clash配置
+// function generateClashConfig(spaceDomain: string) {
+//   return `
+// port: 7890
+// socks-port: 7891
+// mixed-port: 7890
+// allow-lan: true
+// mode: Rule
+// log-level: info
+// external-controller: 127.0.0.1:9090
+// proxies:
+//   - name: "HFProxy"
+//     type: socks5
+//     server: ${spaceDomain}
+//     port: ${CONFIG.port}
+//     skip-cert-verify: true
+// proxy-groups:
+//   - name: "PROXY"
+//     type: select
+//     proxies:
+//       - HFProxy
+//       - DIRECT
+// rules:
+//   - DOMAIN-SUFFIX,google.com,PROXY
+//   - DOMAIN-SUFFIX,github.com,PROXY
+//   - DOMAIN-SUFFIX,githubusercontent.com,PROXY
+//   - MATCH,DIRECT
+// `;
+// }
+// // HTTP服务器处理函数
+// async function handleHttp(req: Request): Promise<Response> {
+//   const url = new URL(req.url);
+//   const spaceDomain = url.hostname;
+//   if (url.pathname === "/config") {
+//     return new Response(generateClashConfig(spaceDomain), {
+//       headers: {
+//         "content-type": "text/yaml",
+//         "content-disposition": "attachment; filename=config.yaml",
+//         "Access-Control-Allow-Origin": "*"
+//       }
+//     });
+//   }
+//   return new Response(`
+//     代理服务器运行中
+//     HTTP端口: ${CONFIG.port}
+//     SOCKS5端口: ${CONFIG.port + 1}
+//     访问 /config 获取配置
+//   `, {
+//     headers: {
+//       "content-type": "text/plain;charset=utf-8",
+//       "Access-Control-Allow-Origin": "*"
+//     }
+//   });
+// }
+// // 启动服务器
+// async function main() {
+//   try {
+//     const listener = Deno.listen({ port: CONFIG.port, hostname: CONFIG.host });
+//     console.log(`代理服务器启动于 ${CONFIG.host}:${CONFIG.port}`);
+//     console.log("等待连接...");
+//     for await (const conn of listener) {
+//       handleConnection(conn).catch(err => {
+//         console.error("连接处理错误:", err.message);
+//       });
+//     }
+//   } catch (err) {
+//     console.error("服务器启动错误:", err.message);
+//   }
+// }
+// if (import.meta.main) {
+//   main().catch(console.error);
+// }