MCP App Integration Demo

MCP应用集成演示

演示仓库：用于将MCP服务器集成到使用外部应用程序/工具的环境中。

什么是MCP（模型上下文协议）？

MCP是一种开放协议，它使人工智能应用和模型能够安全地访问外部数据源和工具。它为人工智能系统与各种服务、数据库和应用之间的交互提供了一种标准化的方式。

连接到MCP服务器的初始步骤

先决条件

• Python 3.8 或更高版本
• mcp Python包
• 访问MCP服务器端点

安装

pip install mcp

基本连接设置

1. 导入所需的模块

   from mcp import Client
   from mcp.types import GetResourcesRequest
   import asyncio

1. 初始化MCP客户端

   async def connect_to_mcp_server():
       # Replace with your MCP server URL
       server_url = "ws://localhost:8080/mcp"
       
       client = Client()
       await client.connect(server_url)
       
       return client

1. 基本服务器通信

   async def get_server_info(client):
       # Get available resources from the server
       response = await client.list_resources()
       print("Available resources:", response)
       
       # Get server capabilities
       capabilities = await client.get_capabilities()
       print("Server capabilities:", capabilities)

1. 完整示例

   import asyncio
   from mcp import Client

   async def main():
       try:
           # Connect to MCP server
           client = await connect_to_mcp_server()
           
           # Get server information
           await get_server_info(client)
           
           # Your application logic here
           
           # Close connection
           await client.disconnect()
       except Exception as e:
           print(f"Error connecting to MCP server: {e}")

   if __name__ == "__main__":
       asyncio.run(main())

配置选项

认证

# For servers requiring authentication
client = Client(
    auth_token="your-auth-token",
    headers={"Authorization": "Bearer your-token"}
)

超时设置

client = Client(
    timeout=30,  # Connection timeout in seconds
    retry_attempts=3
)

常见用例

1. 数据库访问通过MCP连接到数据库以安全地检索数据
2. API 集成通过MCP服务器访问外部API
3. 文件操作通过MCP执行文件系统操作
4. 工具执行执行外部工具和应用程序

错误处理

from mcp.exceptions import MCPConnectionError, MCPTimeoutError

try:
    client = await connect_to_mcp_server()
except MCPConnectionError as e:
    print(f"Connection failed: {e}")
except MCPTimeoutError as e:
    print(f"Connection timed out: {e}")
except Exception as e:
    print(f"Unexpected error: {e}")

下一步行动

1. 查阅您的MCP服务器文档以获取特定端点信息
2. 实现适当的错误处理和日志记录
3. 为不同环境设置配置管理
4. 根据需要添加身份验证和安全措施
5. 彻底测试集成

做出贡献

欢迎随时提交问题和改进建议！

许可证

这个项目是开源的，可在以下许可下使用： 麻省理工学院许可证.