![\"\u5728\u8fd9\u91cc\u63d2\u5165\u56fe\u7247\u63cf\u8ff0\"](\"https:\/\/www.wsisp.com\/helps\/wp-content\/uploads\/2025\/07\/20250729235724-68895fe4e9a1c.png\")
\n
![\"\u5728\u8fd9\u91cc\u63d2\u5165\u56fe\u7247\u63cf\u8ff0\"](\"https:\/\/www.wsisp.com\/helps\/wp-content\/uploads\/2025\/07\/20250729235725-68895fe5bc102.png\")
<\/p>\n\u53c2\u8003：https:\/\/gofastmcp.com\/deployment\/running-server#the-run-method<\/p>\n
stdio\u672c\u5730\u4f7f\u7528；sse\u3001streamable-http\u8fdc\u7a0b\u8c03\u7528（
\nStreamable HTTP\u2014New in version: 2.3.0）<\/p>\n
\n<\/p>\n
\u8c03\u7528：
\nstdio\u3001sse
\n![\"\u5728\u8fd9\u91cc\u63d2\u5165\u56fe\u7247\u63cf\u8ff0\"](\"https:\/\/www.wsisp.com\/helps\/wp-content\/uploads\/2025\/07\/20250729235726-68895fe625ec5.png\")
\nstreamable-http
\n![\"\u5728\u8fd9\u91cc\u63d2\u5165\u56fe\u7247\u63cf\u8ff0\"](\"https:\/\/www.wsisp.com\/helps\/wp-content\/uploads\/2025\/07\/20250729235726-68895fe64a600.png\")
<\/p>\n
\u53c2\u8003：
\nhttps:\/\/gofastmcp.com\/clients\/client<\/p>\n
config\u5982\u679c\u53ea\u6709\u4e00\u4e2a\u670d\u52a1，\u90a3call_tool\u51fd\u6570\u4e0d\u7528\u524d\u7f00\u76f4\u63a5\u5de5\u5177\u51fd\u6570\u540d，\u5982\u679c\u591a\u4e2a\u670d\u52a1，\u9700\u8981\u6dfb\u52a0\u524d\u7f00<\/p>\n
from fastmcp import Client<\/p>\n
# Standard MCP configuration with multiple servers
\nconfig = {
\n "mcpServers": {
\n "trip": {"url": "http:\/\/localhost:8000\/sse"},
\n "math":{
\n "command": "python",
\n "args": [".\/api_mcp_server_math.py"],
\n "env": {"DEBUG": "true"}
\n }<\/p>\n
}
\n}<\/p>\n
async def main():
\n async with Client(config) as client:<\/p>\n
tools = await client.list_tools()
\n print("Available tools:")
\n for tool in tools: ###\u6253\u5370\u7ed3\u679c\u7cfb\u7edf\u4e5f\u81ea\u52a8\u52a0\u4e86\u524d\u7f00
\n print(f" – {tool.name}: {tool.description}")<\/p>\n
hotel_response = await client.call_tool("trip_check_hotel", {"cityname": "\u5e7f\u5dde","date": "\u540e\u5929"})
\n math_response = await client.call_tool("math_add", {"a": 1, "b": 2})
\n print("Math response:", math_response)
\n print("Hotel response:", hotel_response)<\/p>\n
if __name__ == "__main__":
\n import asyncio
\n asyncio.run(main())<\/p>\n
for tool in tools: ###\u6253\u5370\u7ed3\u679c\u7cfb\u7edf\u4e5f\u81ea\u52a8\u52a0\u4e86\u524d\u7f00
\nprint(f" – {tool.name}: {tool.description}")
\n![\"\u5728\u8fd9\u91cc\u63d2\u5165\u56fe\u7247\u63cf\u8ff0\"](\"https:\/\/www.wsisp.com\/helps\/wp-content\/uploads\/2025\/07\/20250729235726-68895fe6f392d.png\")
<\/p>\n
![\"\u5728\u8fd9\u91cc\u63d2\u5165\u56fe\u7247\u63cf\u8ff0\"](\"https:\/\/www.wsisp.com\/helps\/wp-content\/uploads\/2025\/07\/20250729235727-68895fe769de6.png\")
<\/p>\n
\u6a21\u578b\u81ea\u52a8\u8c03\u7528\u5de5\u5177，LLM \u6839\u636e\u7528\u6237\u8f93\u5165\u81ea\u52a8\u9009\u62e9\u5408\u9002\u7684\u5de5\u5177；\u4f7f\u7528\u767e\u70bcqwen3\u601d\u8003\u6a21\u578b\u6d41\u5f0f\u8f93\u51fa<\/p>\n
#!\/usr\/bin\/python3
\n# -*- coding: utf-8 -*-<\/p>\n
import json
\nimport asyncio
\nfrom typing import List, Dict, Optional<\/p>\n
from openai import OpenAI
\nfrom fastmcp import Client<\/p>\n
class IntegratedMCPClient:
\n def __init__(self, config: Dict, model="qwen3-235b-a22b"):
\n """
\n \u521d\u59cb\u5316\u96c6\u6210\u7684 MCP \u5ba2\u6237\u7aef<\/p>\n
Args:
\n config: MCP \u670d\u52a1\u5668\u914d\u7f6e\u5b57\u5178
\n model: \u4f7f\u7528\u7684\u6a21\u578b\u540d\u79f0
\n """
\n self.config = config
\n self.model = model<\/p>\n
# \u521d\u59cb\u5316 OpenAI \u5ba2\u6237\u7aef
\n self.client = OpenAI(
\n api_key="sk-424971",
\n base_url="https:\/\/dashscope.ale-mode\/v1"
\n )<\/p>\n
# \u521d\u59cb\u5316 MCP \u5ba2\u6237\u7aef
\n self.session = Client(config)
\n self.tools = []
\n self.server_tool_mapping = {} # \u8bb0\u5f55\u5de5\u5177\u6765\u81ea\u54ea\u4e2a\u670d\u52a1\u5668<\/p>\n
async def prepare_tools(self):
\n """\u51c6\u5907\u6240\u6709\u53ef\u7528\u7684\u5de5\u5177"""
\n try:
\n # \u83b7\u53d6\u6240\u6709\u5de5\u5177
\n tools = await self.session.list_tools()
\n print(f"\u53d1\u73b0 {len(tools)} \u4e2a\u53ef\u7528\u5de5\u5177:")<\/p>\n
self.tools = []
\n self.server_tool_mapping = {}<\/p>\n
for tool in tools:
\n print(f" – {tool.name}: {tool.description}")<\/p>\n
# \u6784\u5efa\u5de5\u5177\u63cf\u8ff0
\n tool_def = {
\n "type": "function",
\n "function": {
\n "name": tool.name,
\n "description": tool.description,
\n "parameters": tool.inputSchema,
\n }
\n }
\n self.tools.append(tool_def)<\/p>\n
# \u8bb0\u5f55\u5de5\u5177\u6620\u5c04（\u5982\u679c\u9700\u8981\u533a\u5206\u6765\u6e90）
\n # \u8fd9\u91cc\u53ef\u4ee5\u901a\u8fc7\u5de5\u5177\u540d\u524d\u7f00\u6216\u5176\u4ed6\u65b9\u5f0f\u6765\u8bc6\u522b\u6765\u6e90\u670d\u52a1\u5668
\n if tool.name.startswith("trip_"):
\n self.server_tool_mapping[tool.name] = "trip"
\n elif tool.name.startswith("math_"):
\n self.server_tool_mapping[tool.name] = "math"
\n else:
\n self.server_tool_mapping[tool.name] = "unknown"<\/p>\n
except Exception as e:
\n print(f"\u51c6\u5907\u5de5\u5177\u65f6\u51fa\u9519: {e}")
\n self.tools = []<\/p>\n
async def chat(self, messages: List[Dict]) -> Optional[object]:
\n """\u5904\u7406\u804a\u5929\u5bf9\u8bdd，\u652f\u6301\u5de5\u5177\u8c03\u7528"""
\n if not self.tools:
\n await self.prepare_tools()<\/p>\n
try:
\n # \u4f7f\u7528\u6d41\u5f0f\u54cd\u5e94，\u542f\u7528\u601d\u8003\u8fc7\u7a0b
\n response = self.client.chat.completions.create(
\n model=self.model,
\n messages=messages,
\n tools=self.tools if self.tools else None,
\n temperature=0,
\n max_tokens=16000,
\n stream=True,
\n logprobs=False,
\n stream_options={"include_usage": True},
\n extra_body={
\n "enable_thinking": True # \u542f\u7528\u601d\u8003\u8fc7\u7a0b
\n }
\n )<\/p>\n
# \u6536\u96c6\u6d41\u5f0f\u54cd\u5e94
\n collected_content = ""
\n collected_tool_calls = []
\n finish_reason = None<\/p>\n
print("AI: ", end="", flush=True)<\/p>\n
for chunk in response:
\n # \u5b89\u5168\u68c0\u67e5：\u9632\u6b62\u7a7a\u7684 choices
\n if not chunk.choices:
\n continue<\/p>\n
delta = chunk.choices[0].delta
\n finish_reason = chunk.choices[0].finish_reason<\/p>\n
# \u6253\u5370\u601d\u8003\u8fc7\u7a0b（Qwen \u7279\u6709\u5b57\u6bb5）
\n reasoning = getattr(delta, "reasoning_content", None)
\n if reasoning:
\n print(f"{reasoning}", end="", flush=True)<\/p>\n
# \u6253\u5370\u5e38\u89c4\u5185\u5bb9
\n if delta.content:
\n print(delta.content, end="", flush=True)
\n collected_content += delta.content<\/p>\n
# \u6536\u96c6\u5de5\u5177\u8c03\u7528
\n if hasattr(delta, 'tool_calls') and delta.tool_calls:
\n if not collected_tool_calls:
\n collected_tool_calls = [
\n {"id": "", "function": {"name": "", "arguments": ""}}
\n for _ in delta.tool_calls
\n ]<\/p>\n
for i, tool_call_delta in enumerate(delta.tool_calls):
\n if tool_call_delta.id:
\n collected_tool_calls[i]["id"] = tool_call_delta.id
\n if tool_call_delta.function:
\n if tool_call_delta.function.name:
\n collected_tool_calls[i]["function"]["name"] = tool_call_delta.function.name
\n if tool_call_delta.function.arguments:
\n collected_tool_calls[i]["function"]["arguments"] += tool_call_delta.function.arguments<\/p>\n
print() # \u6362\u884c<\/p>\n
# \u5982\u679c\u6ca1\u6709\u5de5\u5177\u8c03\u7528，\u8fd4\u56de\u6536\u96c6\u7684\u5185\u5bb9
\n if finish_reason != 'tool_calls' or not collected_tool_calls:
\n class SimpleMessage:
\n def __init__(self, content):
\n self.content = content
\n return SimpleMessage(collected_content)<\/p>\n
# \u5904\u7406\u5de5\u5177\u8c03\u7528
\n print("\\\\n[\u6b63\u5728\u8c03\u7528\u5de5\u5177…]")
\n assistant_message = {
\n 'role': 'assistant',
\n 'content': collected_content,
\n 'tool_calls': [
\n {
\n "id": tc["id"],
\n "type": "function",
\n "function": {
\n "name": tc["function"]["name"],
\n "arguments": tc["function"]["arguments"]
\n }
\n }
\n for tc in collected_tool_calls
\n ]
\n }<\/p>\n
print(f"[\u52a9\u624b\u6d88\u606f]: \u8c03\u7528\u4e86 {len(collected_tool_calls)} \u4e2a\u5de5\u5177")
\n messages.append(assistant_message)<\/p>\n
# \u6267\u884c\u6bcf\u4e2a\u5de5\u5177\u8c03\u7528
\n for tool_call in collected_tool_calls:
\n try:
\n tool_name = tool_call['function']['name']
\n tool_args = json.loads(tool_call['function']['arguments'])
\n server_name = self.server_tool_mapping.get(tool_name, "unknown")<\/p>\n
print(f"\\\\n[\u6267\u884c\u5de5\u5177]: {tool_name} (\u6765\u81ea\u670d\u52a1\u5668: {server_name})")
\n print(f"[\u5de5\u5177\u53c2\u6570]: {tool_args}")<\/p>\n
# \u8c03\u7528\u5de5\u5177
\n result = await self.session.call_tool(tool_name, tool_args)<\/p>\n
# \u5904\u7406\u7ed3\u679c
\n result_content = ""
\n if result:
\n if isinstance(result, list) and len(result) > 0:
\n if hasattr(result[0], 'text'):
\n result_content = result[0].text
\n else:
\n result_content = str(result[0])
\n else:
\n result_content = str(result)
\n else:
\n result_content = "No result"<\/p>\n
# \u6dfb\u52a0\u5de5\u5177\u7ed3\u679c\u5230\u6d88\u606f\u4e2d
\n messages.append({
\n 'role': 'tool',
\n 'tool_call_id': tool_call['id'],
\n 'content': result_content
\n })<\/p>\n
print(f"[\u5de5\u5177\u7ed3\u679c]: {result_content}")<\/p>\n
except Exception as e:
\n print(f"[\u5de5\u5177\u8c03\u7528\u9519\u8bef]: {e}")
\n messages.append({
\n 'role': 'tool',
\n 'tool_call_id': tool_call['id'],
\n 'content': f"Error executing tool: {str(e)}"
\n })<\/p>\n
# \u4f7f\u7528\u5de5\u5177\u7ed3\u679c\u83b7\u53d6\u6700\u7ec8\u54cd\u5e94
\n print("\\\\n[\u751f\u6210\u6700\u7ec8\u56de\u7b54…]")
\n return await self.chat(messages)<\/p>\n
except Exception as e:
\n print(f"\u804a\u5929\u8fc7\u7a0b\u4e2d\u51fa\u9519: {e}")
\n class ErrorMessage:
\n def __init__(self, content):
\n self.content = content
\n return ErrorMessage(f"\u62b1\u6b49，\u5904\u7406\u60a8\u7684\u8bf7\u6c42\u65f6\u51fa\u73b0\u9519\u8bef: {str(e)}")<\/p>\n
async def loop(self):
\n """\u4ea4\u4e92\u5f0f\u804a\u5929\u5faa\u73af"""
\n print("=== \u96c6\u6210 MCP \u5ba2\u6237\u7aef\u542f\u52a8 ===")
\n print("\u652f\u6301\u7684\u547d\u4ee4:")
\n print(" – quit\/exit\/bye: \u9000\u51fa\u7a0b\u5e8f")
\n print(" – tools: \u663e\u793a\u53ef\u7528\u5de5\u5177")
\n print(" – clear: \u6e05\u9664\u5bf9\u8bdd\u5386\u53f2")
\n print("=====================================\\\\n")<\/p>\n
conversation_history = []<\/p>\n
while True:
\n try:
\n async with self.session:
\n # \u5982\u679c\u662f\u7b2c\u4e00\u6b21\u8fdb\u5165，\u51c6\u5907\u5de5\u5177
\n if not self.tools:
\n await self.prepare_tools()<\/p>\n
question = input("\\\\nUser: ").strip()<\/p>\n
# \u5904\u7406\u7279\u6b8a\u547d\u4ee4
\n if question.lower() in ['quit', 'exit', 'bye']:
\n print("\u518d\u89c1！")
\n break
\n elif question.lower() == 'tools':
\n print(f"\\\\n\u53ef\u7528\u5de5\u5177 ({len(self.tools)} \u4e2a):")
\n for tool in self.tools:
\n func = tool['function']
\n server = self.server_tool_mapping.get(func['name'], 'unknown')
\n print(f" – {func['name']} (\u670d\u52a1\u5668: {server})")
\n print(f" \u63cf\u8ff0: {func['description']}")
\n continue
\n elif question.lower() == 'clear':
\n conversation_history = []
\n print("\u5bf9\u8bdd\u5386\u53f2\u5df2\u6e05\u9664")
\n continue
\n elif not question:
\n continue<\/p>\n
# \u6dfb\u52a0\u7528\u6237\u6d88\u606f\u5230\u5386\u53f2
\n user_message = {"role": "user", "content": question}
\n current_messages = conversation_history + [user_message]<\/p>\n
# \u83b7\u53d6\u54cd\u5e94
\n response = await self.chat(current_messages.copy())<\/p>\n
if response and hasattr(response, 'content'):
\n print(f"\\\\n\u56de\u7b54: {response.content}")<\/p>\n
# \u66f4\u65b0\u5bf9\u8bdd\u5386\u53f2
\n conversation_history.append(user_message)
\n conversation_history.append({"role": "assistant", "content": response.content})<\/p>\n
# \u9650\u5236\u5386\u53f2\u957f\u5ea6，\u907f\u514d\u4e0a\u4e0b\u6587\u8fc7\u957f
\n if len(conversation_history) > 20: # \u4fdd\u7559\u6700\u8fd110\u8f6e\u5bf9\u8bdd
\n conversation_history = conversation_history[-20:]<\/p>\n
except KeyboardInterrupt:
\n print("\\\\n\\\\n\u7a0b\u5e8f\u88ab\u7528\u6237\u4e2d\u65ad")
\n break
\n except Exception as e:
\n print(f"\u5faa\u73af\u8fc7\u7a0b\u4e2d\u51fa\u9519: {e}")
\n continue<\/p>\n
async def single_query(self, query: str) -> str:
\n """\u5355\u6b21\u67e5\u8be2\u63a5\u53e3，\u9002\u7528\u4e8e\u975e\u4ea4\u4e92\u5f0f\u4f7f\u7528"""
\n try:
\n async with self.session:
\n if not self.tools:
\n await self.prepare_tools()<\/p>\n
messages = [{"role": "user", "content": query}]
\n response = await self.chat(messages)<\/p>\n
return response.content if response and hasattr(response, 'content') else "\u65e0\u54cd\u5e94"<\/p>\n
except Exception as e:
\n return f"\u67e5\u8be2\u5931\u8d25: {str(e)}"<\/p>\n
async def main():
\n """\u4e3b\u51fd\u6570"""
\n # MCP \u914d\u7f6e
\n config = {
\n "mcpServers": {
\n "trip": {"url": "http:\/\/localhost:8000\/sse"},
\n "math": {
\n "command": "python",
\n "args": [".\/api_mcp_server_math.py"],
\n "env": {"DEBUG": "true"}
\n }
\n }
\n }<\/p>\n
print("\u6b63\u5728\u521d\u59cb\u5316\u96c6\u6210 MCP \u5ba2\u6237\u7aef…")
\n mcp_client = IntegratedMCPClient(config)<\/p>\n
# \u542f\u52a8\u4ea4\u4e92\u5f0f\u5faa\u73af
\n await mcp_client.loop()<\/p>\n
async def test_single_queries():
\n """\u6d4b\u8bd5\u5355\u6b21\u67e5\u8be2\u7684\u793a\u4f8b"""
\n config = {
\n "mcpServers": {
\n "trip": {"url": "http:\/\/localhost:8000\/sse"},
\n "math": {
\n "command": "python",
\n "args": [".\/api_mcp_server_math.py"],
\n "env": {"DEBUG": "true"}
\n }
\n }
\n }<\/p>\n
mcp_client = IntegratedMCPClient(config)<\/p>\n
# \u6d4b\u8bd5\u67e5\u8be2
\n test_queries = [
\n "\u5e2e\u6211\u67e5\u8be2\u5e7f\u5dde\u540e\u5929\u7684\u9152\u5e97\u4fe1\u606f",
\n "\u8ba1\u7b97 15 \u52a0 27 \u7b49\u4e8e\u591a\u5c11",
\n "\u6211\u60f3\u77e5\u9053\u5317\u4eac\u660e\u5929\u6709\u4ec0\u4e48\u597d\u7684\u9152\u5e97\u63a8\u8350",
\n "\u8ba1\u7b97 100 \u4e58\u4ee5 50",
\n "\u4f60\u597d，\u8bf7\u4ecb\u7ecd\u4e00\u4e0b\u4f60\u7684\u529f\u80fd"
\n ]<\/p>\n
for query in test_queries:
\n print(f"\\\\n{'='*50}")
\n print(f"\u6d4b\u8bd5\u67e5\u8be2: {query}")
\n print(f"{'='*50}")<\/p>\n
result = await mcp_client.single_query(query)
\n print(f"\u7ed3\u679c: {result}")<\/p>\n
if __name__ == '__main__':
\n # \u8fd0\u884c\u4ea4\u4e92\u5f0f\u6a21\u5f0f
\n asyncio.run(main())<\/p>\n
# \u6216\u8005\u8fd0\u884c\u6d4b\u8bd5\u6a21\u5f0f
\n # asyncio.run(test_single_queries())<\/p>\n
![\"\u5728\u8fd9\u91cc\u63d2\u5165\u56fe\u7247\u63cf\u8ff0\"](\"https:\/\/www.wsisp.com\/helps\/wp-content\/uploads\/2025\/07\/20250729235727-68895fe79ca45.png\")
<\/p>\n","protected":false},"excerpt":{"rendered":"
\u6587\u7ae0\u6d4f\u89c8\u9605\u8bfb570\u6b21\u3002\u6458\u8981\uff1a\u672c\u6587\u5c55\u793a\u4e86\u5982\u4f55\u4f7f\u7528fastmcp\u5e93\u7684Client\u7c7b\u914d\u7f6e\u548c\u8c03\u7528\u591a\u670d\u52a1\u5de5\u5177\u3002\u793a\u4f8b\u4ee3\u7801\u6f14\u793a\u4e86\u540c\u65f6\u914d\u7f6e"trip"\u548c"math"\u4e24\u4e2a\u670d\u52a1\uff0c\u5206\u522b\u901a\u8fc7HTTP\u548c\u547d\u4ee4\u884c\u542f\u52a8\u3002\u901a\u8fc7call_tool\u65b9\u6cd5\u8c03\u7528\u4e0d\u540c\u524d\u7f00\u7684\u670d\u52a1\u5de5\u5177\uff08\u5982"trip_check_hotel"\u548c"math_add"\uff09\uff0c\u5e76\u5904\u7406\u8fd4\u56de\u7ed3\u679c\u3002\u5f53\u914d\u7f6e\u591a\u4e2a\u670d\u52a1\u65f6\u9700\u8981\u6dfb\u52a0\u524d\u7f00\u533a\u5206\uff0c\u800c\u5355\u670d\u52a1\u914d\u7f6e\u5219\u53ef\u76f4\u63a5\u8c03\u7528\u5de5\u5177\u51fd\u6570\u540d\u3002\u4ee3\u7801\u91c7\u7528\u5f02\u6b65\u4e0a\u4e0b\u6587\u7ba1\u7406\u5668\u786e\u4fdd\u8d44\u6e90\u6b63\u786e\u91ca\u653e\u3002_fastmcp sse<\/p>\n","protected":false},"author":2,"featured_media":47454,"comment_status":"open","ping_status":"open","sticky":false,"template":"","format":"standard","meta":{"footnotes":""},"categories":[1],"tags":[74,73,4545,43],"topic":[],"class_list":["post-47461","post","type-post","status-publish","format-standard","has-post-thumbnail","hentry","category-server","tag-agent","tag-mcp","tag-ai","tag-43"],"yoast_head":"\n