添加新接口：获取智能体的Mcp接入点地址（/agent/mcp/address/{audioId}）

--AgentMcpAccessPointServiceImpl.java 实现获取智能体的mcp接入点地址定义 --AgentMcpAccessPointController.java 添加获取智能体的Mcp接入点地址接口
2026-07-22 23:23:55 +08:00 · 2025-06-25 16:37:04 +08:00
parent 21339aba42
commit 0631fe37ea
2 changed files with 93 additions and 0 deletions
@@ -0,0 +1,31 @@
+package xiaozhi.modules.agent.controller;
+
+import io.swagger.v3.oas.annotations.Operation;
+import io.swagger.v3.oas.annotations.tags.Tag;
+import lombok.RequiredArgsConstructor;
+import org.springframework.web.bind.annotation.*;
+import xiaozhi.common.utils.Result;
+import xiaozhi.modules.agent.service.AgentMcpAccessPointService;
+
+@Tag(name = "智能体Mcp接入点管理")
+@RequiredArgsConstructor
+@RestController
+@RequestMapping("/agent/mcp")
+public class AgentMcpAccessPointController {
+    private final AgentMcpAccessPointService agentMcpAccessPointService;
+
+    /**
+     * 获取智能体的Mcp接入点地址
+     * @param audioId 智能体id
+     * @return 返回错误提醒或者Mcp接入点地址
+     */
+    @Operation(summary = "获取智能体的Mcp接入点地址")
+    @GetMapping("/address/{audioId}")
+    public Result<String> getAgentMcpAccessAddress(@PathVariable("audioId") String audioId) {
+        String agentMcpAccessAddress = agentMcpAccessPointService.getAgentMcpAccessAddress(audioId);
+        if (agentMcpAccessAddress == null) {
+           return new Result<String>().error("请进入参数管理配置mcp接入点地址");
+        }
+        return new Result<String>().ok(agentMcpAccessAddress);
+    }
+}
@@ -0,0 +1,62 @@
+package xiaozhi.modules.agent.service.impl;
+
+import lombok.AllArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+import org.apache.commons.lang3.StringUtils;
+import org.springframework.stereotype.Service;
+import xiaozhi.common.constant.Constant;
+import xiaozhi.common.utils.AESUtils;
+import xiaozhi.common.utils.HashEncryptionUtil;
+import xiaozhi.modules.agent.service.AgentMcpAccessPointService;
+import xiaozhi.modules.sys.service.SysParamsService;
+
+import java.net.URI;
+import java.net.URISyntaxException;
+import java.util.List;
+
+@AllArgsConstructor
+@Service
+@Slf4j
+public class AgentMcpAccessPointServiceImpl implements AgentMcpAccessPointService {
+    private SysParamsService sysParamsService;
+
+    @Override
+    public String getAgentMcpAccessAddress(String id) {
+        // 获取到mcp的地址
+        String url = sysParamsService.getValue(Constant.SERVER_MCP_ENDPOINT, true);
+        if (StringUtils.isBlank(url)) {
+            return null;
+        }
+        try {
+            // 使用md5对智能体id进行加密
+            String md5 = HashEncryptionUtil.Md5hexDigest(id);
+            // aes需要加密文本
+            String json = "{\"agentId\": %s}".formatted(md5);
+            URI uri = new URI(url);
+            String query = uri.getQuery();
+            // 获取aes加密密钥
+            String str = "key=";
+            String key = query.substring(query.indexOf(str) + str.length());
+            // 加密后成token值
+            String encryptToken = AESUtils.encrypt(key, json);
+            // 获取路径组成部分
+            // 获取协议
+            String wsScheme = (uri.getScheme().equals("https")) ? "wss" : "ws" ;
+            // 获取主机，端口，路径
+            String path = uri.getSchemeSpecificPart();
+            // 获取参数
+            path = path.substring(0,path.lastIndexOf("/"));
+            // 返回智能体Mcp路径的格式
+            String AgentMcpUrl = "%s:%s/mcp?token=%s";
+            return AgentMcpUrl.formatted(wsScheme,path,encryptToken);
+        } catch (URISyntaxException e) {
+            log.error("路径格式不正确路径：{}，\n错误信息:{}",url,e.getMessage());
+            throw new RuntimeException("mcp的地址存在错误，请进入参数管理修改mcp接入点地址");
+        }
+    }
+
+    @Override
+    public List<String> getAgentMcpToolsList(String id) {
+        return List.of();
+    }
+}