jFinal 使用 SolonMCP 开发 MCP（拥抱新潮流）

MCP 官方的 java-sdk 目前只支持 java17+。直接基于 mcp-java-sdk 也比较复杂。使用 SolonMCP，可以基于 java8 开发（像 MVC 的开发风格），且比较简单。
1、SolonMCP 简介

SolonMCP（全称：solon-ai-mcp）是 solon 的一个扩展。支持内嵌到 jfinal，vert.x，springboot2，springboot3 等框架使用。
Maven 主要依赖包：

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

复制代码

具体的示例参考：

• https://gitee.com/opensolon/solon-ai-mcp-embedded-examples/tree/main/solon-ai-embedded-jfinal
  
• https://gitee.com/opensolon/solon-ai-mcp-embedded-examples/tree/main/solon-ai-embedded-jfinal-newstyle
  

2、MCP 服务端开发

2.1、添加入口类 webapp.HelloApp（比较空，注意下 mcpServerConfig）

MCP 内部是基于响应式的，需要开启异步支持。

1. public class HelloApp extends JFinalConfig {
2.     public static void main(String[] args) {
3.         UndertowServer.create(HelloApp.class)
4.                 .setDevMode(false)
5.                 .setPort(8080)
6.                 .onDeploy((cl, di) -> {
7.                     di.getFilters().get("jfinal").setAsyncSupported(true); //注意这个，要开启异步支持
8.                 }).start();
9.     }
11.     public void configConstant(Constants me) {
12.         me.setDevMode(false);
13.     }
15.     public void configRoute(Routes me) {
16.     }
18.     public void configEngine(Engine me) {
19.     }
21.     public void configPlugin(Plugins me) {
22.         me.add(mcpServerConfig);
23.     }
25.     public void configInterceptor(Interceptors me) {
26.     }
28.     public void configHandler(Handlers me) {
29.         me.add(mcpServerConfig);
30.     }
32.     private McpServerConfig mcpServerConfig = new McpServerConfig();
33. }

复制代码

2.2、添加 webapp.mcpserver.McpServerConfig（实现 Handler、IPlugin 接口）

实现 IPlugin 对接 Solon 的生命周期。实现 Handler 对接 mcp 的请求处理。

1. public class McpServerConfig extends Handler implements IPlugin {
2.     public boolean start() {
3.         Solon.start(McpServerConfig.class, new String[]{"--cfg=mcpserver.yml"});
4.         return true;
5.     }
7.     public boolean stop() {
8.         if (Solon.app() != null) {
9.             Solon.stopBlock(false, Solon.cfg().stopDelay());
10.         }
11.         return true;
12.     }
14.     @Override
15.     public void handle(String target, HttpServletRequest request, HttpServletResponse response, boolean[] isHandled) {
16.         if (target.startsWith("/mcp/")) {
17.             Context ctx = new SolonServletContext(request, response);
19.             try {
20.                 //Solon处理(可能是空处理)
21.                 Solon.app().tryHandle(ctx);
23.                 if (isHandled != null && isHandled.length > 0) {
24.                     isHandled[0] = true;
25.                 }
26.             } catch (Throwable e) {
27.                 ctx.errors = e;
29.                 throw e;
30.             } finally {
31.                 ContextUtil.currentRemove();
32.             }
33.         } else {
34.             if (next != null) {
35.                 next.handle(target, request, response, isHandled);
36.             }
37.         }
38.     }
39. }

复制代码

2.3、添加 webapp.mcpserver.tool.McpServer（实现 Handler、IPlugin 接口）

这里是重点了，添加 mcp server 端点（支持多个端点）

1. @McpServerEndpoint(sseEndpoint = "/mcp/sse")
2. public class McpServer {
3.     //
4.     // 建议开启编译参数：-parameters （否则，最好再配置参数的 name）
5.     //
6.     @ToolMapping(description = "查询天气预报")
7.     public String getWeather(@Param(description = "城市位置") String location) {
8.         return "晴，14度";
9.     }
11.     @ResourceMapping(uri = "config://app-version", description = "获取应用版本号")
12.     public String getAppVersion() {
13.         return "v3.2.0";
14.     }
16.     @ResourceMapping(uri = "db://users/{user_id}/email", description = "根据用户ID查询邮箱")
17.     public String getEmail(@Param(description = "用户Id") String user_id) {
18.         return user_id + "@example.com";
19.     }
21.     @PromptMapping(description = "生成关于某个主题的提问")
22.     public Collection<ChatMessage> askQuestion(@Param(description = "主题") String topic) {
23.         return Arrays.asList(
24.                 ChatMessage.ofUser("请解释一下'" + topic + "'的概念？")
25.         );
26.     }
27. }

复制代码

2.4、编译后运行

或者开发时，直接运行 HelloApp:main 方法
3、MCP 客户端开发

客户端简单些

1. public class McpClientTest {
2.     public static void main(String[] args) throws Exception {
3.         McpClientProvider toolProvider = McpClientProvider.builder()
4.                 .apiUrl("http://localhost:8080/mcp/sse")
5.                 .build();
7.         //工具调用
8.         Map<String, Object> map = Collections.singletonMap("location", "杭州");
9.         String rst = toolProvider.callToolAsText("getWeather", map).getContent();
10.         System.out.println(rst);
11.         assert "晴，14度".equals(rst);
12.         
13.         
14.         //资源读取
15.         resourceContent = toolProvider.readResourceAsText("config://app-version").getContent();
16.         System.out.println(resourceContent);
17.     }
18. }

复制代码

4、MCP 客户端作为 LLM（ChatModel） 的工具集使用

也比较简单。使用 ollama 做为 llm 提供者，方便本地测试。

1. public class McpClientTest {
2.     private static final String apiUrl = "http://127.0.0.1:11434/api/chat";
3.     private static final String provider = "ollama";
4.     private static final String model = "qwen2.5:1.5b"; //"llama3.2";//deepseek-r1:1.5b;
5.    
6.     public static void main(String[] args) throws Exception {
7.         //构建 mcp client
8.         McpClientProvider toolProvider = McpClientProvider.builder()
9.                 .apiUrl("http://localhost:8080/mcp/sse")
10.                 .build();
12.         //构建 llm 接口
13.         ChatModel chatModel = ChatModel.of(apiUrl)
14.                 .provider(provider)
15.                 .model(model)
16.                 .defaultToolsAdd(toolProvider) //添加默认工具（这是 mcp client）
17.                 .build();
18.         
19.         //请求
20.         ChatResponse resp = chatModel.prompt("杭州今天的天气怎么样？")
21.                 .call();
23.         System.out.println(resp.getMessage());
24.     }
25. }

复制代码

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