多引擎搜索服务

cargo run

cargo run -- -p 8080
# 或
cargo run -- --port 8080

🚀 MCP Server running at http://0.0.0.0:3000
🔑 Example: POST http://localhost:3000/mcp?kimi-apiKey=YOUR_KEY
📚 Supported providers: kimi, zai, volces, tencentmaas, aliyuncs

cargo build --release

POST http://localhost:3000/mcp?{参数}

{
  "jsonrpc": "2.0",
  "id": 1,
  "method": "tools/list"
}

{
  "jsonrpc": "2.0",
  "id": 2,
  "method": "tools/call",
  "params": {
    "name": "kimi-search",
    "arguments": {
      "query": "今天北京天气怎么样"
    }
  }
}

{
  "jsonrpc": "2.0",
  "id": 2,
  "result": {
    "content": [
      {
        "type": "text",
        "text": "搜索结果..."
      }
    ]
  }
}

{
  "mcpServers": {
    "web-search": {
      "url": "http://localhost:3000/mcp?kimi-apiKey=YOUR_API_KEY&default-search=kimi"
    }
  }
}

{
  "mcpServers": {
    "web-search": {
      "url": "http://localhost:3000/mcp?kimi-apiKey=YOUR_API_KEY&default-search=kimi"
    }
  }
}

docker build -t web-search-mcp .

docker run -d -p 3000:3000 web-search-mcp

version: '3'
services:
  web-search-mcp:
    build: .
    ports:
      - "3000:3000"

web-search-mcp-rs/
├── src/
│   ├── main.rs               # 🚪 入口文件与 MCP HTTP 服务器（动态路由）
│   └── provider/             # 🔌 搜索引擎 Provider 模块
│       ├── mod.rs            #   ├─ Trait 定义、公共类型与注册表
│       ├── kimi.rs           #   ├─ 🌙 Kimi (Moonshot)
│       ├── zai.rs            #   ├─ 🧠 智谱 (BigModel)
│       ├── volces.rs         #   ├─ 🌋 火山引擎 (豆包)
│       ├── tencentmaas.rs    #   ├─ ☁️ 腾讯云 (混元)
│       └── aliyuncs.rs       #   └─ 🟠 阿里云 (通义千问)
├── Cargo.toml                # ⚙️ Rust 包与依赖配置
├── Dockerfile                # 🐳 Docker 构建文件
└── .github/                  # 🚀 CI/CD 自动化构建与发布

use super::{SearchProvider, WebSearchResult};
use std::collections::HashMap;

pub struct MyEngineProvider;

#[async_trait::async_trait]
impl SearchProvider for MyEngineProvider {
    fn name(&self) -> &str { "myengine" }
    fn tool_name(&self) -> &str { "myengine-search" }
    fn description(&self) -> &str { "我的自定义搜索引擎" }
    fn required_params(&self) -> &[&str] { &["myengine-apiKey"] }

    async fn search(
        &self,
        query: &str,
        params: &HashMap<String, String>,
        client: &reqwest::Client,
    ) -> Result<WebSearchResult, String> {
        let api_key = params.get("myengine-apiKey").unwrap();
        // ... 调用搜索 API ...
        Ok(WebSearchResult::text("搜索结果"))
    }
}

pub mod my_engine;
pub use my_engine::MyEngineProvider;

// 在 build_registry 中添加：
registry.register(Box::new(MyEngineProvider));