🧠 Model Context Protocol (MCP) - Server-Client Implementation

🧠 Model Context Protocol (MCP) - サーバー・クライアント実装

このプロジェクトは、FastAPI を使用して Server-Sent Events (SSE) で通信する MCP サーバー と MCP クライアント を含む、シンプルな Model Context Protocol (MCP) システムです。HTTP 経由の SSE を使用した軽量なツール呼び出しを実演します。

---

🏗️ アーキテクチャの概要

+-------------+                SSE HTTP                 +-------------+
|             | <------------------------------------>  |             |
| MCP CLIENT  |                                         | MCP SERVER  |
| (FastAPI)   |  /upload_claim  ⇄  upload_claim         | (SSE Tools) |
| Port: 5000  |  /get_claim_details ⇄ get_claim_details | Port: 8000  |
+-------------+                                         +-------------+

---

📁 プロジェクト構成

.
├── client/                     # MCP Client (FastAPI app)
│   └──main.py
│
├── server/                     # MCP Server with SSE tools
│   └──main.py
|
└── README.md
└── requirements.txt

---

🔧 MCP サーバー

• ポート：8000
• フレームワーク：FastAPI
• プロトコル：Server-Sent Events (SSE)
• 定義済みツール：
  • upload_claim
  • get_claim_details

▶️ MCP サーバーの起動

cd server
pip install -r requirements.txt
python main.py

---

🚀 MCP クライアント

• ポート：5000
• フレームワーク：FastAPI
• エンドポイント：
  • POST /upload_claim → MCP サーバー上の upload_claim ツールを呼び出します
  • GET /get_claim_details → MCP サーバー上の get_claim_details ツールを呼び出します

▶️ MCP クライアントの起動

cd client
pip install -r requirements.txt
python main.py

---

🔄 通信フロー

1. クライアントがツールを呼び出すため、SSE HTTP リクエストを MCP サーバーに送信します。
2. サーバーがリクエストを処理し、SSE 経由でレスポンスをストリーミングして返します。

---

📬 リクエスト例

POST /upload_claim

curl -X POST http://localhost:5000/upload_claim \
  -H "Content-Type: application/json" \
  -d '{
        "emp_id": "12345",
        "claim": "This is a dummy claim!"
      }'

POST /get_claim_details

curl -X POST http://localhost:5000/get_claim_details \
  -H "Content-Type: application/json" \
  -d '{
        "claim_id": "12345"
      }'

🧰 要件

Python 3.10+

requirements.txt`

"mcp[cli]"
fastapi
httpx

各ディレクトリで、次のコマンドを使用して依存関係をインストールします。

pip install -r requirements.txt

---

⚠️ 注意事項

• これは、開発または学習目的の最小限のプロトタイプです。
• データはメモリ内に保存され、サーバーの再起動時にリセットされます。
• シンプルさとストリーミングへの対応のため、SSE を使用しています。

---