fix(mcp): 修复发现注册到 nacos 上的 mcp server 时， 无法正确发现 https 协议的 mcp server 的问题

pom.xml

@@ -229,7 +229,7 @@
 
         <!-- Nacos -->
         <nacos2.version>2.5.1</nacos2.version>
-        <nacos3.version>3.0.2</nacos3.version>
+        <nacos3.version>3.0.3</nacos3.version>
         <nacos-client-mse-extension.version>1.0.4</nacos-client-mse-extension.version>
         <spring-alibaba-nacos-config.version>2023.0.1.3</spring-alibaba-nacos-config.version>
 

spring-ai-alibaba-mcp/spring-ai-alibaba-mcp-common/src/main/java/com/alibaba/cloud/ai/mcp/nacos/service/NacosMcpOperationService.java

@@ -174,7 +174,7 @@ public McpEndpointInfo selectEndpoint(McpServiceRef mcpServiceRef) throws NacosE
 		return mcpEndpointInfo;
 	}
 
-	public boolean createMcpServer(String mcpName, McpServerBasicInfo serverSpec, McpToolSpecification toolSpec,
+	public String createMcpServer(String mcpName, McpServerBasicInfo serverSpec, McpToolSpecification toolSpec,
 			McpEndpointSpec endpointSpec) throws NacosException {
 		endpointSpec.getData().put("namespaceId", this.namespace);
 		return aiMaintainerService.createMcpServer(this.namespace, mcpName, serverSpec, toolSpec, endpointSpec);

spring-ai-alibaba-mcp/spring-ai-alibaba-mcp-registry/src/main/java/com/alibaba/cloud/ai/mcp/discovery/client/transport/LoadbalancedMcpAsyncClient.java

@@ -354,8 +354,8 @@ private void updateAll(NacosMcpServerEndpoint newServerEndpoint) {
 
 	private McpAsyncClient clientByEndpoint(McpEndpointInfo mcpEndpointInfo, String exportPath) {
 		McpAsyncClient asyncClient;
-
-		String baseUrl = "http://" + mcpEndpointInfo.getAddress() + ":" + mcpEndpointInfo.getPort();
+		String protocol = NacosMcpClientUtils.checkProtocol(mcpEndpointInfo);
+		String baseUrl = protocol + "://" + mcpEndpointInfo.getAddress() + ":" + mcpEndpointInfo.getPort();
 		WebClient.Builder webClientBuilder = webClientBuilderTemplate.clone().baseUrl(baseUrl);
 
 		WebFluxSseClientTransport transport;

spring-ai-alibaba-mcp/spring-ai-alibaba-mcp-registry/src/main/java/com/alibaba/cloud/ai/mcp/discovery/client/transport/LoadbalancedMcpSyncClient.java

@@ -294,7 +294,8 @@ public void setLoggingLevel(McpSchema.LoggingLevel loggingLevel) {
 
 	private McpSyncClient clientByEndpoint(McpEndpointInfo mcpEndpointInfo, String exportPath) {
 		McpSyncClient syncClient;
-		String baseUrl = "http://" + mcpEndpointInfo.getAddress() + ":" + mcpEndpointInfo.getPort();
+		String protocol = NacosMcpClientUtils.checkProtocol(mcpEndpointInfo);
+		String baseUrl = protocol + "://" + mcpEndpointInfo.getAddress() + ":" + mcpEndpointInfo.getPort();
 		WebClient.Builder webClientBuilder = webClientBuilderTemplate.clone().baseUrl(baseUrl);
 
 		// Using the build method with link tracking

spring-ai-alibaba-mcp/spring-ai-alibaba-mcp-registry/src/main/java/com/alibaba/cloud/ai/mcp/discovery/client/utils/NacosMcpClientUtils.java

@@ -27,4 +27,17 @@ public static String getMcpEndpointInfoId(McpEndpointInfo mcpEndpointInfo, Strin
 		return mcpEndpointInfo.getAddress() + "@@" + mcpEndpointInfo.getPort() + "@@" + exportPath;
 	}
 
+	public static String checkProtocol(McpEndpointInfo mcpEndpointInfo) {
+		String protocol = mcpEndpointInfo.getProtocol();
+		if (protocol == null || !"http".equals(protocol) && !"https".equals(protocol)) {
+			if (mcpEndpointInfo.getPort() == 443 || mcpEndpointInfo.getPort() == 8443) {
+				protocol = "https";
+			}
+			else {
+				protocol = "http";
+			}
+		}
+		return protocol;
+	}
+
 }