keepAliveInterval修改为可配置

Author: relat-ivity

framework/fel/java/plugins/tool-mcp-server/src/main/java/modelengine/fel/tool/mcp/server/config/McpSseServerConfig.java

@@ -26,10 +26,11 @@
 @Component
 public class McpSseServerConfig {
     @Bean
-    public FitMcpSseServerTransportProvider fitMcpSseServerTransportProvider() {
+    public FitMcpSseServerTransportProvider fitMcpSseServerTransportProvider(
+            @Value("${mcp.server.keep-alive-interval-seconds}") int keepAliveIntervalSeconds) {
         return FitMcpSseServerTransportProvider.builder()
                 .jsonMapper(McpJsonMapper.getDefault())
-                .keepAliveInterval(Duration.ofSeconds(30))
+                .keepAliveInterval(Duration.ofSeconds(keepAliveIntervalSeconds))
                 .build();
     }
 

framework/fel/java/plugins/tool-mcp-server/src/main/java/modelengine/fel/tool/mcp/server/config/McpStreamableServerConfig.java

@@ -26,10 +26,11 @@
 @Component
 public class McpStreamableServerConfig {
     @Bean
-    public FitMcpStreamableServerTransportProvider fitMcpStreamableServerTransportProvider() {
+    public FitMcpStreamableServerTransportProvider fitMcpStreamableServerTransportProvider(
+            @Value("${mcp.server.keep-alive-interval-seconds}") int keepAliveIntervalSeconds) {
         return FitMcpStreamableServerTransportProvider.builder()
                 .jsonMapper(McpJsonMapper.getDefault())
-                .keepAliveInterval(Duration.ofSeconds(30))
+                .keepAliveInterval(Duration.ofSeconds(keepAliveIntervalSeconds))
                 .build();
     }
 

framework/fel/java/plugins/tool-mcp-server/src/main/resources/application.yml

@@ -6,4 +6,5 @@ fit:
 mcp:
   server:
     request:
-      timeout-seconds: 60
+      timeout-seconds: 60
+    keep-alive-interval-seconds: 30

framework/fel/java/plugins/tool-mcp-server/src/test/java/modelengine/fel/tool/mcp/server/support/DefaultMcpServerTest.java

@@ -45,10 +45,10 @@ public class DefaultMcpServerTest {
     void setup() {
         this.toolExecuteService = mock(ToolExecuteService.class);
         McpSseServerConfig sseConfig = new McpSseServerConfig();
-        this.mcpSyncSseServer = sseConfig.mcpSyncSseServer(sseConfig.fitMcpSseServerTransportProvider(), 10);
+        this.mcpSyncSseServer = sseConfig.mcpSyncSseServer(sseConfig.fitMcpSseServerTransportProvider(30), 10);
         McpStreamableServerConfig streamableConfig = new McpStreamableServerConfig();
         this.mcpStreamableSyncServer =
-                streamableConfig.mcpSyncStreamableServer(streamableConfig.fitMcpStreamableServerTransportProvider(),
+                streamableConfig.mcpSyncStreamableServer(streamableConfig.fitMcpStreamableServerTransportProvider(30),
                         10);
     }