开发 Java MCP 服务像写 Controller 一样简单，支持 Java 8

开发 Java MCP 服务像写 Controller 一样简单，支持 Java 8 | 极客日志

<dependency>
    <groupId>org.noear</groupId>
    <artifactId>solon-ai-mcp</artifactId>
</dependency>

@McpServerEndpoint(name = "it-tools", channel = McpChannel.STREAMABLE, mcpEndpoint = "/mcp")
public class MyMcpServer {
    @ToolMapping(description = "查询服务器负载")
    public String getServerLoad(@Param("serverId") String id, @Header("token") String token) {
        return "Server " + id + " load is 15%";
    }
}

@Configuration
public class McpServerConfig {
    @Bean("mcp-weather")
    public McpServerEndpointProvider serverEndpoint() {
        McpServerEndpointProvider serverEndpoint = McpServerEndpointProvider.builder()
                .name("mcp-weather")
                .channel(McpChannel.STDIO)
                .build();
        FunctionToolDesc weatherTool = new FunctionToolDesc("get_weather")
                .description("获取指定城市的天气情况")
                .stringParamAdd("location", "根据用户提到的地点推测城市")
                .doHandle(map -> { return "24 度"; });
        serverEndpoint.addTool(new MethodToolProvider(weatherTool));
        return serverEndpoint;
    }
}

@McpServerEndpoint(channel = McpChannel.STREAMABLE_STATELESS, mcpEndpoint = "/mcp")
public class McpServerTool implements ToolProvider {
    private McpClientProvider stdioToolProvider = McpClientProvider.builder()
            .channel(McpChannel.STDIO)
            // 表示使用 stdio.command("npx").args("-y","@gitee/mcp-gitee@latest")
            .addEnvVar("GITEE_API_BASE", "https://gitee.com/api/v5")
            .addEnvVar("GITEE_ACCESS_TOKEN", "<your personal access token>")
            .build();

    @Override
    public Collection<FunctionTool> getTools() {
        return stdioToolProvider.getTools();
    }
}

// 客户端
public class SamplingClientDemo {
    public void test() {
        McpClientProvider clientProvider = McpClientProvider.builder()
                .url("http://localhost:8080/mcp")
                .customize(spec -> {
                    spec.capabilities(McpSchema.ClientCapabilities.builder().sampling().build());
                    spec.sampling(req -> Mono.just(
                        McpSchema.CreateMessageResult.builder()
                            .content(new McpSchema.TextContent("test"))
                            .build()
                    ));
                })
                .build();
        clientProvider.callToolAsText("demo", Utils.asMap("a", 1)).getContent();
    }
}

// 服务端
@McpServerEndpoint(channel = McpChannel.STREAMABLE, mcpEndpoint = "/mcp")
public class SamplingServerDemo {
    // 可以注入 exchange（实现反向通讯：服务端向客户端请求）
    @ToolMapping(description = "复杂任务拆解")
    public Mono<McpSchema.CreateMessageResult> demo(McpAsyncServerExchange exchange) {
        // 服务端向客户端请求 AI 采样决策
        return exchange.createMessage(
            McpSchema.CreateMessageRequest.builder()
                .messages(Collections.singletonList(
                    McpSchema.PromptMessage.builder()
                        .role(McpSchema.Role.USER)
                        .content(new McpSchema.TextContent("请帮我拆解这个任务..."))
                        .build()
                ))
                .build()
        );
    }
}

McpClientProvider clientProvider = McpClientProvider.builder()
        .channel(McpChannel.STREAMABLE)
        .url("http://localhost:8080/mcp")
        .build();
// 获取所有工具原语
clientProvider.getTools();
// 获取所有模板原语
clientProvider.getResources();
// 获取所有资源模板原语
clientProvider.getResourceTemplates();
// 获取所有提示词原语
clientProvider.getPrompts();

ChatModel chatModel = ChatModel.of(apiUrl).defaultToolAdd(clientProvider).build();
ReActAgent agent = ReActAgent.of(chatModel);

ChatModel chatModel = ChatModel.of(apiUrl).build();
ReActAgent agent = ReActAgent.of(chatModel).defaultToolAdd(clientProvider).build();

import org.noear.solon.ai.chat.skill.Skill;
import org.noear.solon.ai.chat.skill.SkillDesc;
import org.noear.solon.ai.mcp.McpChannel;
import org.noear.solon.ai.mcp.client.McpClientProvider;

public class McpSkillDemo {
    public void test() {
        // 1. 创建 MCP 客户端，从远端获取工具生态
        // 这里假设远端 Server 提供了如 "restart_server", "query_log" 等运维工具
        McpClientProvider devopsMcpProvider = McpClientProvider.builder()
                .channel(McpChannel.STREAMABLE)
                .url("http://devops-center:8080/mcp")
                .build();

        // 2. 使用 SkillDesc 将 MCP 工具集包装成一个'智能运维技能'
        Skill devopsSkill = SkillDesc.builder("devops-skill")
                .description("高级运维管理技能，支持服务器状态查询与故障处理")
                // 智能分发：只有当用户提问包含'服务器'、'重启'、'日志'时才激活此技能
                .isSupported("服务器", "重启", "日志", "负载")
                // 动态指令：为技能注入特殊的 System Prompt 引导
                .instruction(prompt -> {
                    return "你现在是一名高级架构师。在执行重启操作前，请务必确认操作人的权限。";
                })
                // 挂载工具：核心一步！直接将 MCP 获取的所有工具注入到该技能中
                .toolAdd(devopsMcpProvider)
                // 钩子函数：当技能被挂载到会话时触发逻辑（如：记录审计日志）
                .onAttach(prompt -> {
                    System.out.println("检测到运维相关指令，DevOps 技能已就绪...");
                })
                .build();

        // 3. 应用技能：将技能交给 Agent
        ChatModel chatModel = ChatModel.of(apiUrl).build();
        ReActAgent agent = ReActAgent.of(chatModel).defaultSkillAdd(devopsSkill).build();
        // 此时 Agent 只有在聊到运维话题时，才会通过 MCP 协议去调用对应的远端工具
        agent.prompt("帮我查一下 server-01 的负载情况").call();
    }
}

开发 Java MCP 服务像写 Controller 一样简单，支持 Java 8

开发 Java MCP 服务像写 Controller 一样简单，支持 Java 8

一、为什么 Java 开发者需要 MCP？

MCP 彻底改变了游戏规则：

二、Solon-AI：为 MCP 而生的 Java 框架

核心依赖：

1. 像写 Controller 一样写 Mcp Server

2. 除了注解开发外，支持'动态构建'：

3. 强大的协议代理转换

4. 支持'反向通讯'，比如：Sampling 采样

5. '三合一'的超级客户端

三、生产级的稳健性

四、借助 Skills 实现智能加载（智能分发）

五、Solon-AI + MCP 的典型场景

场景 A：企业私有数据助手

场景 B：跨语言工具链整合

场景 C：智能 IDE 与本地自动化

六、总结

更多推荐文章

相关免费在线工具

开发 Java MCP 服务像写 Controller 一样简单，支持 Java 8

开发 Java MCP 服务像写 Controller 一样简单，支持 Java 8

一、为什么 Java 开发者需要 MCP？

MCP 彻底改变了游戏规则：

二、Solon-AI：为 MCP 而生的 Java 框架

核心依赖：

1. 像写 Controller 一样写 Mcp Server

2. 除了注解开发外，支持'动态构建'：

3. 强大的协议代理转换

4. 支持'反向通讯'，比如：Sampling 采样

5. '三合一'的超级客户端

三、生产级的稳健性

四、借助 Skills 实现智能加载（智能分发）

五、Solon-AI + MCP 的典型场景

场景 A：企业私有数据助手

场景 B：跨语言工具链整合

场景 C：智能 IDE 与本地自动化

六、总结

微信扫一扫，关注极客日志

更多推荐文章

相关免费在线工具