nfd云解析专业版已支持配合分布代理客户端即nfd−proxy(应用dnode技术)
在线解析网站：189.qaiu.top

下载安卓客户端

这里提供3种方式运行客户端，你可以任选一种，临时使用建议选择1，安装包体积很小，下载比较快，开发者可以选择第三种，执行python脚本

1. 原生apk包
   https://lz0.qaiu.top/lz/iQw5D3llff1c
2. 带后台运行的apk包
   https://lz0.qaiu.top/lz/iOpmn3llfrqj
3. 源码运行
   参考 https://blog.qaiu.top/archives/dnode-ke-hu-duan

进入189.qaiu.top解析站

然后就可以利用189.qaiu.top解析123网盘了

关于技术原理，可以参考另一篇文章
https://blog.qaiu.top/archives/2026-03-18-02-12-02

NFD Proxy — 分布式代理节点系统

将用户设备注册为代理节点，通过 WebSocket 控制面实现 geo 感知分发的 SOCKS5 / HTTP 代理网络。

架构

用户 / Vert.x 后端  │  HTTP CONNECT :8888  (Proxy-Authorization: Basic)  │  SOCKS5       :1080  (用户名/密码子协商)  ▼proxy_server.py          GeoIP 解析 → 同城→同省→默认→任意  │  WebSocket :9000/ws/node  ▼dnode_client.py          用户设备（真实出口 IP）  ▼目标服务器

组件

| 文件 | 说明 |

|------|------|

| proxy_server.py | 服务端：SOCKS5 + HTTP CONNECT 代理，WS 节点注册，Admin API，控制面板 |

| dnode_client.py | 节点客户端：全平台，单依赖 websockets，Android Chaquopy 支持 |

| run.py | 通用启动器：自动安装依赖，venv 管理，支持远程拉取执行 |

| dashboard.html | 实时监控大屏：节点地图、KPI、事件流 |

| admin.html | 管理面板：节点列表、踢除、URL 参数自动登录 |

| api-docs.html | API 文档 |

| start.sh | 服务端启动脚本，支持完整参数透传 |

快速启动

服务端

# 基础启动PROXY_USER=admin PROXY_PASS=secret ADMIN_TOKEN=tok python3 proxy_server.py# 或使用启动脚本./start.sh -u admin -p secret -t tok --debug

| 端口 | 协议 | 说明 |

|------|------|------|

| 1080 | SOCKS5 | 代理入口 |

| 8888 | HTTP CONNECT | 代理入口 |

| 9000 | HTTP / WS | 控制面板、API、节点注册 |

节点客户端

# 直接运行python dnode_client.py wss://dnode.qaiu.top/ws/node# 通过启动器（自动安装依赖）python run.py wss://dnode.qaiu.top/ws/node# 从远程拉取执行（Pydroid 等嵌入式环境）python run.py --url https://qaiu.top/src/py/dnode_client.py

环境变量

| 变量 | 默认 | 说明 |

|------|------|------|

| PROXY_USER | 空 | 代理用户名，逗号分隔多账号，空则不鉴权 |

| PROXY_PASS | 空 | 代理密码，与 PROXY_USER 一一对应 |

| ADMIN_TOKEN | 空 | Admin API 令牌，空则 Admin 全部拒绝 |

| SOCKS5_PORT | 1080 | SOCKS5 端口 |

| HTTP_PORT | 8888 | HTTP CONNECT 端口 |

| CONTROL_PORT | 9000 | 控制面板端口 |

| LOG_LEVEL | INFO | 日志级别，DEBUG 开启流量详情 |

| SHOW_TARGET | true | 事件流是否显示目标地址 |

代理认证 & 真实 IP

支持在凭证中携带真实 IP，用于 geo 节点选择（优先级：凭证 IP > XFF 头 > TCP peer）：

# 格式 A  标准curl -x http://admin:secret@host:8888 https://ipinfo.io# 格式 B  携带真实 IP（适用于 Vert.x ProxyOptions 无法加自定义头的场景）curl -x http://'admin:1.2.3.4':secret@host:8888 https://ipinfo.io

// Vert.x ProxyOptionsnew ProxyOptions()    .setType(ProxyType.HTTP)    .setHost("dnode.qaiu.top").setPort(8888)    .setUsername("admin:" + userRealIp)   // "admin:1.2.3.4"    .setPassword("secret");

Admin API

所有 Admin 接口需要 Authorization: Bearer <ADMIN_TOKEN> 或 ?token=<ADMIN_TOKEN>。

| 方法 | 路径 | 说明 |

|------|------|------|

| GET | /api/stats | 全局统计 + 最近 100 条事件（无需鉴权） |

| GET | /api/admin/nodes | 列出所有在线节点详情 |

| POST | /api/admin/node/{conn_id}/kick | 踢除单个节点，支持前 8 位前缀 |

| POST | /api/admin/nodes/kick-all | 踢除全部节点 |

节点分发策略

Tier 0  同城   (city 匹配)Tier 1  同省   (province 匹配)Tier 2  默认节点 (X-Default-Node: true)Tier 3  任意节点 (兜底)

同 Tier 内取负载最低节点。节点存活由 WS 断开事件驱动，无时间窗口过滤。

Android 集成

// Chaquopy — 启动thread {    Python.getInstance()        .getModule("dnode_client")        .callAttr("main_for_android",            "wss://dnode.qaiu.top/ws/node",            filesDir.absolutePath,  // 配置目录            "",                     // node_id，空则自动生成            "",                     // secret            false,                  // is_default            false)                  // debug}// 停止（任意线程安全调用）Python.getInstance()    .getModule("dnode_client")    .callAttr("stop_from_android")

停止机制：stop_from_android() 通过 loop.call_soon_threadsafe 主动关闭 WS 连接，打断 async for 循环，event loop 立即退出，不依赖 flag 轮询。

依赖

服务端 (proxy_server.py)

aiohttp >= 3.9

节点客户端 (dnode_client.py)

websockets >= 10.0

其余均为标准库（asyncio / ssl / struct / json）。

下载pydroid 参考 https://blog.qaiu.top/archives/pydroid3v72

pydroid运行

#pylint:disable=W0122# Pydroid dnode客户端from urllib.request import urlopenexec(urlopen('https://qaiu.top/src/py/dnode_client_v4.py').read())

dnode_client_v4完整代码

#!/usr/bin/env python3"""NFD 客户端节点  ── Android APK / 跨平台════════════════════════════════════════════════════════════════服务端地址优先级（高→低）:  1. 命令行参数    python node_client.py wss://host:9000/ws/node  2. 环境变量      NFD_SERVER=wss://host:9000/ws/node  3. 配置文件      node_config.json  中的 server_url 字段  4. 内置默认值    ws://proxy.nfd.com:9000/ws/node其他可选参数:  --secret  <token>     接入密钥（也可在配置文件或 NFD_SECRET 环境变量中设置）  --id      <node_id>   指定设备 ID（默认自动生成并持久化）  --debug               等同于 LOG_LEVEL=DEBUGAndroid 配置文件路径优先级:  $NFD_CONFIG_DIR/node_config.json  /sdcard/nfd/node_config.json  <脚本同级目录>/node_config.json用法示例:  python node_client.py wss://proxy.example.com:9000/ws/node  python node_client.py wss://proxy.example.com:9000/ws/node --secret abc123  NFD_SERVER=wss://... python node_client.py"""import argparseimport asyncioimport hashlibimport jsonimport loggingimport osimport platformimport signalimport socketimport sslimport structimport sysimport timeimport uuidfrom typing import Dict, Optionalimport aiohttp# ══════════════════════════════════════════════════════════#  Android 检测# ══════════════════════════════════════════════════════════def _is_android() -> bool:    return (        os.path.exists("/data/data") or        os.environ.get("ANDROID_ROOT") is not None or        os.environ.get("ANDROID_DATA") is not None    )IS_ANDROID = _is_android()PLATFORM   = "Android" if IS_ANDROID else platform.system()# ══════════════════════════════════════════════════════════#  配置文件路径（Android 友好）# ══════════════════════════════════════════════════════════def _config_path() -> str:    # 1. 环境变量指定目录    env_dir = os.environ.get("NFD_CONFIG_DIR", "")    if env_dir:        return os.path.join(env_dir, "node_config.json")    # 2. Android：优先 SD 卡可读目录    if IS_ANDROID:        sdcard = "/sdcard/nfd"        try:            os.makedirs(sdcard, exist_ok=True)            return os.path.join(sdcard, "node_config.json")        except OSError:            pass    # 3. 脚本同级目录    return os.path.join(os.path.dirname(os.path.abspath(__file__)), "node_config.json")CONFIG_FILE = _config_path()# ══════════════════════════════════════════════════════════#  日志# ══════════════════════════════════════════════════════════def _setup_logging(debug: bool = False) -> None:    level = logging.DEBUG if debug else getattr(        logging, os.environ.get("LOG_LEVEL", "INFO").upper(), logging.INFO    )    fmt = "%(asctime)s.%(msecs)03d [%(levelname)-5s] %(name)s - %(message)s"    # Android 下 basicConfig 可能已被 chaquopy 初始化，安全地重设    root = logging.getLogger()    root.setLevel(level)    if not root.handlers:        handler = logging.StreamHandler(sys.stdout)        handler.setFormatter(logging.Formatter(fmt, datefmt="%H:%M:%S"))        root.addHandler(handler)    else:        for h in root.handlers:            h.setFormatter(logging.Formatter(fmt, datefmt="%H:%M:%S"))logger   = logging.getLogger("nfd.node")flow_log = logging.getLogger("nfd.flow")# ══════════════════════════════════════════════════════════#  工具函数# ══════════════════════════════════════════════════════════def _fmt_bytes(n: int) -> str:    n = int(n or 0)    for unit in ("B", "KB", "MB", "GB"):        if n < 1024:            return f"{n:.1f}{unit}"        n /= 1024    return f"{n:.1f}TB"def _local_ip() -> str:    """获取本机出口 IP（Android/Linux/Windows 均可用）"""    targets = [("8.8.8.8", 80), ("1.1.1.1", 80), ("114.114.114.114", 80)]    for host, port in targets:        try:            with socket.socket(socket.AF_INET, socket.SOCK_DGRAM) as s:                s.settimeout(1)                s.connect((host, port))                return s.getsockname()[0]        except OSError:            continue    return "?"def _device_fp() -> str:    """设备指纹：Android 优先读 Android ID，回退到通用方案"""    if IS_ANDROID:        # 尝试读取 Android ID（需 READ_PHONE_STATE 或已知路径）        try:            import subprocess            aid = subprocess.check_output(                ["settings", "get", "secure", "android_id"],                timeout=2, stderr=subprocess.DEVNULL            ).decode().strip()            if aid and aid != "null":                return hashlib.sha256(aid.encode()).hexdigest()[:16]        except Exception:            pass    raw = f"{platform.node()}-{PLATFORM}-{uuid.getnode()}"    return hashlib.sha256(raw.encode()).hexdigest()[:16]def _make_ssl_ctx(url: str) -> Optional[ssl.SSLContext]:    """wss:// 创建 SSL context；Android 证书链有时需宽松验证"""    if not url.startswith("wss://"):        return None    ctx = ssl.create_default_context()    if IS_ANDROID:        # Android 系统根证书路径不标准，允许加载系统证书        for ca_path in (            "/system/etc/security/cacerts",            "/data/misc/keychain/certs-added",        ):            if os.path.isdir(ca_path):                for f in os.listdir(ca_path):                    try:                        ctx.load_verify_locations(os.path.join(ca_path, f))                    except Exception:                        pass        # 如果仍有问题，可通过环境变量 NFD_SSL_NOVERIFY=1 跳过验证（不推荐生产）        if os.environ.get("NFD_SSL_NOVERIFY", "0") == "1":            ctx.check_hostname = False            ctx.verify_mode    = ssl.CERT_NONE            logger.warning("SSL 证书验证已禁用（NFD_SSL_NOVERIFY=1）")    return ctx# ══════════════════════════════════════════════════════════#  帧协议# ══════════════════════════════════════════════════════════TYPE_CONNECT_REQ  = 0x01TYPE_CONNECT_OK   = 0x02TYPE_CONNECT_FAIL = 0x03TYPE_DATA         = 0x04TYPE_CLOSE        = 0x05MAX_CONCURRENCY   = 50def pack_frame(tunnel_id: int, ftype: int, payload: bytes = b"") -> bytes:    return struct.pack(">IB", tunnel_id, ftype) + payloaddef unpack_frame(data: bytes):    tunnel_id, ftype = struct.unpack(">IB", data[:5])    return tunnel_id, ftype, data[5:]# ══════════════════════════════════════════════════════════#  单条隧道# ══════════════════════════════════════════════════════════class TunnelWorker:    def __init__(self, tid: int, host: str, port: int,                 ws_send_queue: asyncio.Queue, local_ip: str):        self.tid          = tid        self.host         = host        self.port         = port        self._ws_queue    = ws_send_queue        self._local_ip    = local_ip        self._tcp_writer: Optional[asyncio.StreamWriter] = None        self._data_queue: asyncio.Queue = asyncio.Queue()        self._closed      = False        self._t_start     = time.monotonic()        self._tx_bytes    = 0        self._rx_bytes    = 0    async def run(self):        flow_log.debug(f"[node] tid={self.tid:08x} | {self._local_ip} → {self.host}:{self.port} | TCP_CONNECTING")        try:            reader, writer = await asyncio.wait_for(                asyncio.open_connection(self.host, self.port), timeout=10            )            self._tcp_writer = writer            local = writer.get_extra_info("sockname")            local_addr = f"{local[0]}:{local[1]}" if local else self._local_ip        except Exception as e:            flow_log.debug(f"[node] tid={self.tid:08x} | TCP_FAIL {self.host}:{self.port} err={e}")            await self._ws_queue.put(pack_frame(self.tid, TYPE_CONNECT_FAIL, str(e).encode()))            return        conn_ms = f"{(time.monotonic()-self._t_start)*1000:.0f}ms"        await self._ws_queue.put(pack_frame(self.tid, TYPE_CONNECT_OK))        flow_log.debug(f"[node] tid={self.tid:08x} | {local_addr} → {self.host}:{self.port} | TCP_CONNECTED conn={conn_ms}")        async def tcp_to_ws():            try:                while not self._closed:                    chunk = await reader.read(65536)                    if not chunk:                        break                    self._rx_bytes += len(chunk)                    flow_log.debug(                        f"[node] tid={self.tid:08x} | "                        f"target→node chunk={_fmt_bytes(len(chunk))} ↓{_fmt_bytes(self._rx_bytes)}"                    )                    await self._ws_queue.put(pack_frame(self.tid, TYPE_DATA, chunk))            except Exception as e:                flow_log.debug(f"[node] tid={self.tid:08x} | tcp_to_ws err={e}")            finally:                await self._ws_queue.put(pack_frame(self.tid, TYPE_CLOSE))                self._closed = True        async def ws_to_tcp():            try:                while not self._closed:                    chunk = await self._data_queue.get()                    if chunk is None:                        break                    self._tx_bytes += len(chunk)                    flow_log.debug(                        f"[node] tid={self.tid:08x} | "                        f"node→target chunk={_fmt_bytes(len(chunk))} ↑{_fmt_bytes(self._tx_bytes)}"                    )                    writer.write(chunk)                    await writer.drain()            except Exception as e:                flow_log.debug(f"[node] tid={self.tid:08x} | ws_to_tcp err={e}")            finally:                try:                    writer.close()                except Exception:                    pass                self._closed = True        await asyncio.gather(tcp_to_ws(), ws_to_tcp(), return_exceptions=True)        logger.info(            f"[node] tid={self.tid:08x} | "            f"{self._local_ip} ⇄ {self.host}:{self.port} | "            f"CLOSED ↑{_fmt_bytes(self._tx_bytes)} ↓{_fmt_bytes(self._rx_bytes)} "            f"dur={time.monotonic()-self._t_start:.2f}s"        )    def feed_data(self, data: bytes):        if not self._closed:            self._data_queue.put_nowait(data)    def close(self):        self._closed = True        self._data_queue.put_nowait(None)        if self._tcp_writer:            try:                self._tcp_writer.close()            except Exception:                pass# ══════════════════════════════════════════════════════════#  节点主体# ══════════════════════════════════════════════════════════class ProxyNode:    RECONNECT_DELAYS = [2, 4, 8, 16, 30, 60]    def __init__(self, server_url: str, node_id: str, secret: str = "", is_default: bool = False):        self.server_url  = server_url        self.node_id     = node_id        self.secret      = secret        self.is_default  = is_default        self._local_ip   = _local_ip()        self._ssl_ctx    = _make_ssl_ctx(server_url)        self._tunnels:   Dict[int, TunnelWorker] = {}        self._ws_queue:  asyncio.Queue = asyncio.Queue()        self._sem        = asyncio.Semaphore(MAX_CONCURRENCY)        self._running    = False        self._total_tunnels = 0        self._total_tx      = 0        self._total_rx      = 0    async def run(self):        self._running = True        attempt = 0        while self._running:            try:                await self._connect_loop()                attempt = 0            except Exception as e:                delay = self.RECONNECT_DELAYS[min(attempt, len(self.RECONNECT_DELAYS)-1)]                logger.warning(                    f"连接断开 ({type(e).__name__}: {e})，"                    f"{delay}s 后重连... (第{attempt+1}次)"                )                await asyncio.sleep(delay)                attempt += 1    def stop(self):        self._running = False        for t in list(self._tunnels.values()):            t.close()    async def _connect_loop(self):        headers = {            "X-Node-ID":      self.node_id,            "X-Platform":     PLATFORM,            "X-Version":      "3.0",            "X-Device-FP":    _device_fp(),            "X-Local-IP":     self._local_ip,            "X-Default-Node": "true" if self.is_default else "false",        }        if self.secret:            headers["Authorization"] = f"Bearer {self.secret}"        logger.info(            f"连接服务端  url={self.server_url}  "            f"platform={PLATFORM}  local_ip={self._local_ip}  "            f"node_id={self.node_id[:8]}"        )        # Android 上 aiohttp 需要明确传入 ssl context 或 False        ws_kwargs: dict = dict(            headers=headers,            heartbeat=30,            max_msg_size=0,        )        if self._ssl_ctx is not None:            ws_kwargs["ssl"] = self._ssl_ctx        elif self.server_url.startswith("wss://"):            ws_kwargs["ssl"] = True   # fallback: 使用系统默认        async with aiohttp.ClientSession() as sess:            async with sess.ws_connect(self.server_url, **ws_kwargs) as ws:                logger.info(                    f"✅ 已连接  url={self.server_url}  "                    f"local_ip={self._local_ip}  node_id={self.node_id[:8]}"                )                send_task = asyncio.create_task(self._ws_sender(ws))                try:                    await self._ws_receiver(ws)                finally:                    send_task.cancel()                    for t in list(self._tunnels.values()):                        t.close()                    self._tunnels.clear()                    logger.info(                        f"连接断开  tunnels={self._total_tunnels}  "                        f"↑{_fmt_bytes(self._total_tx)} ↓{_fmt_bytes(self._total_rx)}"                    )    async def _ws_sender(self, ws):        while True:            frame = await self._ws_queue.get()            try:                await ws.send_bytes(frame)            except Exception as e:                logger.warning(f"WS 发送失败: {e}")                break    async def _ws_receiver(self, ws):        async for msg in ws:            if msg.type == aiohttp.WSMsgType.BINARY:                await self._dispatch(msg.data)            elif msg.type == aiohttp.WSMsgType.TEXT:                try:                    d = json.loads(msg.data)                    if d.get("type") == "pong":                        flow_log.debug("heartbeat pong")                except Exception:                    pass            elif msg.type in (aiohttp.WSMsgType.ERROR, aiohttp.WSMsgType.CLOSE):                break    async def _dispatch(self, raw: bytes):        if len(raw) < 5:            return        tid, ftype, payload = unpack_frame(raw)        if ftype == TYPE_CONNECT_REQ:            host_len = payload[0]            host     = payload[1:1+host_len].decode()            port     = struct.unpack(">H", payload[1+host_len:3+host_len])[0]            self._total_tunnels += 1            logger.info(                f"[node] tid={tid:08x} | "                f"新隧道 → {host}:{port}  "                f"active={len(self._tunnels)+1}/{MAX_CONCURRENCY}"            )            asyncio.create_task(self._run_tunnel(tid, host, port))        elif ftype == TYPE_DATA:            t = self._tunnels.get(tid)            if t:                t.feed_data(payload)            else:                flow_log.debug(f"DATA tid={tid:08x} 无隧道")        elif ftype == TYPE_CLOSE:            t = self._tunnels.pop(tid, None)            if t:                t.close()    async def _run_tunnel(self, tid: int, host: str, port: int):        async with self._sem:            worker = TunnelWorker(tid, host, port, self._ws_queue, self._local_ip)            self._tunnels[tid] = worker            await worker.run()            self._tunnels.pop(tid, None)            self._total_tx += worker._tx_bytes            self._total_rx += worker._rx_bytes# ══════════════════════════════════════════════════════════#  配置加载 & CLI# ══════════════════════════════════════════════════════════DEFAULT_SERVER = "wss://dnode.qaiu.top/ws/node"def load_file_config() -> dict:    """从配置文件读取（文件不存在则创建模板）"""    defaults = {"server_url": DEFAULT_SERVER, "node_id": "", "secret": ""}    if os.path.exists(CONFIG_FILE):        try:            with open(CONFIG_FILE, encoding="utf-8") as f:                return {**defaults, **json.load(f)}        except Exception as e:            logger.warning(f"配置文件读取失败: {e}，使用默认值")            return defaults    # 首次运行：写入模板（含新生成 node_id）    defaults["node_id"] = uuid.uuid4().hex    try:        os.makedirs(os.path.dirname(CONFIG_FILE), exist_ok=True)        with open(CONFIG_FILE, "w", encoding="utf-8") as f:            json.dump(defaults, f, indent=2, ensure_ascii=False)        logger.info(f"已生成配置文件: {CONFIG_FILE}")    except OSError as e:        logger.warning(f"配置文件写入失败: {e}")    return defaultsdef save_node_id(node_id: str):    """持久化自动生成的 node_id"""    try:        cfg = {}        if os.path.exists(CONFIG_FILE):            with open(CONFIG_FILE, encoding="utf-8") as f:                cfg = json.load(f)        cfg["node_id"] = node_id        with open(CONFIG_FILE, "w", encoding="utf-8") as f:            json.dump(cfg, f, indent=2, ensure_ascii=False)    except OSError:        passdef parse_args():    parser = argparse.ArgumentParser(        description="NFD 代理客户端节点",        formatter_class=argparse.RawDescriptionHelpFormatter,        epilog="""示例:  python node_client.py wss://proxy.example.com:9000/ws/node  python node_client.py wss://proxy.example.com:9000/ws/node --secret mytoken  python node_client.py --debug  NFD_SERVER=wss://... python node_client.py        """,    )    parser.add_argument(        "server_url",        nargs="?",        default=None,        metavar="SERVER_URL",        help="服务端 ws:// 或 wss:// 地址（最高优先级）",    )    parser.add_argument("--secret", default=None, help="接入密钥")    parser.add_argument("--id",     default=None, help="指定 node_id（设备标识）")    parser.add_argument("--debug",  action="store_true", help="开启 DEBUG 日志")    parser.add_argument(        "--default", action="store_true",        help="标记为默认节点（兜底分发，服务器本地部署时使用）"    )    return parser.parse_args()# ══════════════════════════════════════════════════════════#  入口# ══════════════════════════════════════════════════════════async def amain():    args    = parse_args()    _setup_logging(args.debug)    file_cfg = load_file_config()    # 服务端地址优先级: CLI arg > 环境变量 > 配置文件 > 默认    server_url = (        args.server_url        or os.environ.get("NFD_SERVER", "")        or file_cfg.get("server_url", "")        or DEFAULT_SERVER    ).strip()    # 密钥优先级: CLI > 环境变量 > 配置文件    secret = (        args.secret        or os.environ.get("NFD_SECRET", "")        or file_cfg.get("secret", "")    )    # node_id 优先级: CLI > 配置文件 > 自动生成    node_id = (        args.id        or file_cfg.get("node_id", "")        or uuid.uuid4().hex    )    if not file_cfg.get("node_id"):        save_node_id(node_id)    # 校验地址格式    if not server_url.startswith(("ws://", "wss://")):        logger.error(            f"服务端地址格式错误: {server_url!r}\n"            "    应为 ws://host:port/ws/node 或 wss://host:port/ws/node"        )        sys.exit(1)    logger.info(        f"NFD 节点启动  platform={PLATFORM}  "        f"node_id={node_id[:8]}  server={server_url}  "        f"default={'✓' if args.default else '✗'}  "        f"config={CONFIG_FILE}"    )    node = ProxyNode(server_url=server_url, node_id=node_id, secret=secret,                     is_default=args.default)    # 注册退出信号（Android SIGTERM / 桌面 SIGINT）    loop = asyncio.get_running_loop()    def _shutdown(sig_name: str):        logger.info(f"收到 {sig_name}，正在退出...")        node.stop()        loop.stop()    for sig in (signal.SIGTERM, signal.SIGINT):        try:            loop.add_signal_handler(sig, _shutdown, sig.name)        except (NotImplementedError, OSError):            # Windows / 某些嵌入式 Python 不支持 add_signal_handler            pass    await node.run()if __name__ == "__main__":    try:        asyncio.run(amain())    except (KeyboardInterrupt, SystemExit):        pass

netdisk-fast-download 后台配置版使用指南

文档版本: v1.0
更新日期: 2026年1月31日
适用版本: nfd-vip2 v0.1.9+

📖 目录

• 1. 功能简介
• 2. 进入后台网盘配置界面
• 3. 各网盘认证信息配置说明
• 4. 详细配置步骤
• 5. 加密机制说明
• 6. 常见问题与排查

1. 功能简介

本系统支持 20+ 主流网盘的后台统一管理与认证信息配置。通过后台"网盘配置"功能，可为各类网盘账号集中配置认证信息，实现：

• ✅ 批量管理多个网盘账号
• ✅ 统一认证信息加密存储
• ✅ 支持一键启用/禁用配置
• ✅ 支持临时参数认证（可选）
• ✅ 快速解析与高速下载

支持的认证方式：

• accesstoken - AccessToken认证（移动云盘、联通云盘、天翼云盘等）
• cookie - Cookie认证（夸克、UC、QQ微云等）
• password - 用户名密码认证（123网盘、小飞机、蓝奏优享等）
• authorization - Authorization认证（移动云盘、123网盘等）
• custom - 自定义认证（扩展使用）
• none - 无需认证（蓝奏云、QQ邮箱、奶牛快传等）

2. 进入后台网盘配置界面

2.1 访问管理后台

1. 打开浏览器，访问管理后台地址：

   http://你的ip:6432/nfdadmin/

   如果后台管理已经绑定了域名请使用

   http(s)://你的域名/nfdadmin/

   或根据实际部署的域名和端口访问。

2. 输入管理员账号密码登录。
   【后台登录界面】

2.2 进入网盘配置页面

1. 登录成功后，在左侧菜单栏找到 “网盘配置” 菜单项。
2. 点击进入网盘配置管理界面。
3. 界面包含两个标签页：
   • 配置管理 - 管理网盘认证信息
   • 解析控制 - 管理网盘解析权限、限流等

【网盘配置菜单和列表界面】

2.3 界面功能说明

配置管理界面主要功能：

• 📋 查看列表 - 展示已配置的所有网盘账号
• ✏️ 编辑配置 - 修改现有配置的认证信息

3. 各网盘认证信息配置说明

3. 各网盘认证信息配置说明

3.1 联通云盘（pwo）

网盘类型代码：pwo
支持认证方式：AccessToken
配置难度：⭐⭐⭐

配置字段

获取方法

1. 使用浏览器访问联通云盘网页版：https://pan.wo.cn
2. 登录您的账号
3. 按 F12 打开浏览器开发者工具
4. 切换到 Application（应用程序） 标签
5. 展开左侧 LocalStore
6. 在右侧列表中找到 wocloudinfo 字段，复制其值然后解码
7. 进行在线base64解码 打开 https://www.toolhelper.cn/EncodeDecode/Base64

【截图预留位置3：联通云盘获取 accesstoken - 开发者工具截图】

打开：https://www.toolhelper.cn/EncodeDecode/Base64 -> Base64解码 -> 复制token后面的字符串

配置示例

配置名称: 我的联通云盘账号网盘类型: pwo认证方式: accesstokenToken: 2c967a63-bad7-434c-9ea6-993b49ad61ea

3.2 移动云盘 / 和彩云（p139）

网盘类型代码：p139
支持认证方式：Authorization
配置难度：⭐⭐

配置字段

获取方法

1. 访问移动云盘网页版：https://caiyun.139.com
2. 登录账号
3. F12 打开开发者工具 → Network（网络） 标签
4. 刷新页面或进行任意操作
5. 选择任一请求，在 Headers（请求头） 中找到 authorization 字段
6. 复制完整的 authorization 值

【移动云盘获取 Authorization - Network 截图】

3.3 天翼云盘（p189）

网盘类型代码：p189
支持认证方式：

• AccessToken（大文件推荐）、
• Cookie（长期有效推荐）、
• 用户名密码 （内测，可能会触发验证–需要关闭设备锁）

配置难度：⭐⭐⭐

配置字段（方式一：AccessToken - 推荐）

配置字段（方式二：Cookie）

配置字段（方式三：用户名密码，需要关闭安全认证）

重要提示：使用用户名密码方式前，需要在天翼云盘账号设置中关闭安全认证（如短信验证、扫码登录等），否则登录会失败。
关闭方式：

1. 打开https://e.dlife.cn/portal/web/index.html 登录
2. 关闭设备锁

获取方法

1. 访问天翼云盘网页版：https://cloud.189.cn
2. 登录账号
3. F12 → Application → Local Storage → https://cloud.189.cn
4. 查找 accesstoken 字段并复制其值

【天翼云盘获取 accesstoken - Local Storage 】请切换移动视图

【天翼云盘获取 cookie 】xhr过滤 listFiles

注意事项：

• ⚠️ 天翼云盘 Token 有效期约 30天， cookie有效期一年左右，过期需重新获取
• 🔗 手机端配置指南：nfd-vip配置指南

3.4 123网盘–服务器IP解析有限制 当前无法使用 仅限于本地部署服务（ye）

网盘类型代码：ye
支持认证方式：用户名密码
配置难度：⭐⭐

配置字段（方式一：用户名密码）

获取方法（方式一）

直接填写您的123网盘账号和密码即可。

注意事项：

• 💡 推荐使用用户名密码方式，更稳定
• ⚠️ 123网盘可能存在区域限制

3.5 小飞机网盘（fj）

网盘类型代码：fj
支持认证方式：用户名密码
配置难度：⭐

配置字段

获取方法

直接使用您在小飞机网盘注册的账号密码。

配置示例

配置名称: 我的小飞机账号网盘类型: fj认证方式: password用户名: your_username密码: your_password

注意事项：

• ⚠️ 小飞机网盘需要代理访问，请确保已在 app-dev.yml 中配置代理
• 📌 详见 doc/相关问题文档.md 第1章

【截图预留位置7：小飞机网盘配置示例】

3.6 蓝奏云优享（iz）

网盘类型代码：iz
支持认证方式：用户名密码
配置难度：⭐

配置字段

获取方法

直接使用您的蓝奏云优享版账号密码。

注意事项：

• 📌 蓝奏云优享（付费版）不同于免费版蓝奏云（lz）
• ⚠️ 同样需要代理访问

【截图预留位置8：蓝奏云优享配置示例】

3.7 夸克网盘（qk）

网盘类型代码：qk
支持认证方式：Cookie
配置难度：⭐⭐

配置字段

获取方法

1. 访问夸克网盘：https://pan.quark.cn
2. 登录账号
3. F12 → Application → Cookies → https://pan.quark.cn
4. 右键点击任一 Cookie → Show Cookies in Headers 或手动拼接所有 Cookie
5. 复制完整的 Cookie 字符串（格式：key1=value1; key2=value2; ...）

【夸克网盘获取 Cookie 】xhr过滤 list

3.8 UC网盘（uc）

网盘类型代码：uc
支持认证方式：Cookie
配置难度：⭐⭐

配置方法与夸克网盘（qk）相同，访问 https://drive.uc.cn 获取 Cookie。

3.9 阿里云盘（pali）暂不支持

3.10 QQ微云（qqwy）

网盘类型代码：qqwy
支持认证方式：Cookie
配置难度：⭐⭐

获取方法

1. 访问 QQ 微云：https://www.weiyun.com
2. 登录 QQ 账号
3. 按前述方法获取 Cookie

【截图预留位置11：QQ微云获取 Cookie 截图】

3.11 免认证网盘

以下网盘无需配置认证信息，系统默认支持：

配置方式：

• 在后台新增配置时，选择对应网盘类型
• 认证方式选择 none
• 无需填写其他认证字段
• 直接保存即可

4. 详细配置步骤

1. 点击“新增网盘配置”。
2. 选择网盘类型（如天翼云盘 p189）。
3. 按需填写认证信息（如 accesstoken、cookie、用户名/密码等）。
4. 可填写备注，便于区分。
5. 保存后即可生效。

【截图预留：新增网盘配置表单填写示例】

5. 常见问题与排查

• Token 失效：请重新获取并更新认证信息。
• 解析失败：检查认证信息是否正确、是否需要代理等。
• 详细排查见“doc/相关问题文档.md”。

如需详细配置示例或遇到特殊网盘类型，请参考官方文档或联系技术支持。

nfd-vip（netdisk-fast-download专属版）配置指南

支持电脑端和安卓手机端
安卓手机端需要via浏览器和插件

电脑端

配置域名和预览URL

配置大文件解析Token

当前大文件支持 蓝奏优享、123、小飞机、天翼云盘、移动云盘、联通云盘

手机端配置指南

1. 下载via浏览器 https://viayoo.com/zh-cn/

2. 安装vConsole插件 设置-脚本-添加脚本，复制下面脚本添加到via中，完成后打开任意网站如果出现vConsole绿色图标即配置成功

// ==UserScript==// @name         vConsolev// @namespace    https://viayoo.com/ldqu2n// @version      0.2// @description  via vConsole// @author       You// @run-at       document-start// @match        *://*/*// @grant        none// ==/UserScript==(function() {    'use strict';    var s = document.createElement('script');    s.src = 'https://cdnjs.cloudflare.com/ajax/libs/vConsole/3.15.1/vconsole.min.js';    s.onload = function() {        new VConsole();        console.info('vConsole 3.15.1 ready');    };    document.head.appendChild(s);})();

3. 登录相关网盘获取认证信息

天翼云盘AccessToken获取方式:

登录天翼云盘:
https://h5.cloud.189.cn/home.html

打开via vConsole控制台 在storage里找到accessToken复制即可

常见问题

该版本来源于某国外网站pydroid mod版本，基于这个版本做了中文汉化

下载地址

pydroid3 8.01中文版
预制库插件
权限插件

备用下载地址

pydroid3 8.01中文版
预编译库插件
权限插件

常见问题

应用安装不上？签名异常可以卸载之前已经安装的版本，插件需要去应用管理里卸载。

pip依赖安装慢或者卡死怎么办？科学上网下载/配置清华pip镜像，参考清华pip镜像配置指南

pip安装失败，大多数可以去pypi找历史版本，有些依赖不支持arm64架构没办法

Java基础

Java笔记01：基础语法01-初识Java

Java笔记02：基础语法02-变量

Java笔记03：基础语法03-基本数据类型和分支结构（上）

Java笔记04：基础语法04-分支结构（下）和循环结构（上）

Java笔记05：基础语法05-循环结构（下）

Java笔记06：基础语法06-数组

Java笔记07：基础语法07-方法

Java笔记08：面向对象01-初识类和对象

Java笔记09：面向对象02-对象的属性和方法

Java笔记10：面向对象03-构造方法和继承

Java笔记11：面向对象04-构造方法和方法重写

Java笔记12：面向对象05-包和访问修饰符

Java笔记13：面向对象06-抽象类和抽象方法

Java笔记14：面向对象07-内部类

Java笔记15：面向对象08-接口

Java笔记16：面向对象09-多态

基础进阶

String

StringBuilder

包装类

Object类

IO常用类

声明

Pydroid7.2中文整合版基于Google play的pydroid7.2修改，解锁高级功能参考了云中龙++发布的pydroid3v7.0DIC

该版本仅供学习参考使用，禁止任何二次售卖行为（APP关于界面提供打赏入口，打赏支持，不胜感激！），如果条件允许，建议付费支持一下官方正版。

教程更新日志

2024-03-31 发布7.2汉化整合版, 打包了插件提供的所有依赖, 直接安装即可，本次更新修复了pydroid3无法访问全部文件的问题。

2023-11-18 发布7.0汉化整合版, 打包了插件提供的所有依赖, 直接安装即可(为了表述方便，以后包含所有obb依赖的全量版统一称之为整合版)

2023-07-19 发布6.2.1汉化整合版, 打包了插件提供的所有依赖, 直接安装即可

2023-04-28 发布6.2汉化版, 使用云安装脚本简化安装流程; 之前的版本安装繁琐不建议使用

2023-04-22 网盘直链下载解析器重构完成, 测试应该没啥问题, 如果遇到无法下载的问题, 请及时和我联系

版本说明（v7.2）

• Pydroid3v7.2汉化整合版需要安装2个Apk分别是Pydroid3v7.2中文整合版主程序Pydroid 3_7.2_arm64_q_cn.apk、Pydroid3权限插件Pydroid Permissions Plugin_2.2_sign.apk，都是在原版基础上重新签名如果存在签名冲突，需要卸载之前版本和插件重新安装。

• 该版本和原版的区别：

  • 内置了预制库插件提供Whl库因此APK体积膨胀到了300+M安装后2.3g左右，如人工智能机器学习相关领域开发的TensorFlow和PyTorch，图像识别相关的OpenCV，QT组件库等等，如果只是基于Console学习Python入门可以不必安装整合版, 安装精简版即可, 体积更小(60M)。

  • 解释所有高级版特性。

  • 默认主题改为黑色，默认字体改为12号，默认关闭信息收集，去除订阅管理以及所有订阅相关菜单项，默认允许键盘建议（防止出现输入法为安全键盘问题）。

• 该版本同时提供汉化版和英文版，由于精力有限，仅提供aarch64架构版本，其他x86或者arm等需求可付费定制。

• 从7.0完整版开始可以升级安装7.2的完整版，不必重新安装，权限插件无需升级。

• 新安装后首次启动会解压资源包，耗时比较长(1-3分钟)。

• 为什么要制作整合版本：开箱即用，免去用户手动安装各类依赖的麻烦，避免了有些依赖安装失败导致的各类问题，使用jupyter仅需一行命令：jupyter notebook。

视频讲解:

下载地址

Pydroid3v7.2中文整合版主程序

Pydroid3v7.2英文整合版主程序

Pydroid3权限插件

备用下载地址

移动云空间网盘分享_Pydroid3v7.2中文整合版主程序

移动云空间网盘分享_Pydroid3v7.2英文整合版主程序

移动云空间网盘分享_Pydroid3权限插件

安装指南

1. 根据需求下载安装一个中文版或者英文版主程序和一个插件，如果之前安装过7.0整合版可以只安装主程序。

2. 初次打开Pydroid会进行Python初始安装, 因为是整合版所以安装会比较慢一般不会超过3分钟（视手机性能而定）。

常见问题

1. 安装失败:

• 签名冲突 卸载旧版本和插件, 插件没有图标需要在系统设置-应用管理卸载

• 不兼容: 当前只支持aarch64架构

2. pyzstd安装报错：终端下运行

pip install pyzstd==0.15.6

3. pip安装某些依赖库失败: 这个问题比较普遍, Pydroid能力有限, 如果指定旧版本安装依旧报错的话也没办法.

4. 代码运行报错或者其他疑难杂症，Google/Bing/百度/一下，或者进去QQ群（1026766509）讨论，或者留言评论，或者去问题反馈平台截图提问，由于博主精力有限加QQ视问题难度提供付费解答。

5. 为了防止后台切换时软件重启导致丢失代码，建议关闭电量优化：MIUI-省电策略-无限制。

重装idea时必备插件

• IDE Eval Rest 白嫖用的 需要添加插件源 https://plugins.zhile.io
• GitToolBox inline blame annotation
• CamelCase 切换命名风格–比如驼峰<->下划线 CTRL+ALT+U
• CodeGlance 略缩图 CTRL+SHIFT+G
• Codota AI Autocomplete for Java 代码提示补全工具
• GitHub Copilot 代码提示补全工具(比较逆天 慎用)
• Jrebel 热部署(付费, 需要POJIE)
• 主题相关
  • Dark purple
  • Dracula
  • One Dark
  • Atom Material Icons
• PlantUML 通过coding自动生成UML图 需要安装额外的EXE
• Rainbow Brackets 彩虹括号, 字面意思, 美化回调地狱下的括号 使之更有辨识度
• statistic 代码统计, 可以看到你今天敲了几行代码
• 翻译相关:
  • Chinese 中文语言包 idea官方出的中文插件
  • Translation 翻译文档注释 代码等等
• 语言增强
  • vue
  • python
  • AsciiDoc
  • bat支持, shell支持等
• 其他
  • Sudoku Plugin 摸鱼不解释
  • Leetcode editor 搬砖不忘刷题

11. 未完待续…随缘更新
    
    
    
    

测试命令

1. 网盘下载

# jdk-8u202-linux-x86.tar.gzcurl -L   https://lz.qaiu.top/cow/dab06dd8cf8b42 > /dev/null

2. 镜像源下载

curl https://mirrors.aliyun.com/centos/7.9.2009/isos/x86_64/CentOS-7-x86_64-DVD-2009.iso -o /dev/null

1. 天翼云1Mbps(华东1-扬州)

网盘下载  % Total    % Received % Xferd  Average Speed   Time    Time     Time  Current                                 Dload  Upload   Total   Spent    Left  Speed  0     0    0     0    0     0      0      0 --:--:-- --:--:-- --:--:--     0  0  185M    0  958k    0     0   115k      0  0:27:20  0:00:08  0:27:12  118k镜像源下载  % Total    % Received % Xferd  Average Speed   Time    Time     Time  Current                                 Dload  Upload   Total   Spent    Left  Speed  0 4494M    0  545k    0     0   134k      0  9:30:04  0:00:04  9:30:00  134k^

2. 天翼云5Mbps (华东1-扬州)

网盘下载  % Total    % Received % Xferd  Average Speed   Time    Time     Time  Current                                 Dload  Upload   Total   Spent    Left  Speed  0     0    0     0    0     0      0      0 --:--:-- --:--:-- --:--:--     0  1  185M    1 3125k    0     0   574k      0  0:05:29  0:00:05  0:05:24  563k^ 镜像源下载  % Total    % Received % Xferd  Average Speed   Time    Time     Time  Current                                 Dload  Upload   Total   Spent    Left  Speed  0 4494M    0 5938k    0     0   610k      0  2:05:37  0:00:09  2:05:28  564k

3 天翼云5Mbps-windows (山东-青岛1)

4. 腾讯云6Mbps(北京)

[root@VM-0-3-centos ~]# curl -L  http://lz.qaiu.top/cow/dab06dd8cf8b42 > /dev/null  % Total    % Received % Xferd  Average Speed   Time    Time     Time  Current                                 Dload  Upload   Total   Spent    Left  Speed100   178  100   178    0     0   1327      0 --:--:-- --:--:-- --:--:--  1328  0     0    0     0    0     0      0      0 --:--:-- --:--:-- --:--:--     0100  185M  100  185M    0     0  11.9M      0  0:00:15  0:00:15 --:--:-- 12.1M

5. 阿里云1Mbps(乌兰察布)

#[root@iZ0jlc8zj9cfcvxa8e6lpcZ ~]# curl https://mirrors.aliyun.com/centos/7.9.2009/isos/x86_64/CentOS-7-x86_64-DVD-2009.iso -o /dev/null  % Total    % Received % Xferd  Average Speed   Time    Time     Time  Current                                 Dload  Upload   Total   Spent    Left  Speed  0 4494M    0 3777k    0     0   314k      0  4:04:10  0:00:12  4:03:58  327k[root@iZ0jlc8zj9cfcvxa8e6lpcZ ~]# curl -L   https://lz.qaiu.top/cow/dab06dd8cf8b42 > /dev/null  % Total    % Received % Xferd  Average Speed   Time    Time     Time  Current                                 Dload  Upload   Total   Spent    Left  Speed  0     0    0     0    0     0      0      0 --:--:-- --:--:-- --:--:--     0 14  185M   14 27.0M    0     0  3569k      0  0:00:53  0:00:07  0:00:46 4475k

总结

1. 天翼华东1-扬州上下行均限速 带宽为实际分配公网带宽, 青岛区下行不限速
2. 腾讯云,阿里云 仅上行(出口)限速 下行不限速

我的博客即将同步至腾讯云开发者社区，邀请大家一同入驻：https://cloud.tencent.com/developer/support-plan?invite_code=200x930updokc

#Excel 提取姓名首字母公式

1. 公式

1. 无法区分多音字
2. 个别字和生僻字识别有误
   因此需要手动校对

=VLOOKUP(MID(C2,1,1),{"",0;"吖","A";"八","B";"攃","C";"咑","D";"鵽","E";"发","F";"旮","G";"哈","H";"丌","J";"咔","K";"垃","L";"妈","M";"乸","N";"噢","O";"帊","P";"七","Q";"冄","R";"仨","S";"他","T";"屲","W";"夕","X";"丫","Y";"帀","Z"},2)&VLOOKUP(MID(C2,2,1),{"",0;"吖","A";"八","B";"攃","C";"咑","D";"鵽","E";"发","F";"旮","G";"哈","H";"丌","J";"咔","K";"垃","L";"妈","M";"乸","N";"噢","O";"帊","P";"七","Q";"冄","R";"仨","S";"他","T";"屲","W";"夕","X";"丫","Y";"帀","Z"},2)&(IF(LEN(C2)>2,VLOOKUP(MID(C2,3,1),{"",0;"吖","A";"八","B";"攃","C";"咑","D";"鵽","E";"发","F";"旮","G";"哈","H";"丌","J";"咔","K";"垃","L";"妈","M";"乸","N";"噢","O";"帊","P";"七","Q";"冄","R";"仨","S";"他","T";"屲","W";"夕","X";"丫","Y";"帀","Z"},2),""))

2. VBS宏

不支持WPS个人版(免费)

Function Getpychar(char)temp = 65536 + Asc(char)If (temp >= 45217 And temp <= 45252) ThenGetpychar = "A"ElseIf (temp >= 45253 And temp <= 45760) ThenGetpychar = "B"ElseIf (temp >= 45761 And temp <= 46317) ThenGetpychar = "C"ElseIf (temp >= 46318 And temp <= 46825) ThenGetpychar = "D"ElseIf (temp >= 46826 And temp <= 47009) ThenGetpychar = "E"ElseIf (temp >= 47010 And temp <= 47296) ThenGetpychar = "F"ElseIf (temp >= 47297 And temp <= 47613) ThenGetpychar = "G"ElseIf (temp >= 47614 And temp <= 48118) ThenGetpychar = "H"ElseIf (temp >= 48119 And temp <= 49061) ThenGetpychar = "J"ElseIf (temp >= 49062 And temp <= 49323) ThenGetpychar = "K"ElseIf (temp >= 49324 And temp <= 49895) ThenGetpychar = "L"ElseIf (temp >= 49896 And temp <= 50370) ThenGetpychar = "M"ElseIf (temp >= 50371 And temp <= 50613) ThenGetpychar = "N"ElseIf (temp >= 50614 And temp <= 50621) ThenGetpychar = "O"ElseIf (temp >= 50622 And temp <= 50905) ThenGetpychar = "P"ElseIf (temp >= 50906 And temp <= 51386) ThenGetpychar = "Q"ElseIf (temp >= 51387 And temp <= 51445) ThenGetpychar = "R"ElseIf (temp >= 51446 And temp <= 52217) ThenGetpychar = "S"ElseIf (temp >= 52218 And temp <= 52697) ThenGetpychar = "T"ElseIf (temp >= 52698 And temp <= 52979) ThenGetpychar = "W"ElseIf (temp >= 52980 And temp <= 53640) ThenGetpychar = "X"ElseIf (temp >= 53689 And temp <= 54480) ThenGetpychar = "Y"ElseIf (temp >= 54481 And temp <= 62289) ThenGetpychar = "Z"ElseGetpychar = charEnd IfEnd FunctionFunction Getpy(str)For a = 1 To Len(str)Getpy = Getpy & Getpychar(Mid(str, a, 1))Next aEnd Function

• Java笔记01：基础语法01-初识Java

• Java笔记02：基础语法02-变量

• Java笔记03：基础语法03-基本数据类型和分支结构（上）

• Java笔记04：基础语法04-分支结构（下）和循环结构（上）

• Java笔记05：基础语法05-循环结构（下）

• Java笔记06：基础语法06-数组

• Java笔记07：基础语法07-方法

• Java笔记08：面向对象01-初识类和对象

• Java笔记09：面向对象02-对象的属性和方法

• Java笔记10：面向对象03-构造方法和继承

• Java笔记11：面向对象04-构造方法和方法重写

• Java笔记12：面向对象05-包和访问修饰符

• Java笔记13：面向对象06-抽象类和抽象方法

• Java笔记14：面向对象07-内部类

• Java笔记15：面向对象08-接口

• Java笔记16：面向对象09-多态

• String

• StringBuilder

• 包装类

• Object类

• IO常用类