fix(server): ConfigurableMcpHttpSseServer does not start properly

Author: codeboyzhou

src/main/java/com/github/codeboyzhou/mcp/declarative/server/factory/AbstractConfigurableMcpServerFactory.java

@@ -3,13 +3,9 @@
 import com.github.codeboyzhou.mcp.declarative.configuration.McpServerCapabilities;
 import com.github.codeboyzhou.mcp.declarative.configuration.McpServerChangeNotification;
 import com.github.codeboyzhou.mcp.declarative.configuration.McpServerConfiguration;
-import io.modelcontextprotocol.server.McpAsyncServer;
-import io.modelcontextprotocol.server.McpServer;
 import io.modelcontextprotocol.spec.McpSchema;
 import io.modelcontextprotocol.spec.McpServerTransportProvider;
 
-import java.time.Duration;
-
 public abstract class AbstractConfigurableMcpServerFactory<T extends McpServerTransportProvider> implements ConfigurableMcpServerFactory<T> {
 
     protected final McpServerConfiguration configuration;
@@ -18,16 +14,6 @@ protected AbstractConfigurableMcpServerFactory(McpServerConfiguration configurat
         this.configuration = configuration;
     }
 
-    @Override
-    public McpAsyncServer create() {
-        return McpServer.async(transportProvider())
-            .serverInfo(configuration.name(), configuration.version())
-            .capabilities(serverCapabilities())
-            .instructions(configuration.instructions())
-            .requestTimeout(Duration.ofMillis(configuration.requestTimeout()))
-            .build();
-    }
-
     @Override
     public McpSchema.ServerCapabilities serverCapabilities() {
         McpSchema.ServerCapabilities.Builder capabilities = McpSchema.ServerCapabilities.builder();

src/main/java/com/github/codeboyzhou/mcp/declarative/server/factory/ConfigurableMcpHttpSseServerFactory.java

@@ -1,10 +1,17 @@
 package com.github.codeboyzhou.mcp.declarative.server.factory;
 
+import com.github.codeboyzhou.mcp.declarative.common.NamedThreadFactory;
 import com.github.codeboyzhou.mcp.declarative.configuration.McpServerConfiguration;
 import com.github.codeboyzhou.mcp.declarative.configuration.McpServerSSE;
+import com.github.codeboyzhou.mcp.declarative.server.McpHttpServer;
 import com.github.codeboyzhou.mcp.declarative.util.JsonHelper;
+import io.modelcontextprotocol.server.McpAsyncServer;
+import io.modelcontextprotocol.server.McpServer;
 import io.modelcontextprotocol.server.transport.HttpServletSseServerTransportProvider;
 
+import java.time.Duration;
+import java.util.concurrent.Executors;
+
 public class ConfigurableMcpHttpSseServerFactory extends AbstractConfigurableMcpServerFactory<HttpServletSseServerTransportProvider> {
 
     public ConfigurableMcpHttpSseServerFactory(McpServerConfiguration configuration) {
@@ -20,4 +27,19 @@ public HttpServletSseServerTransportProvider transportProvider() {
         return new HttpServletSseServerTransportProvider(JsonHelper.MAPPER, baseUrl, messageEndpoint, sseEndpoint);
     }
 
+    @Override
+    public McpAsyncServer create() {
+        HttpServletSseServerTransportProvider transportProvider = transportProvider();
+        McpAsyncServer server = McpServer.async(transportProvider)
+            .serverInfo(configuration.name(), configuration.version())
+            .capabilities(serverCapabilities())
+            .instructions(configuration.instructions())
+            .requestTimeout(Duration.ofMillis(configuration.requestTimeout()))
+            .build();
+        McpHttpServer httpServer = new McpHttpServer(transportProvider, configuration.sse().port());
+        NamedThreadFactory threadFactory = new NamedThreadFactory(McpHttpServer.class.getSimpleName());
+        Executors.newSingleThreadExecutor(threadFactory).execute(httpServer::start);
+        return server;
+    }
+
 }

src/main/java/com/github/codeboyzhou/mcp/declarative/server/factory/ConfigurableMcpStdioServerFactory.java

@@ -1,9 +1,13 @@
 package com.github.codeboyzhou.mcp.declarative.server.factory;
 
 import com.github.codeboyzhou.mcp.declarative.configuration.McpServerConfiguration;
+import io.modelcontextprotocol.server.McpAsyncServer;
+import io.modelcontextprotocol.server.McpServer;
 import io.modelcontextprotocol.server.transport.StdioServerTransportProvider;
 import io.modelcontextprotocol.spec.McpServerTransportProvider;
 
+import java.time.Duration;
+
 public class ConfigurableMcpStdioServerFactory extends AbstractConfigurableMcpServerFactory<McpServerTransportProvider> {
 
     public ConfigurableMcpStdioServerFactory(McpServerConfiguration configuration) {
@@ -15,4 +19,14 @@ public McpServerTransportProvider transportProvider() {
         return new StdioServerTransportProvider();
     }
 
+    @Override
+    public McpAsyncServer create() {
+        return McpServer.async(transportProvider())
+            .serverInfo(configuration.name(), configuration.version())
+            .capabilities(serverCapabilities())
+            .instructions(configuration.instructions())
+            .requestTimeout(Duration.ofMillis(configuration.requestTimeout()))
+            .build();
+    }
+
 }