使用C#创建一个MCP客户端

前言

网上使用Python创建一个MCP客户端的教程已经有很多了，而使用C#创建一个MCP客户端的教程还很少。
为什么要创建一个MCP客户端呢？
创建了一个MCP客户端之后，你就可以使用别人写好的一些MCP服务了。
效果展示

为了方便大家复现，我没有使用WPF/Avalonia之类的做界面。只是一个简单的控制台程序，可以很容易看懂。

接入了fetch_mcp可以实现获取网页内容了，使用的模型只要具有tool use能力的应该都可以。
我使用的是Qwen/Qwen2.5-72B-Instruct。
开始实践

主要使用的包如下所示：

首先获取MCP服务器：

1. private static async Task<IMcpClient> GetMcpClientAsync()
2. {
3.      DotEnv.Load();
4.      var envVars = DotEnv.Read();
5.      McpClientOptions options = new()
6.      {
7.          ClientInfo = new() { Name = "SimpleToolsConsole", Version = "1.0.0" }
8.      };
10.      var config = new McpServerConfig
11.      {
12.          Id = "test",
13.          Name = "Test",
14.          TransportType = TransportTypes.StdIo,
15.          TransportOptions = new Dictionary<string, string>
16.          {
17.              ["command"] = envVars["MCPCommand"],
18.              ["arguments"] = envVars["MCPArguments"],
19.          }
20.      };
22.      var factory = new McpClientFactory(
23.          new[] { config },
24.          options,
25.          NullLoggerFactory.Instance
26.      );
28.      return await factory.GetClientAsync("test");
29. }

复制代码

写死的话就是这样写：

1. private static async Task<IMcpClient> GetMcpClientAsync()
2. {
3.      DotEnv.Load();
4.      var envVars = DotEnv.Read();
5.      McpClientOptions options = new()
6.      {
7.          ClientInfo = new() { Name = "SimpleToolsConsole", Version = "1.0.0" }
8.      };
10.      var config = new McpServerConfig
11.      {
12.          Id = "test",
13.          Name = "Test",
14.          TransportType = TransportTypes.StdIo,
15.          TransportOptions = new Dictionary<string, string>
16.          {
17.              ["command"] = node,
18.              ["arguments"] = D:/Learning/AI-related/fetch-mcp/dist/index.js,
19.          }
20.      };
22.      var factory = new McpClientFactory(
23.          new[] { config },
24.          options,
25.          NullLoggerFactory.Instance
26.      );
28.      return await factory.GetClientAsync("test");
29. }

复制代码

重点在：

1. TransportOptions = new Dictionary<string, string>
2.          {
3.              ["command"] = node,
4.              ["arguments"] = D:/Learning/AI-related/fetch-mcp/dist/index.js,
5.          }

复制代码

用于连接你想连接的MCP服务器。
如果能正确显示你连接mcp服务器提供的工具，说明连接成功。

1.   var listToolsResult = await client.ListToolsAsync();
2.   var mappedTools = listToolsResult.Tools.Select(t => t.ToAITool(client)).ToList();
3.   Console.WriteLine("Tools available:");
4.   foreach (var tool in mappedTools)
5.   {
6.       Console.WriteLine("  " + tool);
7.   }

复制代码

开启一个聊天循环：

1.     Console.WriteLine("\nMCP Client Started!");
2.     Console.WriteLine("Type your queries or 'quit' to exit.");
4.     ChatDemo chatDemo = new ChatDemo();
6.     while (true)
7.     {
8.         try
9.         {
10.             Console.ForegroundColor = ConsoleColor.DarkYellow;
11.             Console.Write("\nQuery: ");
12.             string query = Console.ReadLine()?.Trim() ?? string.Empty;
14.             if (query.ToLower() == "quit")
15.                 break;
16.             if (query.ToLower() == "clear")
17.             {
18.                 Console.Clear();
19.                 chatDemo.Messages.Clear();                    
20.             }
21.             else
22.             {
23.                 string response = await chatDemo.ProcessQueryAsync(query, mappedTools);
24.                 Console.ForegroundColor = ConsoleColor.DarkYellow;
25.                 Console.WriteLine($"AI回答：{response}");
26.                 Console.ForegroundColor = ConsoleColor.White;
27.             }                     
28.         }
29.         catch (Exception ex)
30.         {
31.             Console.WriteLine($"\nError: {ex.Message}");
32.         }
33.     }
34. }

复制代码

处理每次询问：

1. public async Task<string> ProcessQueryAsync(string query, List tools)
2. {
3.      if(Messages.Count == 0)
4.      {
5.          Messages =
6.          [
7.           // Add a system message
8.          new(ChatRole.System, "You are a helpful assistant, helping us test MCP server functionality."),
9.          ];
10.      }
11.      
12.      // Add a user message
13.      Messages.Add(new(ChatRole.User, query));
15.      var response = await ChatClient.GetResponseAsync(
16.             Messages,
17.             new() { Tools = tools });
18.      Messages.AddMessages(response);
19.      var toolUseMessage = response.Messages.Where(m => m.Role == ChatRole.Tool);
21.      if (toolUseMessage.Count() > 0)
22.      {
23.          var functionMessage = response.Messages.Where(m => m.Text == "").First();            
24.          var functionCall = (FunctionCallContent)functionMessage.Contents[1];
25.          Console.ForegroundColor = ConsoleColor.Green;
26.          string arguments = "";
27.          foreach (var arg in functionCall.Arguments)
28.          {
29.              arguments += $"{arg.Key}:{arg.Value};";
30.          }
31.          Console.WriteLine($"调用函数名:{functionCall.Name};参数信息：{arguments}");
32.          foreach (var message in toolUseMessage)
33.          {
34.              var functionResultContent = (FunctionResultContent)message.Contents[0];
35.              Console.WriteLine($"调用工具结果：{functionResultContent.Result}");
36.          }
38.          Console.ForegroundColor = ConsoleColor.White;
39.      }
40.      else
41.      {
42.          Console.ForegroundColor = ConsoleColor.Green;
43.          Console.WriteLine("本次没有调用工具");
44.          Console.ForegroundColor = ConsoleColor.White;
45.      }
47.      return response.Text;
48. }

复制代码

代码已经放到GitHub，地址：https://github.com/Ming-jiayou/mcp_demo。
将.env-example修改为.env应该就可以运行，如果报错，设置成嵌入的资源即可。
.env配置示例：

1. API_KEY=sk-xxx
2. BaseURL=https://api.siliconflow.cn/v1
3. ModelID=Qwen/Qwen2.5-72B-Instruct
4. MCPCommand=node
5. MCPArguments=D:/Learning/AI-related/fetch-mcp/dist/index.js

复制代码

最后

对C#使用MCP感兴趣的朋友可以关注这个项目：https://github.com/PederHP/mcpdotnet。
有问题欢迎一起交流学习。

来源：程序园用户自行投稿发布，如果侵权，请联系站长删除
免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！