MCP集群演示

使用mcp-amqp-transport框架进行学术研究的AI代理系统

架构

拦截器管道：

1. 分析 → 将消息记录到Opensearch以供分析
2. 安全 → 流量限制 + 内容过滤

MCP服务器：

• Firecrawl（网络爬虫）
• Arxiv（学术论文）

快速开始

# 启动Kubernetes
minikube start
eval $(minikube docker-env)

# 构建并部署MCP服务器
cd mcp_cluster
docker build -f Dockerfile.amqp-transport -t mcp-amqp-transport:latest .
kubectl apply -f k8s/

# 构建并部署拦截器
cd ../interceptors_cluster
docker build -f Dockerfile.monitor -t monitor-interceptor:latest .
docker build -f Dockerfile.safety -t safety-interceptor:latest .
docker build -f Dockerfile.opensearch-logger -t opensearch-logger:latest .
kubectl apply -f k8s_storage/
kubectl apply -f k8s/

# 运行代理
cd ../agent
uv sync
uv run agent.py

配置

更新ConfigMaps中的RabbitMQ凭据：

• mcp_cluster/k8s/amqp-config.yaml
• interceptors_cluster/k8s/*-config.yaml

监控

kubectl get pods
kubectl logs -f deployment/safety-interceptor
kubectl port-forward service/opensearch-dashboards 5601:5601

功能

• 容错性：消息持久化防止数据丢失
• 水平扩展：通过绑定队列到交换机来添加服务器
• 安全性：每客户端20次调用限制，600字响应限制
• 可观测性：CloudWatch + OpenSearch日志
• 分析：标记计数和消息索引

清理

kubectl delete -f interceptors_cluster/k8s/
kubectl delete -f mcp_cluster/k8s/
minikube stop