feat(server): Introduce HttpMode enum and update server configuration for HTTP mode support

Author: codeboyzhou

src/main/java/com/github/codeboyzhou/mcp/declarative/McpServers.java

@@ -3,11 +3,13 @@
 import com.github.codeboyzhou.mcp.declarative.common.GuiceInjectorModule;
 import com.github.codeboyzhou.mcp.declarative.configuration.McpServerConfiguration;
 import com.github.codeboyzhou.mcp.declarative.configuration.YAMLConfigurationLoader;
+import com.github.codeboyzhou.mcp.declarative.enums.HttpMode;
 import com.github.codeboyzhou.mcp.declarative.server.McpHttpServer;
 import com.github.codeboyzhou.mcp.declarative.server.component.McpServerPromptFactory;
 import com.github.codeboyzhou.mcp.declarative.server.component.McpServerResourceFactory;
 import com.github.codeboyzhou.mcp.declarative.server.component.McpServerToolFactory;
 import com.github.codeboyzhou.mcp.declarative.server.configurable.ConfigurableMcpHttpSseServerFactory;
+import com.github.codeboyzhou.mcp.declarative.server.configurable.ConfigurableMcpHttpStreamableServerFactory;
 import com.github.codeboyzhou.mcp.declarative.server.configurable.ConfigurableMcpServerFactory;
 import com.github.codeboyzhou.mcp.declarative.server.configurable.ConfigurableMcpStdioServerFactory;
 import com.github.codeboyzhou.mcp.declarative.server.simple.SimpleMcpHttpSseServerFactory;
@@ -19,7 +21,7 @@
 import com.google.inject.Guice;
 import com.google.inject.Injector;
 import io.modelcontextprotocol.server.McpAsyncServer;
-import io.modelcontextprotocol.spec.McpServerTransportProvider;
+import io.modelcontextprotocol.spec.McpServerTransportProviderBase;
 import io.modelcontextprotocol.util.Assert;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
@@ -44,23 +46,23 @@ public static McpServers run(Class<?> applicationMainClass, String[] args) {
   public void startStdioServer(SimpleMcpServerBaseInfo serverInfo) {
     SimpleMcpStdioServerFactory factory = new SimpleMcpStdioServerFactory();
     McpAsyncServer server = factory.create(serverInfo);
-    registerComponents(server);
+    registerComponentsTo(server);
   }
 
   public void startSseServer(SimpleMcpHttpSseServerInfo serverInfo) {
     SimpleMcpHttpSseServerFactory factory = new SimpleMcpHttpSseServerFactory();
     McpAsyncServer server = factory.create(serverInfo);
     McpHttpServer httpserver = new McpHttpServer();
     httpserver.use(factory.transportProvider(serverInfo)).bind(serverInfo.port()).start();
-    registerComponents(server);
+    registerComponentsTo(server);
   }
 
   public void startStreamableServer(SimpleMcpHttpStreamableServerInfo serverInfo) {
     SimpleMcpHttpStreamableServerFactory factory = new SimpleMcpHttpStreamableServerFactory();
     McpAsyncServer server = factory.create(serverInfo);
     McpHttpServer httpserver = new McpHttpServer();
     httpserver.use(factory.transportProvider(serverInfo)).bind(serverInfo.port()).start();
-    registerComponents(server);
+    registerComponentsTo(server);
   }
 
   public void startServer(String configFileName) {
@@ -80,17 +82,24 @@ private void doStartServer(McpServerConfiguration configuration) {
       return;
     }
 
-    ConfigurableMcpServerFactory<? extends McpServerTransportProvider> factory;
+    ConfigurableMcpServerFactory<? extends McpServerTransportProviderBase> factory;
     if (configuration.stdio()) {
       factory = new ConfigurableMcpStdioServerFactory(configuration);
     } else {
-      factory = new ConfigurableMcpHttpSseServerFactory(configuration);
+      final String httpMode = configuration.httpMode().name();
+      if (HttpMode.SSE.name().equalsIgnoreCase(httpMode)) {
+        factory = new ConfigurableMcpHttpSseServerFactory(configuration);
+      } else if (HttpMode.STREAMABLE.name().equalsIgnoreCase(httpMode)) {
+        factory = new ConfigurableMcpHttpStreamableServerFactory(configuration);
+      } else {
+        throw new NullPointerException("factory is null, please check your configuration");
+      }
     }
     McpAsyncServer server = factory.create();
-    registerComponents(server);
+    registerComponentsTo(server);
   }
 
-  private void registerComponents(McpAsyncServer server) {
+  private void registerComponentsTo(McpAsyncServer server) {
     injector.getInstance(McpServerResourceFactory.class).registerTo(server);
     injector.getInstance(McpServerPromptFactory.class).registerTo(server);
     injector.getInstance(McpServerToolFactory.class).registerTo(server);

src/main/java/com/github/codeboyzhou/mcp/declarative/configuration/McpServerConfiguration.java

@@ -1,11 +1,13 @@
 package com.github.codeboyzhou.mcp.declarative.configuration;
 
 import com.fasterxml.jackson.annotation.JsonProperty;
+import com.github.codeboyzhou.mcp.declarative.enums.HttpMode;
 import com.github.codeboyzhou.mcp.declarative.enums.ServerType;
 
 public record McpServerConfiguration(
     @JsonProperty("enabled") boolean enabled,
     @JsonProperty("stdio") boolean stdio,
+    @JsonProperty("http-mode") HttpMode httpMode,
     @JsonProperty("name") String name,
     @JsonProperty("version") String version,
     @JsonProperty("type") ServerType type,

src/main/java/com/github/codeboyzhou/mcp/declarative/enums/HttpMode.java

@@ -0,0 +1,6 @@
+package com.github.codeboyzhou.mcp.declarative.enums;
+
+public enum HttpMode {
+  SSE,
+  STREAMABLE
+}

src/test/resources/mcp-server-sse-mode.yml

@@ -1,5 +1,6 @@
 enabled: true
 stdio: false
+http-mode: sse
 name: mcp-server
 version: 1.0.0
 type: SYNC

src/test/resources/mcp-server.yml

@@ -1,5 +1,6 @@
 enabled: true
 stdio: false
+http-mode: sse
 name: mcp-server-test
 version: 1.0.0
 type: ASYNC