Java SolonMCP 实现 MCP 实践全解析：SSE 与 STDIO 通信模式详解

一、MCP简介

MCP（Model Context Protocol，模型上下文协议）是由Anthropic公司于2024年推出的开放标准，旨在统一AI模型与外部数据源、工具之间的通信方式。MCP提供了一套规范化的接口，使大语言模型（LLM）能够更便捷地与各类外部工具和资源进行交互。
通俗点讲是：

1. 一个专属的 RPC 协议

复制代码

MCP的核心价值在于：

• 标准化接口：为AI模型提供统一的工具发现和使用接口
  
• 安全通信：定义了一套安全的模型与工具之间的通信协议
  
• 跨平台兼容：适用于不同AI提供商的模型
  
• 提升AI能力：让AI能够访问最新数据和执行复杂操作
  

二、SolonMCP 简介

SolonMCP（全称 Solon-AI-MCP）是一个基于 Java 的高级框架，专为构建 MCP 服务器而设计。它极大简化了 MCP 服务器的开发流程，让开发者能够以最小的代码量创建功能强大的MCP服务器。
SolonMCP 的主要特点包括：

• 简洁的 API：通过注解形式，简化MCP服务器的创建
  
• 丰富的功能：支持工具（Tools）、资源（Resources）、提示模板（Prompts）等MCP核心元素
  
• 多种传输方式：支持 STDIO 和 SSE 等不同传输协议
  
• 类型安全：利用 Java 的类型提示，自动生成 MCP 协议所需的模式定义
  
• 内置图像处理：支持图像数据的自动格式转换和处理
  
• 使用 SolonMCP，开发者可以专注于业务逻辑，而不必过多关注底层协议细节。
  

Maven 依赖包：

1. <dependency>
2.     <groupId>org.noear</groupId>
3.     solon-ai-mcp</artifactId>
4.     <version>3.3.1-M1</version>
5. </dependency>

复制代码

Gradle 依赖包：

1. org.noear:solon-ai-mcp:3.3.1-M1

复制代码

三、Java SolonMCP 实现 STDIO 方式

（1）基本示例

下面是一个使用 SolonMCP 实现 STDIO 通信方式的基本示例，创建一个简单的计算器工具 CalculatorTools：

1. @McpServerEndpoint(channel = McpChannel.STDIO)
2. public class CalculatorTools {
3.     @ToolMapping(description = "将两个数字相加")
4.     public int add(@Param int a, @Param int b) {
5.         return a + b;
6.     }
8.     @ToolMapping(description = "从第一个数中减去第二个数")
9.     public int subtract(@Param int a, @Param int b) {
10.         return a - b;
11.     }
13.     @ToolMapping(description = "将两个数相乘")
14.     public int multiply(@Param int a, @Param int b) {
15.         return a * b;
16.     }
18.     @ToolMapping(description = "将第一个数除以第二个数")
19.     public float divide(@Param float a, @Param float b) {
20.         return a / b;
21.     }
22. }

复制代码

在这个示例中，我们：

• 创建了一个名为 CalculatorTools 的 MCP 服务器实例
  
• 使用 @ToolMapping 注解定义了四个计算工具
  
• 通过 @McpServerEndpoint(channel = McpChannel.STDIO) 以 STDIO 模式启动服务器
  

4.2 运行和使用

（先打包成 jar 胖包）运行 STDIO 模式的 MCP 服务器：

1. java -jar demo.jar

复制代码

在这种模式下，服务器将等待标准输入上的请求，然后通过标准输出返回响应。所有支持 STDIO 模式的 MCP 客户端（或工具，或中间件），都可以连接使用。
五、Java SolonMCP 实现 SSE 方式

5.1 基本示例

下面是使用 SolonMCP 实现 SSE 通信方式的示例，创建一个简单的天气服务：

1. @McpServerEndpoint(sseEndpoint = "/mcp/sse")
2. public class WeatherTools {
3.     @ToolMapping(description = "获取指定城市的当前天气")
4.     public String get_weather(@Param String city) {
5.         return "{city: '" + city + "', temperature:[10,25], condition:['sunny', 'clear', 'hot'], unit:celsius}";
6.     }
8.     //给前端用，需要严格的 json 格式
9.     @Produces(MimeType.APPLICATION_JSON_VALUE)
10.     @ResourceMapping(uri = "weather://cities", description = "获取所有可用的城市列表")
11.     public List<String> get_available_cities() {
12.         return Arrays.asList("Tokyo", "Sydney", "Tokyo");
13.     }
15.     @ResourceMapping(uri = "weather://forecast/{city}", description = "获取指定城市的天气预报资源")
16.     public String get_forecast(@Param String city) {
17.          return "{city: '" + city + "', temperature:[10,25], condition:['sunny', 'clear', 'hot'], unit:celsius}";
18.     }
19. }

复制代码

在这个示例中：

• 我们创建了一个名为 "Weather Service" 的 MCP 服务器
  
• 定义了一个 get_weather 工具函数，用于获取城市的当前天气
  
• 添加了两个资源：一个返回所有可用城市的列表，另一个返回指定城市的天气预报
  
• 通过指定 sseEndpoint 以 SSE 模式启动服务器
  

5.2 运行和使用

运行 SSE 模式的 MCP 服务器：

1. java -jar demo.jar

复制代码

服务器将在指定端口（默认为 8080）启动，并监听HTTP连接。您可以通过浏览器访问：

1. http://localhost:8080/mcp/sse

复制代码

要与此服务器交互，可以使用支持 SSE 传输的 MCP 客户端，或者使用如下 Java 代码创建一个简单的客户端：

1. public void test() {
2.     McpClientProvider clientProvider = McpClientProvider.builder()
3.                 .apiUrl("http://localhost:8080/mcp/sse")
4.                 .build();
6.     String rst1 = clientProvider.callToolAsText("get_weather", Map.of("city", "杭州"))
7.                                 .getContent();
8.                                    
9.     String rst2 = clientProvider.readResourceAsText("weather://cities")
10.                                 .getContent();
11. }

复制代码

六、总结

Java SolonMCP 为开发者提供了一种简单高效的方式来构建 MCP 服务器，无论是使用 STDIO 还是 SSE 传输方式。

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