Passer au contenu principal
G

dsh-dual-proxy

gambn/dsh-dual-proxy

Agent gateway manager: picks a working gateway among proxies and direct, verifies the model channel, and switches online; DSH plugin plus standalone CLI.

Installer

dsh plugin --profile web add github:gambn/dsh-dual-proxy

README

dsh-dual-proxy

中文 · English

CI npm

Agent 的网关管理插件:在多个网关之间在线自动切换,让模型请求不再被一条不稳的路卡死。

它把「agent 到模型端点的网络路径」当成可管理的资源:在配置的上游、额外指定的代理、启动环境里的代理和直连之间自动选一条能通的;运行中用真实请求持续验证,失败立刻切到下一条——不需要重启宿主,也不需要改客户端配置。

快速开始

# DSH 插件(npm)
dsh plugin --profile web add dsh-dual-proxy

# 独立 CLI
npm install -g dsh-dual-proxy

要求 Node.js ≥ 22.19.0;DSH 插件还要求 dsh ≥ 0.1.7。插件安装后确认 dsh.profile.bundles 含 dsh-dual-proxy,再重启 dsh web;细节见下文。

从源码安装(可选):

git clone https://github.com/gambn/dsh-dual-proxy.git
cd dsh-dual-proxy
npm install
dsh plugin --profile web add "$PWD"

两种形态,同一份核心:

  • DSH 插件(推荐):随 DSH 启停,配置在「设置 → 插件」里改,可把宿主自身的模型请求接进来;
  • 独立进程:手动跑 CLI,或挂 systemd 用户服务,非 DSH 宿主的 agent 与脚本也能直接用。

它解决什么

上游代理并不稳定:同一个代理可能对 A 站通、对 B 站不通,也可能整段时间全挂;本机同时装着两个代理时,哪个能用还会变。只认一条路的客户端在这种时候会成片失败,而在死路上重试只是拖延。

这一层把候选路都握在手里,按 host 选:

客户端 → 127.0.0.1:7898
           ├── 网关 A(TLS 探测通过)→ 上游代理
           ├── 网关 B(TLS 探测通过)→ 上游代理
           └── 都探测失败 → 直连

健康检查用一个真实请求把同一组候选走一遍,谁先给出 <500 的响应,谁就成为全局首选。

行为

  • 候选网关 = upstreamHost:upstreamPort(或 upstreamUrl)+ gateways + 启动环境的 HTTP(S)_PROXY/ALL_PROXY,去重并排除自身监听端口,最后补 direct。
  • 目的地分流规则(0.7.3,人工名单):preferDirect / --prefer-direct(或 PREFER_DIRECT)和 preferProxy / --prefer-proxy(或 PREFER_PROXY)按目标 host 指定先直连或先走代理,逗号分隔,支持 * 通配;只匹配归一化后的 host(小写、去方括号/尾点;IDN 按 punycode),不接受正则、CIDR、端口或 URL 路径。优先级:规则 > per-host 缓存 > 全局健康首选 > 默认候选顺序;两名单同时命中时直连优先;规则只在 hot 区调整顺序,冷却中的网关不会被拉回;未命中规则的 host 候选顺序维持原行为(冷却语义见下方两档冷却)。*.cn 不匹配 cn 本身,也不匹配 deepseek.cn,要覆盖 apex 需显式写 deepseek.cn。这是人工策略,不是自动国内/海外分类。
  • 上游代理认证:upstreamUrl、gateways 或环境变量里的 HTTP 代理 URL 可带 user:pass;连接代理时会带 Proxy-Authorization: Basic。当前只支持 http:// 上游代理:upstreamUrl 传 https:// 会报错;额外候选(gateways、--gateway、GATEWAY、启动环境代理)里的 https:// 或非法值会给脱敏 warning 后跳过。Basic 只是 base64,不是加密,只建议回环或受信任网络。
  • CONNECT(HTTPS):443 上先对候选做 TLS 握手探测,通过的才用来开隧道;失败换下一条。
  • 普通 HTTP:请求体先缓冲(上限 8 MB),按同一顺序换路重放;建连用 attemptTimeoutMs(已知路径用 fastFailTimeoutMs),等响应头用 responseTimeoutMs,响应体开始流之后不再计时。
  • 幂等键重放:打开 retryNonIdempotentWithIdempotencyKey 后,非幂等请求只有在带非空 Idempotency-Key/X-Idempotency-Key 时才允许发送后重放;代理不验证上游是否真的去重。
  • 重放策略(仅普通 HTTP,CONNECT 隧道不重放):到网关/目标的 TCP 连接还没建立就失败时,任何方法都重放;连接建立后失败时,只重放幂等方法(GET/HEAD/OPTIONS/TRACE/PUT/DELETE)。POST/PATCH 等默认停止并回 502,响应体是 non-idempotent request may have been delivered; not replayed;需要旧行为时打开 retryNonIdempotentAfterSend。
  • 已知路径的快失败只覆盖建连阶段:缓存或健康首选的那条网关,TCP 连不上时 2 秒内换路;如果它连上了却迟迟不回响应头,仍要等满 responseTimeoutMs(默认 60 秒)。
  • 健康检查:每 healthIntervalMs 用 GET healthUrl 验证一次通道,<500 就算通(401/403 说明端点活着);通过者设为全局首选,全部失败则清掉首选、下次请求重新扫描。设为 0 关闭。
  • 每 host 偏好缓存(默认 60 秒,最多 1000 条,LRU 淘汰):缓存命中跳过探测;失败即切换。
  • 失败网关冷却(默认 30 秒):某条路失败后进入冷却,期间排到最后,别的 host 不会再先撞它;健康检查证明它恢复时自动解除。
  • 失败即复检:任何一条路刚失败就踢一次健康检查(1 秒内只踢一次),不用等下一个 60 秒周期。
  • 接入宿主(routeHostFetch,插件形态):用 undici 全局 dispatcher 把进程内的 fetch 引到本代理,模型请求因此真的经过这里选路;回环地址默认直连,禁用/卸载时恢复原来的 dispatcher。
  • 逐跳标头按 RFC 9110 过滤(Connection 及其点名的字段、Proxy-Connection、Transfer-Encoding 等),Host 重写为目标主机;响应方向的逐跳标头同样清掉。
  • IPv6:CONNECT 支持 [::1]:443 这类字面量,host 统一去掉方括号、转小写、去掉 FQDN 末尾的点。
  • 关闭最多等 shutdownTimeoutMs(默认 1.5 秒,内部选项,不在设置页与 CLI 暴露)让在途请求自然结束,超时后强制断开所有 socket。
  • 全部候选都失败时回 502;非幂等请求在连接建立后失败且未开 retryNonIdempotentAfterSend、也没有可用的幂等键开关时,也会立即回 502,不再尝试剩余候选。
  • 日志只写主机、网关与原因,不记录任何请求内容。

作为 DSH 插件

# 已发布到 npm 后
dsh plugin --profile web add dsh-dual-proxy

# 本地 / link 安装
cd /path/to/dsh-dual-proxy && npm install   # 链接安装不会把依赖装进项目目录
dsh plugin --profile web add /path/to/dsh-dual-proxy

运行要求 Node.js ≥ 22.19.0(undici 8 的要求);版本不满足时 CLI 会直接报错退出,插件加载也会给出明确错误。插件形态需要 dsh ≥ 0.1.7(设置页的 volatile 表单从该版本开始提供)。

确认 ~/.dsh/profiles/web/package.json 的 dsh.profile.bundles 里包含 dsh-dual-proxy(插件包里带 cordis.patch.yml,加进 bundles 才会被组合),然后重启 dsh web。启用后在「设置 → 插件」里可以看到并修改:

字段默认说明
listenHost127.0.0.1监听地址
listenPort7898监听端口
portFallback0EADDRINUSE 时按端口 +1 重试的个数;默认 0 保持固定入口
upstreamHost127.0.0.1第一个候选网关
upstreamPort7897第一个候选网关的端口
upstreamUrl空第一个候选的完整 URL,可含 user:pass;非空时覆盖 upstreamHost/upstreamPort,非法值直接报错
gateways空额外候选网关,host:port 逗号分隔
preferDirect空这些 host 先试直连,逗号分隔,支持 * 通配
preferProxy空这些 host 先试代理,逗号分隔,支持 * 通配
routeHostFetchfalse把宿主进程的 fetch 引到本代理(bundle patch 里默认打开)
healthUrlhttps://api.deepseek.com通道验证地址;空则关闭后台验证(443 仍做 TLS 探测,普通 HTTP 只按顺序试)
healthIntervalMs60000健康检查间隔;0 关闭
fastFailTimeoutMs2000已知路径(缓存/首选)的建连超时
cooldownMs30000失败网关的冷却时长;0 关闭
retryNonIdempotentAfterSendfalse连接建立后失败时也重放 POST/PATCH(危险,默认关)
retryNonIdempotentWithIdempotencyKeyfalse仅当请求带非空 Idempotency-Key/X-Idempotency-Key 时,允许发送后重放非幂等请求
attemptTimeoutMs5000每次尝试/探测超时
responseTimeoutMs60000普通 HTTP 等响应头的上限
prefTtlMs60000每 host 偏好缓存 TTL
verifyTlstrue443 上是否做 TLS 探测

0.6.0 行为变更:POST/PATCH 在连接建立后失败不再自动换路重放,改为 502;需要旧行为时打开 retryNonIdempotentAfterSend。

routeHostFetch 打开后,DSH 自己的模型请求会先到 7898 再按网关选路。它作用于进程内的所有 fetch(不止模型调用);pnpm、git 这类子进程不继承,仍按启动环境里的代理走。插件被禁用或卸载时,原来的 dispatcher 会被还原。

端口冲突:插件会占用 7898。如果之前挂过独立进程版或 systemd 服务,先停掉:

systemctl --user disable --now dsh-dual-proxy 2>/dev/null

作为独立进程

node bin/dsh-dual-proxy.js --listen-port 7898 --upstream-port 7897 \
  --gateway 127.0.0.1:12334 --health-url https://api.deepseek.com
参数默认说明
--listen-host127.0.0.1监听地址
--listen-port7898监听端口
--port-fallback0EADDRINUSE 时按端口 +1 重试的个数
--print-config—打印最终生效配置后退出(别名 --dry-run)
--upstream-host127.0.0.1第一个候选网关
--upstream-port7897第一个候选网关的端口
--upstream-url—第一个候选的完整 URL,可含 user:pass;非空时覆盖 host/port
--gateway—额外候选网关,可重复
--prefer-direct空这些 host 先试直连,逗号分隔,支持 * 通配
--prefer-proxy空这些 host 先试代理,逗号分隔,支持 * 通配
--health-url空通道验证地址
--health-interval-ms60000健康检查间隔,0 关闭
--fast-fail-ms2000已知路径的建连超时
--cooldown-ms30000失败网关的冷却时长
--timeout-ms5000每次尝试/探测超时
--response-timeout-ms60000普通 HTTP 等响应头的上限
--pref-ttl-ms60000每 host 偏好缓存 TTL
--no-verify-tls关跳过 443 的 TLS 探测
--retry-non-idempotent-after-send关连接建立后失败时也重放 POST/PATCH
--retry-non-idempotent-with-idempotency-key关带 Idempotency-Key 时允许发送后重放

环境变量同名(LISTEN_HOST、LISTEN_PORT、PORT_FALLBACK、UPSTREAM_HOST、UPSTREAM_PORT、UPSTREAM_URL、GATEWAY、PREFER_DIRECT、PREFER_PROXY、HEALTH_URL、HEALTH_INTERVAL_MS、FAST_FAIL_MS、COOLDOWN_MS、ATTEMPT_TIMEOUT_MS、RESPONSE_TIMEOUT_MS、PREF_TTL_MS、VERIFY_TLS=0、RETRY_NON_IDEMPOTENT_AFTER_SEND=1、RETRY_NON_IDEMPOTENT_WITH_IDEMPOTENCY_KEY=1)。

systemd 用户服务模板在 contrib/。

配合 Claude Code

Claude Code 是原生二进制,不能像 DSH 那样把 fetch 引到进程内;适配方式是用启动器包一层:代理在启动器进程里监听,再把代理环境变量指向它并启动 claude。

# 默认监听 7896;`--` 之后原样交给 claude
claude-dual-proxy --listen-port 7896 --gateway 127.0.0.1:12334 -- --resume

启动器会:按与独立进程相同的方式解析候选网关;端口默认 7896,EADDRINUSE 时默认向后找 10 个端口并把实际端口交给子进程;给子进程设置 HTTP_PROXY/HTTPS_PROXY(大小写各一份)和 ALL_PROXY,并替换掉启动环境里 socks 的 ALL_PROXY;把回环地址并入 NO_PROXY;claude 退出时关闭代理。子进程的 ANTHROPIC_BASE_URL、ANTHROPIC_AUTH_TOKEN 等变量保持不变。

宿主适配层与核心的边界:包入口(src/index.js)仍是 DSH 插件,实现在 src/adapters/dsh.js;宿主无关的核心通过 dsh-dual-proxy/core 导出(createDispatcher、resolveUpstream、collectGateways 等),其他宿主可以只依赖这一层。

测试

npm test

测试面向仓库或源码快照;首次先在源码目录 npm install,再 npm test。npm 包不含 test/,安装后不能直接跑这套用例。

用例覆盖:HTTP 直连回退、经假代理转发、多个网关时跳过不通的、两条都不通返回 502、黑洞网关按超时换路、请求与响应两个方向的逐跳标头过滤、上游中途断开不带崩进程、CONNECT 直连隧道与经假代理隧道、CONNECT 200 同包早期数据、IPv6 字面量、缓存网关卡住时快失败换路、失败网关冷却后不再先撞、两档冷却的 host 隔离与 phase 分类、流式 reset 不记冷却、目的地规则(解析/匹配/优先级/健康与缓存覆盖/CLI/env)、关闭时强制断开在途隧道、网关解析与去重(含自身端口排除与自环防护)、健康检查的选择与失败、健康循环记住首选、失败踢一次健康检查、健康检查重入锁、偏好缓存上限、CLI 参数校验与退出码、端口退避与 EADDRINUSE 诊断、socks 告警去重、--print-config、插件生命周期(启动/重启/双 context)、自签证书的 TLS 探测、非幂等重放策略(send 前后边界、方法分类、开关、日志与冷却)、上游代理认证(CONNECT/HTTP/健康检查、407)、带幂等键的发送后重放(开关/键存在性/日志)、以及 fetch 路由的安装/替换/回滚与回环绕过。

排障

  • 端口没有监听者,listen 仍报 EADDRINUSE:先看 ss -tan | grep :7898。同一端口上由别的进程建立过的短连接会留下 TIME-WAIT;如果它建立时没带 SO_REUSEADDR,后来者即使带 Node 的 reuseAddress 也绑不上。换端口,或用 --port-fallback 自动退避;日志会打印实际监听端口。DSH 插件默认 0,保持 7898 这个已知入口;CLI 和 claude-dual-proxy 可显式开启。
  • 启动日志出现 socks ... skipped:上游只支持 http:// 代理,ALL_PROXY=socks://... 会被跳过,这是预期行为。

0.7.3 行为变更

新增人工目的地规则;冷却从单一网关级改为两档。没有规则时请求的候选顺序与 0.7.2 一致,但 direct/TLS/等头/reset 的冷却不再跨 host 污染,代理自身失败仍全局冷却。

边界

  • 只处理 HTTP/1.1 的 CONNECT 与普通 HTTP;不做透明代理、不接管 UDP。
  • 普通 HTTP 请求在网关连上后要等满 responseTimeoutMs(默认 60 秒)才判定响应头超时;0.7.3 不缩短这个等待,幂等键只改变超时后的重放决策。
  • CONNECT 隧道建立后代理只转发字节,TLS 端到端;隧道内失败无法换路,要覆盖只能做 MITM 解密,和本项目“不拦截”的定位冲突。
  • 不校验证书,不缓存内容,不做鉴权。默认只绑回环;把 listenHost 改成非回环地址会在启动时告警——那等于开放一个无鉴权代理,风险自负。
  • 上游代理认证只支持 http:// 的 Basic;不支持 https:// 上游代理(TLS-to-proxy)。Basic 只适合回环或受信任网络,远程代理的凭证保护不在本项目范围内。
  • 只负责「到不到得了」,不负责「信不信得过」——证书校验仍是客户端的责任。
  • 健康检查只发一个无凭证 GET,判据是「有没有 <500 的响应」,不代表凭证或模型权限有效。
  • 不保证「至多一次」:默认 retryNonIdempotentAfterSend: false 时,POST/PATCH 在连接建立后失败会直接 502(可能已送达、未重放),幂等方法仍会重放;打开该开关会恢复发送后重放,代价是可能重复执行。客户端 SDK 对 5xx 的自动重试不受代理控制,对计费或写入敏感的调用仍应在上游使用幂等键。

反馈

问题、建议与使用疑问走 GitHub Issues:https://github.com/gambn/dsh-dual-proxy/issues。请勿在 Issue 里粘贴 token、密钥或完整请求内容;安全问题见 SECURITY.md。

License

MIT

Plugins associés