MCP 服务器

// 使用自定义配置创建服务器
McpSyncServer syncServer = McpServer.sync(transport)
    .serverInfo("my-server", "1.0.0")
    .capabilities(ServerCapabilities.builder()
        .resources(true)     // 启用资源支持
        .tools(true)         // 启用工具支持
        .prompts(true)       // 启用提示支持
        .logging()           // 启用日志支持
        .build())
    .build();

// 初始化服务器
syncServer.initialize();

// 注册工具、资源和提示
syncServer.addTool(syncToolRegistration);
syncServer.addResource(syncResourceRegistration);
syncServer.addPrompt(syncPromptRegistration);

// 发送日志通知
syncServer.loggingNotification(LoggingMessageNotification.builder()
    .level(LoggingLevel.INFO)
    .logger("custom-logger")
    .data("服务器已初始化")
    .build());

// 完成后关闭服务器
syncServer.close();

// 使用自定义配置创建异步服务器
McpAsyncServer asyncServer = McpServer.async(transport)
    .serverInfo("my-server", "1.0.0")
    .capabilities(ServerCapabilities.builder()
        .resources(true)
        .tools(true)
        .prompts(true)
        .logging()
        .build())
    .build();

// 初始化服务器
asyncServer.initialize()
    .doOnSuccess(v -> logger.info("服务器已初始化"))
    .subscribe();

// 注册工具、资源和提示
asyncServer.addTool(asyncToolRegistration);
asyncServer.addResource(asyncResourceRegistration);
asyncServer.addPrompt(asyncPromptRegistration);

// 发送日志通知
asyncServer.loggingNotification(LoggingMessageNotification.builder()
    .level(LoggingLevel.INFO)
    .logger("custom-logger")
    .data("服务器已初始化")
    .build())
    .subscribe();

// 同步工具注册
var syncToolRegistration = new McpServerFeatures.SyncToolRegistration(
    new Tool("calculator", "执行基本计算", 
        new JsonSchemaObject()
            .addProperty("operation", new JsonSchemaString())
            .addProperty("a", new JsonSchemaNumber())
            .addProperty("b", new JsonSchemaNumber())
    ),
    request -> {
        // 工具实现
        return new CallToolResult(result);
    }
);

// 异步工具注册
var asyncToolRegistration = new McpServerFeatures.AsyncToolRegistration(
    new Tool("calculator", "执行基本计算", 
        new JsonSchemaObject()
            .addProperty("operation", new JsonSchemaString())
            .addProperty("a", new JsonSchemaNumber())
            .addProperty("b", new JsonSchemaNumber())
    ),
    request -> {
        // 工具实现
        return Mono.just(new CallToolResult(result));
    }
);

// 同步资源注册
var syncResourceRegistration = new McpServerFeatures.SyncResourceRegistration(
    new Resource("custom://resource", "名称", "描述", "mime-type", null),
    request -> {
        // 资源读取实现
        return new ReadResourceResult(contents);
    }
);

// 异步资源注册
var asyncResourceRegistration = new McpServerFeatures.AsyncResourceRegistration(
    new Resource("custom://resource", "名称", "描述", "mime-type", null),
    request -> {
        // 资源读取实现
        return Mono.just(new ReadResourceResult(contents));
    }
);

// 同步提示注册
var syncPromptRegistration = new McpServerFeatures.SyncPromptRegistration(
    new Prompt("greeting", "描述", List.of(
        new PromptArgument("name", "描述", true)
    )),
    request -> {
        // 提示实现
        return new GetPromptResult(description, messages);
    }
);

// 异步提示注册
var asyncPromptRegistration = new McpServerFeatures.AsyncPromptRegistration(
    new Prompt("greeting", "描述", List.of(
        new PromptArgument("name", "描述", true)
    )),
    request -> {
        // 提示实现
        return Mono.just(new GetPromptResult(description, messages));
    }
);