# multi-domain-agents

**Repository Path**: code-me/multi-domain-agents

## Basic Information

- **Project Name**: multi-domain-agents
- **Description**: No description available
- **Primary Language**: Unknown
- **License**: Not specified
- **Default Branch**: master
- **Homepage**: None
- **GVP Project**: No

## Statistics

- **Stars**: 0
- **Forks**: 0
- **Created**: 2026-01-27
- **Last Updated**: 2026-02-09

## Categories & Tags

**Categories**: Uncategorized

**Tags**: None

## README

# Collab

完整的企业级多域代理AI系统，支持金融、法律、医疗、教育和技术等多个专业领域。

## 🎉 v2.1 重大更新 - 自主团队系统完善版

框架v2.1在v2.0基础上进行了全面完善，实现了**真正可用的自主运行系统**：

### 核心框架优化
- 🚀 **新增Agent时间减少80%** (4小时 → 30分钟)
- 🔧 **新增工具时间减少85%** (60分钟 → 10分钟)
- 🔥 **配置热更新** - 无需重启
- 🎨 **插件化架构** - 零代码添加新功能

### 🆕 自主团队系统（v2.1完善版）
- 🤖 **智能目标分解** - 高层目标自动拆解为任务树（优化的LLM提示词）
- ⚡ **自主运行执行** - 事件驱动的自动调度 + Agent集成
- ✅ **双重验证机制** - AI自验证 + 人工验收
- 🎛️ **全面人工干预** - 暂停/恢复/修改/回滚/紧急中止
- 📊 **实时监控系统** - WebSocket实时推送 + 可视化监控台
- 🧠 **AI智能增强** - 代码审查 + 知识推荐
- 🔄 **自动重试机制** - 任务失败自动重试(最多3次)
- 📈 **性能监控** - 实时性能指标和统计分析

### v2.1 新增功能
- ✨ **WebSocket实时推送** - 替代轮询，毫秒级状态更新
- ✨ **任务执行引擎** - 与AgentManager深度集成
- ✨ **智能重试机制** - 自动重试失败任务
- ✨ **性能监控系统** - 完整的性能指标和分析
- ✨ **优化的提示词** - 更智能的任务分解
- ✨ **完整测试套件** - 端到端测试用例

👉 [v2.1改进总结](./docs/autonomous-system/AUTONOMOUS_SYSTEM_IMPROVEMENTS.md) | [自主团队系统文档](./docs/autonomous-system/AUTONOMOUS_SYSTEM_COMPLETE.md) | [快速启动](./docs/autonomous-system/QUICKSTART_AUTONOMOUS.md)

## 功能特性

✅ **多域专家代理** - 针对不同领域的AI代理
✅ **工作流编排** - 任务队列和异步处理
✅ **知识库管理** - 向量检索和语义搜索
✅ **对话记忆** - 短期和长期记忆管理
✅ **自主聊天路由** - 自动选择专家与多专家协作
✅ **聊天指令系统** - Notion风格的快捷指令,支持8种指令类型 🆕
✅ **缓存优化** - Redis缓存层
✅ **性能监控** - Prometheus指标
✅ **插件系统** - 插件式代理注册和工具动态加载
✅ **权限管理** - 细粒度权限控制和RBAC
✅ **中间件系统** - 可定制的请求处理链
✅ **MCP服务集成** - Model Context Protocol客户端和服务器支持
✅ **生产就绪** - Docker和Kubernetes支持

### 🆕 v2.0 新特性

✨ **统一插件系统** - 热插拔、依赖解析、版本管理  
✨ **抽象执行引擎** - 支持ToolLoop、ReAct、Plan-Execute等多种模式  
✨ **配置驱动架构** - 统一配置文件，支持热更新  
✨ **工具标准化** - @tool装饰器，自动发现  
✨ **领域模板系统** - CLI快速创建新领域  
✨ **智能并行执行** - 自动依赖分析，最大化并行度  
✨ **多级智能缓存** - L1本地 + L2 Redis，智能预热  
✨ **聊天指令系统** - 输入`/`触发,支持搜索/计划/领域/工作流等8种指令 🆕

## 系统架构

```
客户端 -> API网关 -> 认证/速率限制 -> 编排器/聊天服务 -> 代理管理器
              |
              ├-> 代理实例 (金融、法律、医疗、教育、技术)
              ├-> 知识库 (向量检索)
              ├-> 记忆管理 (对话历史)
              └-> LLM服务 (OpenAI/Claude)
```

## 🆕 v2.0 快速体验

### 创建新领域（10分钟）

```bash
python -m src.cli.domain_generator \
  --domain marketing \
  --name "营销" \
  --description "营销策划专家" \
  --skills marketing-strategy \
  --create-agent
```

### 开发自定义工具（5分钟）

```python
from src.core.tool_schema import tool, ToolCategory

@tool(name="my_tool", description="...", category=ToolCategory.WEB)
async def my_tool(param: str) -> str:
    return f"Result: {param}"
```

### 使用智能缓存（即时）

```python
from src.utils.smart_cache import get_smart_cache

cache = await get_smart_cache()
result = await cache.get_or_compute(key, compute_fn, warm_up=True)
```

👉 [查看更多v2.0示例](./docs/guides/QUICKSTART_V2.md)

---

## 快速开始

### 1. 环境准备

```bash
# 克隆项目
git clone <repository-url>
cd multi-domain-agents

# 创建Python虚拟环境
python -m venv venv
source venv/bin/activate  # Linux/Mac
# 或
venv\Scripts\activate  # Windows
```

### 2. 安装依赖

```bash
pip install -r requirements.txt
```

### 3. 配置环境变量

```bash
# 复制示例配置
cp .env.example .env

# 编辑.env文件，填入你的API密钥
# - DASHSCOPE_API_KEY (阿里云百炼，推荐)
# - 或 OPENAI_API_KEY (OpenAI)
# - SECRET_KEY (JWT密钥，生产环境必须修改)
# - 数据库连接信息
```

**详细配置说明**: 参考 [配置指南](docs/guides/CONFIG_GUIDE.md)

### 4. 启动服务

#### 使用Docker Compose（推荐）

```bash
docker-compose up -d
```

这将启动：
- FastAPI应用 (端口 8000)
- MongoDB (端口 27017)
- Redis (端口 6379)
- Elasticsearch (端口 9200)
- Prometheus (端口 9090)
- Grafana (端口 3000)

#### 直接运行

```bash
python -m src.main
```

### 5. 验证运行

打开浏览器访问：
- API文档: http://localhost:8000/docs
- API详细文档: http://localhost:8000/redoc
- 健康检查: http://localhost:8000/health
- 系统状态: http://localhost:8000/status

## API使用示例

### 提交任务

```bash
curl -X POST "http://localhost:8000/api/v1/tasks" \
  -H "Authorization: Bearer YOUR_TOKEN" \
  -H "Content-Type: application/json" \
  -d '{
    "domain": "finance",
    "action": "analyze",
    "params": {
      "ticker": "AAPL"
    }
  }'
```

### 聊天服务

完整接口说明请参考 [聊天服务API文档](docs/api/CHAT_API.md)。

#### 统一聊天接口（自动路由）

```bash
curl -X POST "http://localhost:8000/api/v1/chat" \
  -H "Authorization: Bearer YOUR_TOKEN" \
  -H "Content-Type: application/json" \
  -d '{
    "conversation_id": "conv_123",
    "message": "我想了解苹果股票的情况"
  }'
```

#### 显式指定专家领域

```bash
curl -X POST "http://localhost:8000/api/v1/chat" \
  -H "Authorization: Bearer YOUR_TOKEN" \
  -H "Content-Type: application/json" \
  -d '{
    "conversation_id": "conv_123",
    "message": "请做技术架构设计",
    "explicit_domain": "tech"
  }'
```

#### 获取聊天上下文

```bash
curl "http://localhost:8000/api/v1/chat/conv_123/context" \
  -H "Authorization: Bearer YOUR_TOKEN"
```

### 获取任务状态

```bash
curl "http://localhost:8000/api/v1/tasks/{task_id}" \
  -H "Authorization: Bearer YOUR_TOKEN"
```

### 搜索知识库

```bash
curl "http://localhost:8000/api/v1/knowledge/search?query=股票分析&domain=finance&top_k=5" \
  -H "Authorization: Bearer YOUR_TOKEN"
```

### 列出所有代理

```bash
curl "http://localhost:8000/api/v1/agents" \
  -H "Authorization: Bearer YOUR_TOKEN"
```

### 获取系统统计

```bash
curl "http://localhost:8000/api/v1/stats/tasks" \
  -H "Authorization: Bearer YOUR_TOKEN"
```

## 支持的代理

| 代理 | 域 | 主要功能 |
|------|-----|----------|
| FinanceAgent | finance | 股票分析、投资组合、市场预测 |
| LegalAgent | legal | 法律咨询、合同审核、法律研究 |
| MedicalAgent | medical | 诊断、治疗建议、医学研究 |
| EducationAgent | education | 教学解释、练习生成、知识评估 |
| TechAgent | tech | 技术支持、代码审查、架构设计 |

## 项目结构

```
multi-domain-agents/
├── src/
│   ├── main.py                          # 应用入口
│   ├── api/
│   │   ├── deps.py                     # 依赖注入
│   │   ├── routes.py                   # 路由聚合入口
│   │   ├── routers/                    # 路由模块
│   │   └── schemas/                    # 请求/响应模型
│   ├── agents/
│   │   ├── base_agent.py               # 基础代理类
│   │   ├── finance_agent.py            # 金融代理
│   │   ├── legal_agent.py              # 法律代理
│   │   ├── medical_agent.py            # 医疗代理
│   │   ├── education_agent.py          # 教育代理
│   │   └── tech_agent.py               # 技术代理
│   ├── core/
│   │   ├── orchestrator.py             # 工作流编排器
│   │   ├── agent_manager.py            # 代理管理器
│   │   ├── auth_service.py             # 认证服务
│   │   ├── event_bus.py                # 事件总线
│   │   └── config.py                   # 配置管理
│   ├── chat/
│   │   ├── router.py                   # 聊天路由器
│   │   ├── service.py                  # 聊天服务
│   │   ├── coordinator.py              # 多专家协调器
│   │   └── prompts/
│   │       └── routing_prompts.py      # 路由提示词
│   ├── knowledge/
│   │   ├── knowledge_base.py           # 知识库
│   │   └── memory_manager.py           # 记忆管理
│   └── utils/
│       ├── cache.py                    # 缓存管理
│       └── monitoring.py               # 监控指标
├── docker-compose.yaml                 # Docker Compose配置
├── Dockerfile                          # 容器构建文件
├── requirements.txt                    # Python依赖
├── .env.example                        # 环境变量示例
├── permissions.yaml                    # 权限配置
├── plugins.yaml                        # 插件配置
├── tools.yaml                          # 工具配置
├── middleware.yaml                     # 中间件配置
├── prometheus.yaml                     # Prometheus配置
├── domain_config.yaml                  # 领域路由配置
├── README.md                           # 项目概览
├── docs/                               # 文档目录
│   ├── INDEX.md                        # 文档总索引
│   ├── guides/                         # 用户指南
│   ├── api/                            # API参考
│   ├── architecture/                   # 架构设计
│   ├── features/                       # 功能模块文档
│   │   ├── command-system/             #   指令系统
│   │   ├── skills/                     #   技能系统
│   │   ├── task-queue/                 #   任务队列
│   │   ├── routing/                    #   路由系统
│   │   └── page-viewer/               #   页面查看器
│   ├── autonomous-system/              # 自主团队系统
│   ├── team-system/                    # 多Agent团队协作
│   ├── optimization/                   # 性能优化
│   ├── changelog/                      # 版本更新日志
│   ├── implementation/                 # 实现记录
│   └── fixes/                          # 问题修复记录
└── plugins/                            # 插件目录
    └── example_agent/                   # 示例插件
```

## 配置说明

详细的配置说明请参考 [配置指南](docs/guides/CONFIG_GUIDE.md)。

### 核心配置

主要配置文件：
- `.env` - 环境变量配置（必需）
- `permissions.yaml` - 权限配置
- `plugins.yaml` - 插件配置
- `middleware.yaml` - 中间件配置
- `tools.yaml` - 工具配置
- `mcp_config.yaml` - MCP服务器配置

### 快速配置

```bash
# 1. 复制环境变量模板
cp .env.example .env

# 2. 编辑.env文件，至少配置：
# - DASHSCOPE_API_KEY (阿里云百炼API密钥)
# - SECRET_KEY (JWT密钥，生产环境必须修改)

# 3. 可选：调整其他配置文件
# - permissions.yaml (权限和角色)
# - middleware.yaml (中间件设置)
```

**详细配置说明**: 参考 [配置指南](docs/guides/CONFIG_GUIDE.md)

## 性能优化

### 缓存策略
- Redis缓存查询结果
- 本地缓存降低网络延迟
- 自动过期清理机制

### 并发控制
- 信号量限制并发任务数
- 异步队列处理任务
- 连接池管理

### 监控
- Prometheus指标导出
- 请求追踪
- 性能指标收集

## 部署

### Kubernetes部署

```bash
# 创建namespace
kubectl create namespace ai-agents

# 部署应用
kubectl apply -f k8s/deployment.yaml -n ai-agents
kubectl apply -f k8s/service.yaml -n ai-agents

# 查看部署状态
kubectl get pods -n ai-agents
```

### 扩展副本

```bash
kubectl scale deployment multi-domain-agents --replicas=3 -n ai-agents
```

## 故障排除

### 连接问题
- 检查MongoDB和Redis是否运行
- 验证OPENAI_API_KEY是否有效
- 检查防火墙规则

### 性能问题
- 增加Redis缓存大小
- 调整并发任务限制
- 检查数据库索引

### 日志查看

```bash
# Docker日志
docker-compose logs -f api

# 直接运行日志
# 查看 stdout/stderr 输出
```

## 技术栈

- **后端框架**: FastAPI + Uvicorn
- **数据库**: MongoDB + Redis
- **向量搜索**: Elasticsearch / Pinecone
- **LLM**: OpenAI / 阿里云百炼
- **容器化**: Docker + Kubernetes
- **监控**: Prometheus + Grafana
- **日志**: ELK Stack

## 许可证

MIT License

## 贡献指南

欢迎提交Issue和Pull Request！

## 文档索引

完整文档索引请参考 [docs/INDEX.md](docs/INDEX.md)。

### 核心文档
- [文档总索引](docs/INDEX.md) - 所有文档的完整分类索引
- [系统架构](docs/architecture/ARCHITECTURE.md) - 系统架构和设计决策
- [开发指南](docs/guides/DEVELOPMENT_GUIDE.md) - 开发环境设置和扩展指南
- [配置指南](docs/guides/CONFIG_GUIDE.md) - 所有配置文件的详细说明
- [部署指南](docs/guides/DEPLOYMENT_GUIDE.md) - 生产环境部署说明

### v2.0/v2.1 文档
- [v2.0 快速开始](docs/guides/QUICKSTART_V2.md) - 5分钟上手v2.0新特性
- [v2.0 API参考](docs/api/API_REFERENCE_V2.md) - 新增API完整参考
- [v2.0 迁移指南](docs/optimization/MIGRATION_TO_V2.md) - 从v1.0迁移到v2.0
- [框架优化指南](docs/optimization/FRAMEWORK_OPTIMIZATION_GUIDE.md) - 完整的优化说明
- [扩展性示例](docs/optimization/EXTENSIBILITY_EXAMPLES.md) - 插件、工具、引擎开发示例
- [v2.1 更新日志](docs/changelog/CHANGELOG_V2.1.md) - v2.1版本变更记录

### 功能文档
- [认证指南](docs/guides/AUTH_GUIDE.md) - 用户认证和权限使用
- [权限管理](docs/guides/PERMISSION_GUIDE.md) - 权限系统使用指南
- [插件开发](docs/guides/PLUGIN_GUIDE.md) - 如何开发插件
- [扩展API](docs/api/EXTENSION_API.md) - 插件、工具、中间件管理API
- [聊天服务API](docs/api/CHAT_API.md) - 自主专家聊天接口
- [MCP使用指南](docs/guides/MCP_GUIDE.md) - Model Context Protocol集成指南
- [指令系统指南](docs/features/command-system/COMMAND_SYSTEM_GUIDE.md) - 聊天指令系统使用
- [技能系统指南](docs/features/skills/SKILLS_USER_GUIDE.md) - 技能系统使用指南

### 运维文档
- [故障排查](docs/guides/TROUBLESHOOTING.md) - 常见问题和解决方案
- [技术设计](docs/architecture/FULFILL_DESIGN.md) - 完整技术方案

### 快速导航

**新用户**: [快速开始](#快速开始) → [配置指南](docs/guides/CONFIG_GUIDE.md) → [认证指南](docs/guides/AUTH_GUIDE.md)

**开发者**: [开发指南](docs/guides/DEVELOPMENT_GUIDE.md) → [架构设计](docs/architecture/ARCHITECTURE.md) → [插件开发](docs/guides/PLUGIN_GUIDE.md)

**运维人员**: [配置指南](docs/guides/CONFIG_GUIDE.md) → [故障排查](docs/guides/TROUBLESHOOTING.md) → [部署](#部署)

## 联系方式

如有问题或建议，请提交Issue。