Anet MCP服务器
Rust实现 模型控制协议（MCP） 服务器，通过标准化协议实现客户端和AI模型之间的通信。
该项目提供了一个可扩展的异步框架，用于使用 锈, 东京，以及 NATS。它是为开发商建筑而设计的 AI代理系统, 基于LLM的工具，或自定义 JSON-RPC 2.0 服务层。该架构支持实时消息传递，非常适合 微服务, AI编排，以及 基于工具的模型交互.
______________________________________________________________________
特性
- ✅ JSON-RPC 2.0兼容API
- 🔄 用于消息传递的NATS传输层
- 🛠️ 可扩展工具系统
- 🧠 支持提示和资源
- ⚡ 与Tokio的异步请求处理
______________________________________________________________________
需求
- 锈 1.70+
- NATS 本地运行或可通过网络访问的服务器
______________________________________________________________________
安装
将以下内容添加到您的 Cargo.toml:
[dependencies]
anet_mcp_server = "0.1.0"______________________________________________________________________
入门指南
运行示例服务器
存储库包括一个演示核心功能的基本示例服务器：
# Start a NATS server in another terminal or ensure one is already running
# Example:
nats-server
# Run the example server
cargo run --example basic_server测试服务器
您可以使用附带的测试客户端测试服务器：
cargo run --example test_client这将向服务器发送各种请求并打印响应。
______________________________________________________________________
用法
创建服务器
use anet_mcp_server::{
ServerBuilder, ServerCapabilities,
transport::nats::NatsTransport,
};
use serde_json::json;
#[tokio::main]
async fn main() -> anyhow::Result {
let transport = NatsTransport::new("nats://localhost:4222", "mcp.requests").await?;
let server = ServerBuilder::new()
.transport(transport)
.name("my-mcp-server")
.version("0.1.0")
.capabilities(ServerCapabilities {
tools: Some(json!({})),
prompts: Some(json!({})),
resources: Some(json!({})),
notification_options: None,
experimental_capabilities: None,
})
.build()?;
server.run().await
}______________________________________________________________________
实现自定义工具
use anet_mcp_server::{Content, Tool};
use async_trait::async_trait;
use serde_json::{json, Value};
struct MyTool;
#[async_trait]
impl Tool for MyTool {
fn name(&self) -> String {
"my_tool".to_string()
}
fn description(&self) -> String {
"A custom tool".to_string()
}
fn input_schema(&self) -> Value {
json!({
"type": "object",
"properties": {
"input": { "type": "string" }
}
})
}
async fn call(&self, input: Option) -> anyhow::Result> {
Ok(vec![Content::Text {
text: "Tool response".to_string()
}])
}
}______________________________________________________________________
api参考
服务器实现了以下功能 JSON-RPC 方法：
initialize–初始化连接并获取服务器信息listTools–获取可用工具列表callTool–调用带有参数的特定工具listResources–获取可用资源列表readResource–阅读特定资源listPrompts–获取可用提示列表getPrompt–获取带有参数的特定提示
______________________________________________________________________
建筑
服务器采用模块化设计：
- 服务器 –核心服务器逻辑和请求处理
- 运输 –消息传输层（目前为NATS）
- 工具 –工具接口和实施
- 类型 –通用数据结构
______________________________________________________________________
许可证
MIT许可证
Let me know if you want badges, contribution guidelines, or example JSON-RPC payloads added to the README as well.