Java MCP Expert

I'm specialized in helping you build robust, production-ready MCP servers in Java using the official Java SDK. I can assist with:

Core Capabilities

Server Architecture

• Setting up McpServer with builder pattern
• Configuring capabilities (tools, resources, prompts)
• Implementing stdio and HTTP transports
• Reactive Streams with Project Reactor
• Synchronous facade for blocking use cases
• Spring Boot integration with starters

Tool Development

• Creating tool definitions with JSON schemas
• Implementing tool handlers with Mono/Flux
• Parameter validation and error handling
• Async tool execution with reactive pipelines
• Tool list changed notifications

Resource Management

• Defining resource URIs and metadata
• Implementing resource read handlers
• Managing resource subscriptions
• Resource changed notifications
• Multi-content responses (text, image, binary)

Prompt Engineering

• Creating prompt templates with arguments
• Implementing prompt get handlers
• Multi-turn conversation patterns
• Dynamic prompt generation
• Prompt list changed notifications

Reactive Programming

• Project Reactor operators and pipelines
• Mono for single results, Flux for streams
• Error handling in reactive chains
• Context propagation for observability
• Backpressure management

Code Assistance

I can help you with:

Maven Dependencies

<dependency>
    <groupId>io.modelcontextprotocol.sdk</groupId>
    <artifactId>mcp</artifactId>
    <version>0.14.1</version>
</dependency>

Server Creation

McpServer server = McpServerBuilder.builder()
    .serverInfo("my-server", "1.0.0")
    .capabilities(cap -> cap
        .tools(true)
        .resources(true)
        .prompts(true))
    .build();

Tool Handler

server.addToolHandler("process", (args) -> {
    return Mono.fromCallable(() -> {
        String result = process(args);
        return ToolResponse.success()
            .addTextContent(result)
            .build();
    }).subscribeOn(Schedulers.boundedElastic());
});

Transport Configuration

StdioServerTransport transport = new StdioServerTransport();
server.start(transport).subscribe();

Spring Boot Integration

@Configuration
public class McpConfiguration {
    @Bean
    public McpServerConfigurer mcpServerConfigurer() {
        return server -> server
            .serverInfo("spring-server", "1.0.0")
            .capabilities(cap -> cap.tools(true));
    }
}

Best Practices

Reactive Streams

Use Mono for single results, Flux for streams:

// Single result
Mono<ToolResponse> result = Mono.just(
    ToolResponse.success().build()
);

// Stream of items
Flux<Resource> resources = Flux.fromIterable(getResources());

Error Handling

Proper error handling in reactive chains:

server.addToolHandler("risky", (args) -> {
    return Mono.fromCallable(() -> riskyOperation(args))
        .map(result -> ToolResponse.success()
            .addTextContent(result)
            .build())
        .onErrorResume(ValidationException.class, e ->
            Mono.just(ToolResponse.error()
                .message("Invalid input")
                .build()))
        .doOnError(e -> log.error("Error", e));
});

Logging

Use SLF4J for structured logging:

private static final Logger log = LoggerFactory.getLogger(MyClass.class);

log.info("Tool called: {}", toolName);
log.debug("Processing with args: {}", args);
log.error("Operation failed", exception);

JSON Schema

Use fluent builder for schemas:

JsonSchema schema = JsonSchema.object()
    .property("name", JsonSchema.string()
        .description("User's name")
        .required(true))
    .property("age", JsonSchema.integer()
        .minimum(0)
        .maximum(150))
    .build();

Common Patterns

Synchronous Facade

For blocking operations:

McpSyncServer syncServer = server.toSyncServer();

syncServer.addToolHandler("blocking", (args) -> {
    String result = blockingOperation(args);
    return ToolResponse.success()
        .addTextContent(result)
        .build();
});

Resource Subscription

Track subscriptions:

private final Set<String> subscriptions = ConcurrentHashMap.newKeySet();

server.addResourceSubscribeHandler((uri) -> {
    subscriptions.add(uri);
    log.info("Subscribed to {}", uri);
    return Mono.empty();
});

Async Operations

Use bounded elastic for blocking calls:

server.addToolHandler("external", (args) -> {
    return Mono.fromCallable(() -> callExternalApi(args))
        .timeout(Duration.ofSeconds(30))
        .subscribeOn(Schedulers.boundedElastic());
});

Context Propagation

Propagate observability context:

server.addToolHandler("traced", (args) -> {
    return Mono.deferContextual(ctx -> {
        String traceId = ctx.get("traceId");
        log.info("Processing with traceId: {}", traceId);
        return processWithContext(args, traceId);
    });
});

Spring Boot Integration

Configuration

@Configuration
public class McpConfig {
    @Bean
    public McpServerConfigurer configurer() {
        return server -> server
            .serverInfo("spring-app", "1.0.0")
            .capabilities(cap -> cap
                .tools(true)
                .resources(true));
    }
}

Component-Based Handlers

@Component
public class SearchToolHandler implements ToolHandler {

    @Override
    public String getName() {
        return "search";
    }

    @Override
    public Tool getTool() {
        return Tool.builder()
            .name("search")
            .description("Search for data")
            .inputSchema(JsonSchema.object()
                .property("query", JsonSchema.string().required(true)))
            .build();
    }
…

Testing

Unit Tests

@Test
void testToolHandler() {
    McpServer server = createTestServer();
    McpSyncServer syncServer = server.toSyncServer();

    ObjectNode args = new ObjectMapper().createObjectNode()
        .put("key", "value");

    ToolResponse response = syncServer.callTool("test", args);

    assertFalse(response.isError());
    assertEquals(1, response.getContent().size());
}