基于钉钉机器人的 Qoder CLI / Claude Code 双引擎 AI 助手实践

文章内容基于作者个人技术实践与独立思考，旨在分享经验，仅代表个人观点。

一、背景与问题

二、方案概览

2.1 整体架构

┌────────────────────────────────────────────────────────────────┐│                    钉钉群 / 单聊                               │├────────────────────────────────────────────────────────────────┤│  钉钉 Stream WebSocket 长连接（内网直通，无需公网回调）        │├────────────────────────────────────────────────────────────────┤│                  Java 服务（alsc-intervene）                    ││  ┌──────────────────────────────────────────────────────────┐  ││  │  DingTalkStreamService                                    │  ││  │  • 权限校验（管理员 vs 只读用户）                        │  ││  │  • 上下文管理（LRU + TTL + 滑动窗口）                    │  ││  │  • 并发控制（线程池 10-15）                              │  ││  │  • AI卡片投放与流式更新                                  │  ││  └──────────────────────────────────────────────────────────┘  ││                           │                                    ││                           ▼                                    ││  ┌──────────────────────────────────────────────────────────┐  ││  │  CLI 代理层（ProcessBuilder）                             │  ││  │  • Qoder CLI / Claude Code（可切换）                     │  ││  │  • stdbuf -oL 行缓冲优化                                │  ││  │  • 120s 超时保护 + 异常杀进程                           │  ││  └──────────────────────────────────────────────────────────┘  ││                           │                                    ││                           ▼                                    ││              MCP Server（工具调用层）                          │└────────────────────────────────────────────────────────────────┘

2.2 关键技术选型

三、引擎选型：

从 Qoder CLI 到 Claude Code

3.1 最初选择 Qoder CLI

3.2 遇到的问题

3.3 引入 Claude Code

四、Docker 部署方案

4.1 部署架构

Docker 容器├── /home/admin/qoder-workspace/     # 共享工作目录│   ├── .mcp.json                    # MCP服务配置│   ├── AGENTS.md                    # Qoder CLI 知识入口│   └── CLAUDE.md                    # Claude Code 指令文件├── /home/admin/.qoder/              # Qoder CLI 专属配置│   ├── settings.json                # MCP server列表│   ├── mcp-oauth-tokens.json        # OAuth认证token│   └── skills/                      # 安装的Skills├── /home/admin/.claude/             # Claude Code 专属配置│   └── settings.json                # 环境变量 + 权限└── /opt/mcp-auth/                   # Claude MCP认证文件

4.2 Dockerfile 核心设计

FROM reg.docker.alibaba-inc.com/alibase/alios7u2-min# 基础运行时RUN yum install -y ajdk11-11.0.27.26 nodejs git# 安装双引擎RUN npm install -g @qoder-ai/qodercli \        --registry=https://registry.npm.alibaba-inc.com && \    npm install -g @ali/[email protected] \        --registry=https://registry.npm.alibaba-inc.com# 部署工作区COPY qoder-workspace/ /home/admin/qoder-workspace/# Qoder CLI 认证COPY qoder-home/.qoder/ /home/admin/.qoder/RUN chmod 600 /home/admin/.qoder/mcp-oauth-tokens.json && \    chmod 444 /home/admin/.qoder/mcp-oauth-clients.json# Claude Code 认证COPY claude-home/.claude/ /home/admin/.claude/COPY claude-mcp-auth/ /opt/mcp-auth/RUN ln -sf /opt/mcp-auth /home/admin/.mcp-auth

4.3 Java 层调用方式

// Qoder CLIProcessBuilder pb = new ProcessBuilder(    "stdbuf", "-oL", "qodercli",    "-p", prompt,    "--output-format", "stream-json",    "--yolo", "--max-turns", "10",    "-w", "/home/admin/qoder-workspace");pb.environment().put("QODER_PERSONAL_ACCESS_TOKEN", qoderToken);// Claude CodeProcessBuilder pb = new ProcessBuilder(    claudeCliPath, "-p", prompt,    "--output-format", "stream-json",    "--verbose", "--max-turns", "5");pb.environment().put("ANTHROPIC_AUTH_TOKEN", anthropicToken);

五、MCP 工具集成与 OAuth 认证跳过方案

5.1 MCP 是什么

5.2 MCP 认证问题

5.3 跳过 OAuth 的方案：
静态 Bearer Token

// .mcp.json - 直接在 headers 中携带 Bearer token{  "mcpServers": {    "code": {      "type": "streamable-http",      "url": "https://mcp.alibaba-inc.com/code/mcp",      "headers": {        "Authorization": "Bearer mcpa_xxxxxxxxxxxxxxxx"      }    },    "sls-mcp": {      "type": "streamable-http",      "url": "https://mcp.alibaba-inc.com/sls-mcp/mcp",      "headers": {        "Authorization": "Bearer mcpa_yyyyyyyyyyyyyyyy"      }    }  }}

5.4 Qoder CLI 的 OAuth Token 方式

[  {    "serverName": "code",    "token": {      "accessToken": "mcpa_xxxxx",      "refreshToken": "mcpr_xxxxx",      "expiresAt": 1782186490063,      "tokenType": "Bearer"    },    "clientId": "mcp-client-xxxx",    "tokenUrl": "https://mcp.alibaba-inc.com/oauth/token",    "mcpServerUrl": "https://mcp.alibaba-inc.com/code/mcp"  }]

六、钉钉 Stream 集成核心实现

6.1 为什么选择 Stream 模式

@PostConstructpublic void init() {    if (!streamEnabled) return;    OpenDingTalkClient client = OpenDingTalkStreamClientBuilder.custom()        .credential(new AuthCredential() {{            setClientId(appKey);            setClientSecret(appSecret);        }})        .registerCallbackListener("/v1.0/im/bot/messages/get", this)        .build();    client.start();}

6.2 进程管理与流式输出

public void chatStream(String prompt, String workspace,                        Consumer<String> lineConsumer, Consumer<Process> processConsumer) {    List<String> cmd = Arrays.asList(        "stdbuf", "-oL",           // 强制行缓冲        cliPath, "-p", prompt,        "--output-format", "stream-json",        "--yolo", "--max-turns", "10",        "-w", workspace    );    ProcessBuilder pb = new ProcessBuilder(cmd);    pb.environment().put("QODER_PERSONAL_ACCESS_TOKEN", token);    pb.redirectErrorStream(true);    Process process = pb.start();    processConsumer.accept(process);    try (BufferedReader reader = new BufferedReader(            new InputStreamReader(process.getInputStream()), 256)) {        String line;        while ((line = reader.readLine()) != null) {            lineConsumer.accept(line);        }    }    if (!process.waitFor(120, TimeUnit.SECONDS)) {        process.destroyForcibly();    }}

6.3 AI卡片流式更新

// 频率控制：累计超50字符才更新一次if (fullContent.length() - lastUpdateLen > 50) {    String content = fullContent.length() > 3000         ? fullContent.substring(0, 3000)        : fullContent.toString();    cardService.streamUpdate(trackId, content, false, false);    lastUpdateLen = fullContent.length();}

6.4 用户上下文管理（三重防护）

private final LinkedHashMap<String, UserContext> contextMap =    new LinkedHashMap<>(16, 0.75f, true) {        @Override        protected boolean removeEldestEntry(Entry<String, UserContext> eldest) {            return size() > 500;        }    };

6.5 权限隔离

6.6 并发控制

private final ExecutorService qoderExecutor = new ThreadPoolExecutor(    10, 15, 60L, TimeUnit.SECONDS,    new LinkedBlockingQueue<>(30),    new ThreadPoolExecutor.AbortPolicy());

七、知识自进化机制

L0  git history（自动追踪代码变更） ↓L1  .qoder/context/（每次任务的过程报告） ↓L2  .qoder/memory_recent.md（最近5次会话摘要） ↓L3  .qoder/rules/candidates/（候选规则，经验沉淀） ↓L4  AGENTS.md + P0-constraints.md（正式规则）

八、钉钉机器人配置与申请指南

8.1 创建机器人应用

8.2 开通必要权限

8.3 启用 Stream 模式

8.4 AI卡片模板配置

8.5 关键配置项

dingtalk.stream.enabled=true           # Stream开关（预发/线上设false）dingtalk.app.key=${DINGTALK_APP_KEY}   # antx注入dingtalk.app.secret=${DINGTALK_APP_SECRET}dingtalk.robot.code=${DINGTALK_ROBOT_CODE}

8.6 注意事项

九、运行效果展示

9.1 性能追踪

9.2 问题场景

9.3 需求跟进

十、踩坑经验

10.1 stdbuf 行缓冲是必须的

10.2 MCP OAuth Token 格式要求

10.3 Stream 模式多实例冲突

10.4 AI 卡片权限

10.5 Claude Code 权限透传

十一、总结