MCP with RAG Demo
这个演示项目展示了如何实现一个具有检索增强生成 (RAG) 功能的模型上下文协议 (MCP) 服务器。该演示允许 AI 模型与知识库交互、搜索信息以及添加新文档。
thinklytics
README
MCP 与 RAG 演示
这个演示项目展示了如何实现一个具有检索增强生成 (RAG) 功能的模型上下文协议 (MCP) 服务器。该演示允许 AI 模型与知识库交互、搜索信息和添加新文档。
功能
- 具有工具和资源支持的 MCP 服务器
- RAG 实现(回退到内存存储)
- 用于与 MCP 服务器交互的客户端示例
- 支持 SSE (HTTP) 和 stdio 通信模式
- 简单的提示模板
前提条件
- Python 3.8+
- pip (Python 包管理器)
安装
- 克隆存储库:
git clone <repository-url>
cd mcp-demo
- 创建一个虚拟环境:
python -m venv mcp-env
source mcp-env/bin/activate # 在 Windows 上:mcp-env\Scripts\activate
- 安装所需的依赖项:
pip install -r requirements.txt
项目结构
mcp-demo/
├── server.py # 主要的 MCP 服务器实现
├── client_example.py # 与服务器交互的客户端示例
├── requirements.txt # 项目依赖项
├── sample_data.txt # 可作为资源使用的示例数据
├── tools/
│ ├── __init__.py # 包初始化
│ └── rag_tools.py # RAG 工具实现
└── README.md # 此自述文件
运行演示
步骤 1:启动 MCP 服务器
您可以在两种不同的模式下运行 MCP 服务器:
选项 A:SSE (HTTP) 模式
此模式允许服务器使用服务器发送事件 (SSE) 通过 HTTP 接受连接:
python server.py --sse
默认情况下,服务器将监听 0.0.0.0:8000
。您可以自定义主机和端口:
python server.py --sse --host 127.0.0.1 --port 9000
选项 B:stdio 模式
此模式允许服务器通过标准输入/输出进行通信:
python server.py --stdio
步骤 2:运行客户端示例
服务器启动并运行后,打开一个新的终端窗口(保持服务器在第一个窗口中运行):
连接到 SSE 服务器
# 确保您的虚拟环境已激活
source mcp-env/bin/activate # 在 Windows 上:mcp-env\Scripts\activate
# 以 SSE 模式运行客户端
python client_example.py --sse http://localhost:8000
如果 URL 中缺少 "/sse",客户端将自动附加它。
通过 stdio 连接
# 确保您的虚拟环境已激活
source mcp-env/bin/activate # 在 Windows 上:mcp-env\Scripts\activate
# 以 stdio 模式运行客户端
python client_example.py --stdio --command python --args "server.py --stdio"
您可以根据需要自定义命令和参数。
客户端示例的作用
客户端示例演示了几个关键操作:
- 列出 MCP 服务器中可用的工具、资源和提示
- 调用 echo 工具以验证基本通信
- 使用元数据将文档添加到知识库
- 使用 RAG 系统搜索知识库
- 从服务器读取示例资源
可用的 MCP 工具
此演示中提供了以下工具:
echo
: 一个简单的工具,可以回显提供的消息add
: 一个将两个数字相加的工具add_document
: 将文档添加到知识库rag_search
: 在知识库中搜索与查询相关的信息list_documents
: 列出知识库中的所有文档
可用的 MCP 资源
sample://data
: 提供对 sample_data.txt 中示例数据的访问
可用的 MCP 提示
greeting
: 一个简单的问候提示模板
自定义演示
添加新工具
要添加新工具,请修改 server.py
文件:
@mcp.tool()
def your_tool_name(param1: type, param2: type) -> return_type:
"""Tool description"""
# Tool implementation
return result
添加新资源
要添加新资源,请修改 server.py
文件:
@mcp.resource("resource://pattern")
def your_resource_function() -> str:
"""Resource description"""
# Resource implementation
return "Resource content"
添加新提示
要添加新的提示模板,请修改 server.py
文件:
@mcp.prompt()
def your_prompt_name(param1: str, param2: str) -> str:
"""Prompt description"""
return f"""
Your prompt template text with {param1} and {param2} parameters.
"""
故障排除
客户端连接问题
如果在运行客户端时遇到“连接被拒绝”错误:
- 确保服务器实际上在另一个终端窗口中运行
- 检查您是否使用了正确的 URL(默认为 http://localhost:8000)
- 确保服务器正在监听预期的接口(0.0.0.0 接受外部连接)
- 尝试显式指定服务器 URL:
python client_example.py --sse http://localhost:8000
服务器端点问题
MCP 服务器在 /sse
公开一个 SSE(服务器发送事件)端点。使用客户端连接时:
- 完整的 URL 应该是
http://localhost:8000/sse
- 如果您指定的 URL 中缺少
/sse
,客户端将自动附加它
调试模式
如果遇到问题,您可以启用调试模式以获得更详细的输出:
python client_example.py --sse http://localhost:8000 --debug
常见问题
客户端连接的导入错误
如果在运行客户端示例时看到导入错误,请确保已安装所有必需的依赖项:
pip install mcp-sdk
找不到包或版本不匹配
如果您遇到导入错误或版本兼容性问题,请尝试安装特定版本的 MCP 包:
pip install mcp-sdk>=1.0.0
许可证
本项目作为示例实现提供,并根据 MIT 许可证提供。
设置
-
安装所需的依赖项:
pip install -r requirements.txt
-
创建一个
.env
文件:cp .env.example .env
-
编辑
.env
文件并添加您的 OpenAI API 密钥:OPENAI_API_KEY=your_api_key_here
您还可以在
.env
文件中配置其他选项:MCP_SERVER_URL
: MCP 服务器的 URL(默认:http://localhost:3000)DEBUG
: 启用调试模式(默认:false)
用法
运行演示:
python openai_example.py
您可以使用命令行参数覆盖 .env
文件中的设置:
python openai_example.py --api-key YOUR_API_KEY --server-url http://your-server-url
环境变量
可以在 .env
文件中设置以下环境变量:
OPENAI_API_KEY
: 您的 OpenAI API 密钥(必需)MCP_SERVER_URL
: MCP 服务器的 URL(可选)DEBUG
: 启用调试模式(可选)
命令行参数
--api-key
: 您的 OpenAI API 密钥(覆盖 .env 文件)--server-url
: MCP 服务器的 URL(覆盖 .env 文件)--debug
: 启用调试模式(覆盖 .env 文件)
MCP OpenAI 示例
此示例演示了如何将模型控制协议 (MCP) 与 OpenAI 的 API 一起使用。
设置
-
安装所需的依赖项:
pip install -r requirements.txt
-
基于
.env.example
模板创建一个.env
文件:cp .env.example .env
-
编辑
.env
文件并添加您的 OpenAI API 密钥:OPENAI_API_KEY=your_api_key_here
运行示例
运行示例脚本:
python openai_example.py
您也可以直接指定选项:
python openai_example.py --api-key your_api_key_here --server-url http://localhost:3000 --debug
示例的作用
- 从
.env
文件加载环境变量 - 使用您的 API 密钥配置 OpenAI 客户端
- 列出可用的模型
- 使用简单的提示创建聊天完成
环境变量
OPENAI_API_KEY
: 您的 OpenAI API 密钥(必需)MCP_SERVER_URL
: MCP 服务器的 URL(可选,默认为 http://localhost:3000)DEBUG
: 启用调试日志记录(可选,默认为 false)
推荐服务器
Crypto Price & Market Analysis MCP Server
一个模型上下文协议 (MCP) 服务器,它使用 CoinCap API 提供全面的加密货币分析。该服务器通过一个易于使用的界面提供实时价格数据、市场分析和历史趋势。 (Alternative, slightly more formal and technical translation): 一个模型上下文协议 (MCP) 服务器,利用 CoinCap API 提供全面的加密货币分析服务。该服务器通过用户友好的界面,提供实时价格数据、市场分析以及历史趋势数据。
MCP PubMed Search
用于搜索 PubMed 的服务器(PubMed 是一个免费的在线数据库,用户可以在其中搜索生物医学和生命科学文献)。 我是在 MCP 发布当天创建的,但当时正在度假。 我看到有人在您的数据库中发布了类似的服务器,但还是决定发布我的服务器。
mixpanel
连接到您的 Mixpanel 数据。 从 Mixpanel 分析查询事件、留存和漏斗数据。

Sequential Thinking MCP Server
这个服务器通过将复杂问题分解为顺序步骤来促进结构化的问题解决,支持修订,并通过完整的 MCP 集成来实现多条解决方案路径。

Nefino MCP Server
为大型语言模型提供访问德国可再生能源项目新闻和信息的能力,允许按地点、主题(太阳能、风能、氢能)和日期范围进行筛选。
Vectorize
将 MCP 服务器向量化以实现高级检索、私有深度研究、Anything-to-Markdown 文件提取和文本分块。
Mathematica Documentation MCP server
一个服务器,通过 FastMCP 提供对 Mathematica 文档的访问,使用户能够从 Wolfram Mathematica 检索函数文档和列出软件包符号。
kb-mcp-server
一个 MCP 服务器,旨在实现便携性、本地化、简易性和便利性,以支持对 txtai “all in one” 嵌入数据库进行基于语义/图的检索。任何 tar.gz 格式的 txtai 嵌入数据库都可以被加载。
Research MCP Server
这个服务器用作 MCP 服务器,与 Notion 交互以检索和创建调查数据,并与 Claude Desktop Client 集成以进行和审查调查。

Cryo MCP Server
一个API服务器,实现了模型补全协议(MCP),用于Cryo区块链数据提取,允许用户通过任何兼容MCP的客户端查询以太坊区块链数据。