🔍 Rust MCP 服务器 + Inspector 示例：带有 Add 工具的 SSE 传输

鸣谢：https://dev.to/joshmo_dev/using-model-context-protocol-with-rig-m7o

本项目演示了如何使用服务器发送事件 (SSE) 来设置 MCP（模型上下文协议）服务器和客户端进行通信。它包含一个简单的工具，用于将两个数字相加，并与 RIG 代理集成以进行 LLM 提示。

---

🚀 快速开始

克隆此仓库并运行：

cargo run

在单独的终端中，使用以下命令启动 MCP Inspector：

npx @modelcontextprotocol/inspector sse http://127.0.0.1:3001/sse

您将看到如下输出：

Starting MCP inspector...
Proxy server listening on port 3000
New SSE connection
Query parameters: { transportType: 'sse', url: 'http://localhost:3001/sse' }
SSE transport: url=http://localhost:3001/sse, headers=
Connected to SSE transport
Connected MCP client to backing server transport
Created web app transport
Set up MCP proxy
🔍 MCP Inspector is up and running at http://localhost:5173 🚀

您现在可以在 http://localhost:5173 查看 Web 界面

---

🛠️ 功能

• ✅ 使用 ServerSseTransport 设置自定义 MCP 服务器
• ✅ 将 MCP 客户端连接到服务器
• ✅ 注册自定义工具：AddTool，用于将两个数字相加
• ✅ 通过 MCP 列出已注册的工具
• ✅ 与 RIG 集成，并使用该工具提示 LLM 代理

---

🧠 代码概览

#[tool(
    name = "Add",
    description = "Adds two numbers together.",
    params(a = "The first number to add", b = "The second number to add")
)]
async fn add_tool(a: f64, b: f64) -> Result<ToolResponseContent> {
    Ok(tool_text_content!((a + b).to_string()))
}

这定义了在 MCP 服务器中注册的 Add 工具。

主函数设置：

• 追踪
• MCP 服务器和传输 (SSE)
• 初始化并列出可用工具的 MCP 客户端
• 带有 OpenAI 后端的 RIG 代理，它使用 MCP 工具

然后，代理运行一个提示：

let response = agent.prompt("Add 10 + 10").await;

---

🧪 示例输出

成功运行时，您将看到如下日志：

Initialized: Ok(...)
Tools: Ok([...])
Building RIG agent
Prompting RIG agent
Agent response: Some("20")

---

🧰 技术栈

• 🦀 带有 tokio 的 Rust
• 📡 来自 mcp_core 的 SSE 传输
• 🔧 MCP 服务器/客户端架构
• 🤖 带有 OpenAI 模型的 RIG 代理
• 🌐 MCP Inspector Web 界面

---

📦 依赖项

确保您的 Cargo.toml 中包含以下内容：

[dependencies]
tokio = { version = "1", features = ["full"] }
anyhow = "1"
serde_json = "1"
mcp_core = "..."
mcp_core_macros = "..."
rig = "..."

将 ... 替换为基于您的环境的适当版本。

---

📍 Inspector GUI

访问 http://localhost:5173 以查看和交互 MCP Inspector UI。

---

✅ 测试日志示例

Query parameters: { transportType: 'sse', url: 'http://localhost:3001/sse' }
Connected to SSE transport
Connected MCP client to backing server transport
Set up MCP proxy
Received message for sessionId cdd4a8be-57e2-44e3-9b81-3df300e86f22

---

📬 问题或反馈？

请随时提出问题或开始讨论！