Manjusaka - 牛屎虾

高性能 · 高安全 · 全平台 · 开源免费

📈 Star 历史曲线

牛屎虾

https://github.com/ydhcui/manjusaka

Manjusaka（牛屎虾）——基于 Rust 的全平台远程管理平台，以 AI 决策与执行分离架构为核心：AI 仅负责分析与规划，执行端在远端运行，避免 AI 直接操作本地环境。实现全平台支持、插件生态与趣味交互的完美融合。

✨ 特性

• 🦀 纯血 Rust：极致性能，极致安全，拒绝历史包袱
• 🌐 全平台制霸：Windows、Linux、macOS 通吃，甚至能在树莓派上跑
• 🔥 AI决策分离：AI 只动脑，不动手，再也不怕"龙虾"清空你的本机文件
• 🚀 分段加载：先上线再装逼，npc1 轻量级，npc2 全功能，按需加载
• 🖥️ 虚拟桌面：远程桌面不仅看得见，还能摸得着（VNC 模式）
• 🗄️ 文件管理：分块传输、断点续传，大文件传输稳如老狗
• 🕳️ 隧道玩法：端口转发、SOCKS5 代理，内网穿透玩出花
• 🤖 QQ智能助手：在 QQ 上直接让 AI 帮你内网渗透，摸鱼渗透两不误
• 🧩 插件生态：支持 BOF、Net、EXE 等插件，想加啥功能就加啥，插件文档自动同步为 AI 技能
• 💬 AI聊天：基于 adk-rust 框架，通过聊天的方式进行渗透，危险操作弹窗确认
• 🔐 多协议传输：npc1 支持 HTTP / S3 对象存储信箱（OSS/MinIO 中转，不直接建连），npc2 支持 TCP/KCP/WebSocket，另有 SSH 原生直连；传输层 trait 化，可扩展 icmp、mqtt 等
• 🐚 原生 SSH 连接：无需在目标安装 Agent，直接 SSH 协议接管终端/SFTP/代理
• 🔌 内置 MCP：14 个 nps_* 工具内置在 nps 服务中（HTTP JSON-RPC + 令牌鉴权），Claude / Cursor 直接接入，无需独立网关
• 🗝️ 数据库加密：SQLCipher 全库加密，密钥随机派生

🏗️ 架构设计

flowchart TD
    subgraph Server["管理服务器 (NPS)"]
        WebAPI["Web API + WebSocket<br/>Poem + OpenAPI :33000"]
        McpEnd["内置 MCP 端点 /mcp<br/>JSON-RPC 2.0 + 令牌"]
        AgentMgr["Agent 状态管理<br/>AppState + SQLCipher"]
        AIBot["AI 渗透<br/>adk-rust + Skills + Memory"]
        Bots["机器人<br/>QQ / TG / 企微 / 钉钉 / 飞书"]
    end

    subgraph Agents["客户端"]
        NPC1["NPC1<br/>HTTP :31000 / S3 信箱"]
        NPC2["NPC2<br/>全功能 Agent<br/>终端/VNC/SFTP/SOCKS5"]
        SSH["SSH 原生连接<br/>russh 持久会话"]
    end

    OSS["S3 兼容对象存储<br/>（OSS / MinIO，可选）"]

    subgraph Frontend["前端 (NPU)"]
        SPA["Vue3 SPA<br/>Element Plus + xterm + noVNC"]
    end

    subgraph AIClients["AI 客户端"]
        Claude["Claude Desktop / Cursor"]
    end

    SPA -->|"HTTPS + WebSocket"| WebAPI
    Claude -->|"HTTP JSON-RPC + Bearer"| McpEnd
    WebAPI --> AgentMgr
    AgentMgr <-->|"Noise + Yamux"| NPC2
    AgentMgr <-->|"HTTP API"| NPC1
    AgentMgr <-->|"russh + direct-tcpip"| SSH
    NPC1 <-->|"轮询读写信箱对象"| OSS
    AgentMgr <-->|"服务端 3s 轮询"| OSS
    Bots --> AIBot
    AIBot -->|"RPC / SSH exec"| NPC2

Workspace 结构

manjusaka/
├── Cargo.toml              # Workspace 根配置
├── build.ps1               # 一键编译脚本（Windows + WSL Linux/macOS）
├── docker-deploy.sh        # Docker 一键部署脚本
├── nps/                    # 管理服务器（控制端）
│   ├── src/
│   │   ├── main.rs         # 启动入口（getopts：--scheme http|https）
│   │   ├── core/           # 核心逻辑（状态/SSH/SRDI/数据库密钥）
│   │   ├── models/         # SeaORM 数据模型（SQLCipher）
│   │   ├── npc/            # 客户端管理（npc1 传输 trait: http/s3 + npc2）
│   │   ├── npu/            # Web API + WebSocket + 内置 MCP 端点
│   │   ├── ops/            # 统一工具层（16 个 nps_*，AI 渗透与 MCP 共享）
│   │   ├── aibot/          # AI 渗透（adk-rust 工具/技能/记忆/确认）
│   │   ├── bots/           # 机器人（QQ/TG/企微/钉钉/飞书/Webhook）
│   │   └── protos/         # Protobuf 协议
├── npc1/                   # 轻量客户端（HTTP 直连 / S3 信箱信标）
├── npc2/                   # 增强客户端（全功能 Agent）
├── stub/                   # NPC2 独立可执行拼接加载器
├── npu/                    # Vue3 前端
├── protos/                 # Protobuf 定义（workspace 共享）
├── libs/                   # 共享库
│   ├── transport/          # 传输层抽象（HTTP/S3/ICMP + TCP/KCP/WS）
│   ├── noise/              # Noise 协议加密
│   ├── crypto/             # AES-GCM 加密
│   ├── utils/              # 通用工具
│   ├── coffee/             # BOF 加载器
│   ├── memexec/            # 内存 PE 加载
│   ├── rustclr/            # .NET CLR 托管
│   ├── conpty/             # Windows 伪终端
│   ├── enigo/              # 跨平台输入模拟
│   ├── rustvncserver/      # VNC 服务器
│   └── clipboard/          # 剪贴板重定向
├── license/                # 授权生成器源码（产物复制到 scripts/）
├── scripts/                # 运维工具（license_gen / migratedb 迁移）
├── payloads/               # 预编译植入物
├── plugins/                # 插件库（运行时填充）
├── skills/                 # AI 技能 + 插件技能（运行时填充）
├── certs/                  # TLS 证书
└── data/                   # 数据目录

技术栈

• 编程语言: Rust
• Web 框架: Poem + Poem-OpenAPI
• 数据库: SQLite + SQLCipher 全库加密（通过 SeaORM）
• AI 框架: adk-rust（adk-core + adk-model openai）
• 异步运行时: Tokio
• 序列化: Protocol Buffers
• 加密: AWS-LC-RS, X25519-Dalek, AES-GCM, SQLCipher
• 网络: HTTP/HTTPS, S3 兼容对象存储, WebSocket, KCP, SSH
• 系统交互: sysinfo, netstat2, libloading
• 前端: Vue3 + Element Plus + xterm.js + noVNC

通信协议

• 控制通道: API + WebSocket
• 数据通道: 自定义二进制协议
• 文件传输: 分块传输，断点续传
• 屏幕传输: 智能压缩，增量更新

🧩 核心组件

NPS — 管理服务器

NPS 是整个系统的控制中心，基于 Poem Web 框架 + SeaORM + SQLite 构建。

启动流程（nps/src/main.rs）：

1. 创建 data/、payloads/、plugins/、skills/ 目录
2. 初始化日志（写入 nps.log，支持运行时调整级别）
3. 连接 SQLite 数据库（nps.db，SQLCipher 全库加密），建表并初始化默认数据
4. 加载活跃项目到内存
5. 启动 QQ/Telegram 等机器人
6. 启动 Agent 心跳监控循环（30s 间隔广播状态）
7. 启动 NPC2 监听器（TCP/WS/KCP）与 S3 项目轮询器
8. 启动 NPC1 HTTP 门面（:31000）
9. 启动 Web 管理 API（:33000，默认 TLS；--scheme http 时不启用）

双监听器设计：

Web API 服务（14 个 OpenAPI 模块）：

另有内置 MCP 端点 POST /mcp（JSON-RPC 2.0，纯令牌鉴权，见下文）。

认证机制：

• Cookie 名 AUTH，HttpOnly，24 小时有效期
• AuthMiddleware 拦截所有请求，白名单：/captcha、/login、/loginbyauth
• 自定义 UserSessionStorage：支持按用户名清除所有会话（密码重置后触发）
• 后台每 60s 清理过期会话

状态管理（core/state.rs）： AppState 持有共享状态（全部 Arc<Mutex<>>）：conn（SQLite 连接）、projects（活跃项目）、agents（在线 Agent）、events（事件队列）、agent_tasks（任务快照）、clients（WebSocket 前端）、listens（监听器停止信号）、proxys（代理实例）、payloads（临时下载地址）。

NpsAgent 统一抽象：

struct NpsAgent {
    ntype: String,                              // "npc1" | "npc2" | "ssh"
    npc1: protos::nps::Agent,                    // Agent 基本信息
    npc2: Option<YamuxControl>,                 // NPC2 yamux 多路复用
    ssh: Option<Arc<russh::client::Handle>>,     // SSH 持久会话
    ctrl: Option<mpsc::Sender<()>>,              // 控制通道
}

无论 Agent 是 NPC2 回连还是 SSH 原生连接，最终都统一为 NpsAgent 并通过 AgentEvent 广播给前端。

NPC1 — 轻量客户端

NPC1 是轻量信标 Agent，适合初次植入。传输层已 trait 化，支持两种回连方式：

• HTTP 直连：回连 nps 的 NPC1 HTTP 门面（:31000），GET 拉取任务 / POST 回传结果
• S3 对象存储信箱（dead-drop 模型）：与 nps 不直接建连，双方轮询同一批对象交换数据； 适合目标出网受限但可访问对象存储（阿里云 OSS / MinIO）的场景

首次上线即拿配置：npc1 可默认只内嵌 ip/key 等最小信息，首次经 HTTP 上线后 由服务端下发 S3 信箱配置（含项目级 ak/sk），之后改由 S3 通道上线。

S3 信箱对象布局（单桶多项目）：

{route}/{sha256(agentid)}/up.dat     Agent → NPS 事件（单槽位，处理完删除）
{route}/{sha256(agentid)}/hb.dat     心跳标记（只看存在性）
{route}/{sha256(agentid)}/down.dat   NPS → Agent 配置类事件（读取后删除 = ACK）
{route}/{sha256(agentid)}/task.dat   NPS → Agent 任务类事件（读取后删除 = ACK）

目录名为 agentid 的 sha256 单向哈希，桶内列举不暴露 agent 身份；服务端固定 3s 轮询。

工作流程：

1. 解密内嵌 DNA 配置（AES）
2. 发送 Agent 上线信息（用户名、主机名、内网 IP、PID、平台、架构）
3. 循环：拉取任务 → AES-CBC 解密 → 执行 → 回传结果 → 随机休眠

反检测特性：

• 随机心跳抖动（jitter）
• Hook GetExtendedTcpTable 隐藏 TCP ESTABLISHED 连接
• obfstr 编译期字符串混淆
• AES 加密的内嵌配置
• 伪装验证码流量（未知路由返回 CAPTCHA 图片）

通信： Protobuf 消息体，AES-CBC 加密，Base64 编码；S3 模式下为对象读写。

NPC2 — 增强客户端

NPC2 是全功能 Agent，基于 russh 构建，支持终端、VNC、SFTP、SOCKS5 等。

连接方式：

连接建立流程（npc2/src/core.rs）：

1. 构建 Agent 信息（sysinfo 采集）
2. 创建 NoiseConfig 加密配置
3. 根据 ctype 选择 spawn_connecter（dial）或 spawn_listener（bind）
4. Noise 握手（5s 超时）→ 协议握手 → 注册 Agent
5. 建立 YamuxSession（多路复用），获取 control 句柄
6. 广播 AgentEvent{status:"create"} 到前端
7. 循环监听 yamux 事件和控制信号

内置 SSH 服务器（npc2/src/rssh.rs）：

NPC2 内嵌一个 SSH 服务器（russh::server），支持以下 subsystem：

Agent 工具层（npc2/src/agents/）： 通过 rpc subsystem 接收 ToolAct 指令，注册了 8 个工具处理器：

终端（npc2/src/terminal/）：

• Windows：优先 ConPTY，回退 Pipe 终端
• Unix：标准 PTY

VNC 虚拟桌面（npc2/src/vnc.rs）：

• 基于 rustvncserver（纯 Rust VNC 服务器，支持 11 种编码）
• 输入模拟通过 enigo（键盘/鼠标）
• 单例模式，多用户共享同一 VNC 实例

平台特性：

• 端口复用：Windows 用 netsh portproxy，Linux 用 iptables REDIRECT
• **进程隐藏