手搓MCP客户端动态调用多MCP服务,调用哪个你说了算!

01 引言

前两天,有个粉丝朋友咨询MCP服务如何动态调用,动态加载MCP服务的链接?我们都知道MCP客户端可以配置多个MCP服务的地址:

spring.ai.mcp.client.sse.connections.server1.url=http://localhost:xxxx
spring.ai.mcp.client.sse.connections.server2.url=http://localhost:xxxx
spring.ai.mcp.client.sse.connections.server3.url=http://localhost:xxxx

这样的MCP服务会自动加载到项目中,类似合成一个服务。一个请求进来,MCP客户端会在所有的服务中寻找合适的方法。

但是,业务中总会有各种不同的场景。例如,粉丝朋友的需求。SpringBoot一直坚持约定大于配置的方式,Spring AI也不例外,既然提供配置文件的配置,那么JavaBean的配置一样可行。指定调用只要需要找到调用的时机,自然可以控制。

本篇就带大家一起解决这份粉丝朋友的问题。

02 MCP动态调用

2.1 代码追踪

在研究动态调用之前,我们需要知道配置用在了哪里?

我们直接在.properties.yml配置文件中,

按住Ctrl,然后用鼠标点击url,就会跳转到下面的文件:

从方法中可以看到:

最终的配置会保存在SseParameters中,最后放到Map集合中。使用或者获取服务链接的时候,肯定也会通过getConnections()来获取,这个也是突破问题的关键。

2.2 探寻使用位置

上面找到了配置文件对用的Java类:

org.springframework.ai.mcp.client.autoconfigure.properties.McpSseClientProperties

我们可以采用上面相同的方法,看看哪里调用了getConnections(),由于我们的源码没有全部下载下来,所以很大程度上可能找不到。所以,断点提示就变成了我们唯一的出路。

断点启动之后,我们看到连接数为0,也就是还没有加载MCP服务的链接呢。如下图:

我们断点继续向下执行(快捷键:F8),中间会经历漫长的Bean的创建过程。我们的目标就是看看是哪一个Bean实例化的时候会获取连接。

我们就需要注意几个注解:@Bean@Component等,终于实例化出来了,找到了关键类:

org.springframework.ai.mcp.client.autoconfigure.McpClientAutoConfiguration

具体如图:

我们可以看到namedTransports里面就包含了我们MCP服务,最终放到mcpSyncClients集合中,如下图:

至此,Spring 启动随后完成。

2.3 修改点

我们可以看到mcpSyncClients集合上有@Bean标签,所以会被Spring管理,所以可以直接从Spring容器中,通过注入的方式获取到。

但是修改点有在哪里呢?我们先看看MCP调用的案例:

从构建ChatClient到发送请求参数,就只有ChatModelToolCallbackProvider两个参数。而ChatMode表示采用的大模型的类型,显然和MCP服务没有关系,就只有ToolCallbackProvider这个类了。

org.springframework.ai.tool.ToolCallbackProvider的实现有四个:

通过注入的ToolCallbackProvider,我们断点可以看到它的实现是:

org.springframework.ai.mcp.SyncMcpToolCallbackProvider

从代码的构造启可以看到,参数就是我们上面注入的mcpSyncClients

2.4 动态调用

我们只要根据MCP服务的名称区分不同的McpSyncClient即可。

我们从截图可以看到:

小编提供了两个MCP服务,分别是csdn-mcp-server(CSDN文章浏览服务)和gzh-mcp-server(种种好推荐服务)。小编没有传递参数,默认会调用gzh-mcp-server

我们看看返回的结果:

请求是一个与csdn-mcp-server匹配度比较高的请求,最终只调用了gzh-mcp-server。所以我们就可以控制调用的MCP服务了。

03 动态加载

动态调用的问题,我们已经解决了。如果这些服务链接想从数据库读取,又该如何处理呢?

最直接的想法,就是直接将配置文件对应的Bean自己new出来交给Spring管理。

3.1 配置McpSseClientProperties

Bean配置

@Bean
public McpSseClientProperties mcpSseClientProperties() {McpSseClientProperties mcpSseClientProperties = new McpSseClientProperties();Map<String, SseParameters> connections = mcpSseClientProperties.getConnections();connections.put("server1", new SseParameters("http://localhost:8080", null));connections.put("server2", new SseParameters("http://localhost:8082", null));return mcpSseClientProperties;
}

启动结果

McpSseClientProperties发现了2个,实际只需要一个。也就是说,框架自动实例化McpSseClientProperties和我们的冲突了。

这种方式行不通!!!

既然已经存在,那就直接添加连接呢?因为Spring默认是单例。

3.2 动态加载链接

容器启动后加载链接

测试

已经加载成功了。

04 小结

到这里粉丝朋友的问题就全部解决了。同时,也分享给大家,希望对大家有帮助!

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。
如若转载,请注明出处:http://www.pswp.cn/bicheng/94124.shtml
繁体地址,请注明出处:http://hk.pswp.cn/bicheng/94124.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

Go语言中的优雅并发控制:通道信号量模式详解

在Go语言的并发编程中&#xff0c;“通过通信共享内存”的设计哲学贯穿始终。当面对高并发场景时&#xff0c;无限制创建goroutine可能导致资源耗尽、CPU过载等问题&#xff0c;通道信号量模式&#xff08;Channel Semaphore Pattern&#xff09; 正是一种基于Go通道特性的优雅…

鸿蒙 NEXT开发中轻松实现人脸识别功能

大家好&#xff0c;我是 V 哥。 今天给大家介绍在 HarmonyOS 原生鸿蒙开发中&#xff0c;实现人脸识别功能&#xff0c;这个功能在常用的 APP 开发中上镜率还是很高的&#xff0c;在传统的 Android 或 iOS 开发中&#xff0c;通常我们要借助第三方库来实现&#xff0c;而在鸿蒙…

华为开发者空间训练营-优秀作品公布

排名标题总分奖品1手把手教你开发一个地区智能查询MCP&#xff0c;赋能地理位置类MCP服务的“零输入”无感交互95华为 freebuds 6i 蓝牙耳机2基于华为开发者空间云主机DeepSeek助力电商企业AI海报文案驱动的最佳实践落地 94华为 freebuds 6i 蓝牙耳机32小时基于华为开发者空间和…

基于Python与Tkinter开发的微博多功能自动化助手

文章目录 摘要 1. 背景与意义 2. 需求分析 3. 核心架构设计 3.1. 技术选型 3.2. 核心思想:UI与逻辑分离的异步架构 4. 深度模块化剖析 4.1. 微博核心API交互模块 4.2. 健壮性设计:代理与重试机制 4.3. GUI界面模块 (WeiboApp 类) 4.4. 异步任务处理模块 5. 难点分析与解决方案…

效果驱动复购!健永科技RFID牛场智能称重项目落地

近日&#xff0c;北京某养殖企业持续下单电子耳标识读器&#xff0c;在牛场智能称重中落地应用&#xff0c;通过自动、准确地识别牛只并记录体重数据&#xff0c;显著提升效率和数据精准度&#xff0c;实现了“效果驱动复购”的良性循环。健永科技RFID技术在北京某养殖企业智能…

计算机网络:2、TCP和UDP

2、TCP和UDP 简介 TCP(transmission Control Protocol)&#xff1a;是一种通信标准&#xff0c;它使应用程序和计算设备能够在网络上交换消息。它的设计目的是在互联网上发送数据包&#xff0c;并确保数据和信息在网络上的成功传递。UDP(the User Datagram Protocol)&#xf…

WEB安全篇:浏览器攻击原理及防护

1、XSS&#xff1a;跨站脚本攻击就是攻击者想尽一切办法将可以执行的代码注入到网页中。攻击者在web页面恶意插入HTML或script标签&#xff0c;当用户浏览该页面时&#xff0c;恶意代码就会被执行&#xff0c;从而达到攻击的目的。XSS利用的是用户对指定网站的信任。比如&#…

汇编语言学习2---GNU Debugger (GDB)

学习记录&#xff0c;在汇编语言 &#xff0c;我们面对的是机器码&#xff08;以汇编指令形式展现&#xff09;&#xff0c;所以断点要设置在机器码被加载到内存中的位置。 GEF插件使用 安装插件wget -O ~/.gdbinit-gef.py -q https://gef.blah.cat/pyecho source ~/.gdbinit-g…

谈谈架构的内容

一、架构的定义架构是一个界定不清的东西&#xff0c;我们很难讲清楚哪些东西是架构&#xff0c;哪些东西不是架构。但软件行业里其实人人都在搞架构&#xff0c;软件设计就是架构本身。架构这个词出现得很早&#xff0c;有些人认为是 NASA&#xff08;也可能是NATO&#xff09…

C#文件(夹)读取相关(完善中。。。)

前言阅读项目编辑器的代码时&#xff0c;发现好多与文件&#xff08;夹&#xff09;路径相关代码。本来自己之前对路径相关的东西就模模糊糊&#xff0c;希望通过这篇笔记能让自己模糊的地方明朗一下。" / " 与 " \ "你是否有过这样的疑惑&#xff1a;Wind…

FPGA DP1.4 With DSC解决方案

引言&#xff1a;迎接高清高刷时代的显示挑战随着8K分辨率、高刷新率、HDR和更广色域内容的普及&#xff0c;传统视频接口的带宽正面临极限。DisplayPort 1.4标准虽提供了高达32.4 Gbps的带宽&#xff08;HBR3速率&#xff09;&#xff0c;但要无压缩地传输8K60Hz 10bpp HDR视频…

新手向:Python开发简易网络服务器

Python网络服务器开发指南&#xff1a;从零开始的完整实现网络服务器基础概念网络服务器是互联网基础设施的核心组件&#xff0c;它本质上是一个持续运行的程序&#xff0c;负责监听特定端口&#xff08;如HTTP服务的80端口或HTTPS的443端口&#xff09;&#xff0c;处理来自客…

819 机器学习-决策树2

一、决策树的算法信息增益&#xff1a;某个属性带来的熵增1、决策树三大经典算法• ID3 → 信息增益 信息增益&#xff1a;某个属性带来的熵增• C4.5 → 信息增益率 信息增益率&#xff1a;信息增益自身熵• CART → 基尼指数&#xff08;分类&#xff09;&#xff1b;平方误…

Objective-C 版本的 LiveEventBus 效果

想要 Objective-C 版本的 LiveEventBus 效果&#xff08;跨页面/跨模块通信&#xff0c;支持粘性和非粘性事件&#xff09;。在 iOS 里对应的就是 NSNotificationCenter&#xff0c;但是它 默认不支持粘性事件&#xff0c;所以如果你想要“粘性”&#xff0c;需要自己封装一层。…

WindowsAPI|每天了解几个winAPI接口之网络配置相关文档Iphlpapi.h详细分析七

上一篇&#xff1a;WindowsAPI|每天了解几个winAPI接口之网络配置相关文档Iphlpapi.h详细分析六 如果有错误欢迎指正批评&#xff0c;在此只作为科普和参考。 C:\Program Files (x86)\Windows Kits\10\Include\10.0.22621.0\um\iphlpapi.h 文章目录CreateIpNetEntry&#xff1…

STM32F407VGT6从零建立一个标准库工程模板+VSCode或Keil5

一、前言 下载平台:STM32F407ZGT6 代码使用平台:VSCode 编译器:arm-none-aebi-gcc ---- 默认你已经安装 程序下载工具:STlink ---- 默认你拥有 批处理工具:make ---- 默认你已经安装 使用此方法可以不借助其它插件&#xff0c;例如:STM32EIDE。这个方法已经经过验证可以在STM3…

佩京VR党建工作站-党建VR系统-VR党建展厅

VR党建工作站是一种依托VR虚拟现实技术的数字化党建文化学习工具。它通过将丰富的学习内容植入到智慧党建科技产品中&#xff0c;构建出沉浸式的学习场景&#xff0c;从而创新了体验式学习模式&#xff0c;促进了党员的自主学习。VR党建工作站核心功能&#xff1a;1、了解实时新…

Kotlin 协程之Channel的概念和基本使用

前言 在 专栏 之前的文章中&#xff0c;我们已经知道了协程的启动、挂起、取消、异常以及常用的协程作用域等基础应用。 这些基础应用适合的场景是一次性任务&#xff0c;执行完就结束了的场景。 launch / async 适合的场景 网络请求数据库查询文件读写并行计算任务等等 而…

安装使用Conda

文章目录Linux安装 Conda&#xff08;Miniconda 或 Anaconda&#xff09;​Miniconda (轻量版)激活配置Windows安装配置 Conda​添加清华镜像源加速创建并激活 Conda 环境验证步骤​安装项目依赖运行项目Linux安装 Conda&#xff08;Miniconda 或 Anaconda&#xff09;​ Mini…

面向智能空战的深度强化学习技术综述

CSDN大礼包《大模型课程》 CSDN大礼包《深度强化学习课程》 CSDN大礼包《人工智能平台设计开发课程》