feat(vertx-demo): 添加 MCP 协议支持

vertx-demo/build.gradle.kts

@@ -41,16 +41,8 @@ tasks.test {
   }
 }
 
-tasks.compileKotlin {
+kotlin {
-  kotlinOptions {
+  jvmToolchain(17)
-    jvmTarget = "17"
-  }
-}
-
-tasks.compileTestKotlin {
-  kotlinOptions {
-    jvmTarget = "17"
-  }
 }
 
 spotless {
@@ -88,10 +80,9 @@ dependencies {
   implementation("io.vertx:vertx-auth-jwt:$vertxVersion")
   implementation("io.vertx:vertx-redis-client:$vertxVersion")
 
-  implementation("dev.langchain4j:langchain4j-open-ai:1.0.0-beta1")
   implementation("dev.langchain4j:langchain4j:1.0.0-beta1")
-
+  implementation("dev.langchain4j:langchain4j-open-ai:1.0.0-beta1")
-
+  implementation("dev.langchain4j:langchain4j-mcp:1.0.0-beta1")
 
   implementation("com.google.inject:guice:5.1.0")
   implementation("org.reflections:reflections:0.10.2")

vertx-demo/src/main/kotlin/app/controller/ChatController.kt

@@ -1,12 +1,12 @@
 package app.controller
 
+import app.port.mcp.AiClient
 import com.google.inject.Inject
 import dev.langchain4j.model.chat.request.ChatRequestParameters
 import dev.langchain4j.model.chat.response.ChatResponse
 import dev.langchain4j.model.chat.response.StreamingChatResponseHandler
 import dev.langchain4j.model.openai.OpenAiChatModel
 import dev.langchain4j.model.openai.OpenAiStreamingChatModel
-import io.vertx.core.http.HttpServerResponse
 import io.vertx.ext.web.RoutingContext
 import kotlinx.coroutines.CoroutineScope
 import kotlinx.coroutines.Dispatchers
@@ -109,4 +109,21 @@ class ChatController @Inject constructor(
 
     return null
   }
+
+
+  @AllowAnonymous
+  @D("MCP测试", "详细说明......")
+  suspend fun chatWithMcp(
+    @D("message", "提问") message: String,
+  ): String {
+    val aiService = AiClient.getAiAssistant()
+
+    return withContext(Dispatchers.IO) {
+
+      val response = aiService.chat(message)
+      println(response)
+
+      return@withContext response
+    }
+  }
 }

vertx-demo/src/main/kotlin/app/port/mcp/AiClient.kt

@@ -0,0 +1,75 @@
+package app.port.mcp
+
+import dev.langchain4j.mcp.McpToolProvider
+import dev.langchain4j.mcp.client.DefaultMcpClient
+import dev.langchain4j.mcp.client.McpClient
+import dev.langchain4j.mcp.client.transport.stdio.StdioMcpTransport
+import dev.langchain4j.memory.chat.MessageWindowChatMemory
+import dev.langchain4j.model.chat.ChatLanguageModel
+import dev.langchain4j.model.chat.request.ChatRequestParameters
+import dev.langchain4j.model.openai.OpenAiChatModel
+import dev.langchain4j.service.AiServices
+import kotlinx.coroutines.Dispatchers
+import kotlinx.coroutines.withContext
+import mu.KotlinLogging
+import org.aikrai.vertx.config.Config
+
+interface AiAssistant {
+  fun chat(message: String): String
+}
+
+object AiClient {
+  private val logger = KotlinLogging.logger { }
+  val baseUrl = Config.getKey("langchain4j.open-ai.chat-model.base-url").toString()
+  val apiKey = Config.getKey("langchain4j.open-ai.chat-model.api-key").toString()
+  val modelName = Config.getKey("langchain4j.open-ai.chat-model.model-name").toString()
+
+
+  private suspend fun createMcpClient(): McpClient {
+    val apiKey = Config.getKey("weather.api.api-key").toString()
+    return withContext(Dispatchers.IO) {
+      DefaultMcpClient.Builder()
+        .transport(
+//          HttpMcpTransport.Builder()
+//            .sseUrl("http://127.0.0.1:17080/sse")
+//            .build()
+          StdioMcpTransport.Builder()
+            .command(
+              listOf(
+                "java",
+                "-Dspring.ai.mcp.server.stdio=true",
+                "-jar",
+                "vertx-demo/src/main/resources/mcp-demo-0.0.1-SNAPSHOT.jar",
+                "--weather.api.api-key=${apiKey}"
+              )
+            )
+            .logEvents(true)
+            .build()
+        )
+        .build()
+    }
+  }
+
+  private fun createChatClient(): ChatLanguageModel {
+    return OpenAiChatModel.builder()
+      .baseUrl(baseUrl)
+      .apiKey(apiKey)
+      .defaultRequestParameters(
+        ChatRequestParameters.builder()
+          .modelName(modelName)
+          .build()
+      )
+      .build()
+  }
+
+  suspend fun getAiAssistant(): AiAssistant {
+    val toolProvider = McpToolProvider.builder()
+      .mcpClients(listOf(createMcpClient()))
+      .build()
+    return AiServices.builder(AiAssistant::class.java)
+      .chatLanguageModel(createChatClient())
+      .chatMemory(MessageWindowChatMemory.withMaxMessages(10))
+      .toolProvider(toolProvider)
+      .build()
+  }
+}

vertx-fw/build.gradle.kts

@@ -27,16 +27,8 @@ tasks.test {
   }
 }
 
-tasks.compileKotlin {
+kotlin {
-  kotlinOptions {
+  jvmToolchain(17)
-    jvmTarget = "17"
-  }
-}
-
-tasks.compileTestKotlin {
-  kotlinOptions {
-    jvmTarget = "17"
-  }
 }
 
 spotless {