开源模型应用落地-模型上下文协议(MCP)-从数据孤岛到万物互联(一)

news2025/4/12 15:03:01

一、前言

    当开发者还在为每个AI工具编写臃肿的API适配器时,一场关于「连接」的技术革命已悄然降临。模型上下文协议MCP)正在用一套全新的交互语法,重新定义人工智能与物理世界的对话方式。MCP协议如同为AI系统装上了“万能接口”,通过标准化的客户端-服务器架构,将大语言模型(LLM)与数据库、API乃至物理设备无缝连接。它不仅是数据孤岛的破壁者——让实时更新的企业文档、代码仓库直接成为模型的“记忆延伸”;更是行动力的赋能器——从自动生成销售报告到远程操控IoT设备,AI得以突破虚拟边界,真正成为生产力工具。这种“知行合一”的特性,正在重新定义人机协作的深度与广度。


二、术语介绍

2.1.MCP

     MCP协议(Model Context Protocol,模型上下文协议)是由Anthropic公司于2024年11月推出的开放标准协议,旨在为大型语言模型(LLM)与外部数据源、工具之间建立统一的通信接口。其核心作用在于解决AI模型因数据孤岛限制难以发挥潜力的问题,通过标准化交互方式提升AI应用的扩展性和实用性。

一、MCP协议的核心定义
    1.1. 协议定位
    MCP被类比为AI领域的“USB-C接口”,通过解耦LLM与外部系统的集成,实现一次开发即可动态连接多种服务(如数据库、API、本地文件系统等)。例如,开发者无需为每个新工具单独定制接口,只需遵循MCP标准即可实现AI与工具的即插即用。

    1.2. ​技术架构
    采用客户端-服务器模型,包含三个核心组件:

  • ​MCP主机:运行AI模型的环境(如Claude桌面应用);
  • ​MCP客户端:负责与服务器通信并转发请求;
  • ​MCP服务器:提供具体功能服务的轻量级程序(如文件管理或API调用)。

二、MCP协议的核心作用
​    2.1. 统一交互标准
    标准化JSON-RPC 2.0协议支持本地(标准输入输出)与远程(HTTP/SSE)通信,兼容Python、Java等多种编程语言,降低开发复杂度。例如,本地通信保障医疗数据安全传输,远程通信支持云端服务扩展。

​    2.2. 动态扩展能力
    通过资源(Resource)、工具(Tool)、提示(Prompt)三大核心概念,AI模型可自动发现新工具并实时交互。例如连接GitHub时,AI可自动提交代码或修复BUG,无需人工预定义接口。

    ​2.3. 安全与权限控制
    内置权限验证机制,用户需手动批准敏感操作(如文件删除或邮件发送),确保数据隐私。在企业场景中,该特性尤为重要,如金融分析时需严格管控市场数据访问权限。

2.2.STDIO vs SSE

    STDIOSSE是两种核心的传输机制,分别适用于不同的通信场景

  (一)STDIO(标准输入输出)​
    定义与实现:
    STDIO模式通过标准输入(stdin)和标准输出(stdout)​实现本地进程间通信。客户端将MCP服务端作为子进程启动,双方通过JSON-RPC消息进行交互:

  • 客户端通过stdin发送请求,服务端通过stdout返回响应。
  • 消息以换行符分隔,且需严格遵守JSON-RPC 2.0格式。

    作用与特点:

  • ​高效低延迟:适用于本地开发或单一机器环境,避免了网络传输开销。
  • ​简单易用:无需网络配置,适合快速集成命令行工具或调试。
  • ​局限性:仅支持本地通信,无法扩展至分布式场景。

    应用场景:

  • 本地AI助手与工具集成(如天气查询服务)。
  • 开发阶段的快速原型验证。

  (二)SSE(Server-Sent Events,服务端推送事件)​
    定义与实现
    SSE模式基于HTTP协议,服务端通过单向流式通信主动推送数据至客户端:

  • 服务端需提供两个端点:​SSE端点(用于客户端连接)​和HTTP POST端点(用于客户端发送消息)​。
  • 消息以SSE事件流形式传输,客户端通过长连接接收实时更新。

    作用与特点

  • ​实时性:支持服务端主动推送(如股票行情、实时日志),适用于需持续更新的场景。
  • ​分布式支持:可跨物理机器部署,允许多客户端并发连接。
  • ​协议限制:仅服务端到客户端单向通信,双向交互需结合HTTP POST请求。

    应用场景:

  • 远程AI代理系统(如跨区域部署的智能客服)。
  • 需要实时数据流的应用(如IoT设备监控)。

    对比与选择建议

2.3.UV

 是由Rust编写的高性能包管理工具,主要用于项目的依赖管理和打包。

    UV 作为 Python 生态中的新一代包管理工具,相比传统的 pip 具有显著优势,主要体现在以下几个方面:

一、极速性能(10-100 倍提升)
    UV 的核心竞争力在于其 ​Rust 语言实现的高性能引擎。以下为关键性能对比:

  • ​依赖安装:安装大型项目(如 Trio)时,UV 耗时约 0.06 秒,而 pip 需要 1.56 秒,速度提升 ​26 倍。
  • ​虚拟环境创建:UV 创建虚拟环境仅需 ​4.1 毫秒,而 pip 的 venv 需 1.5 秒,速度提升 ​365 倍。
  • ​依赖解析:通过 ​PubGrub 算法优化和并行处理,UV 能快速解决复杂依赖冲突,尤其在处理大规模依赖树时优势明显。

二、功能集成(一站式解决方案)

    UV ​整合了多个工具链,解决了 pip 需配合其他工具(如 virtualenv、pip-tools、pipx 等)的碎片化问题

三、兼容性与易用性

  • ​无缝迁移:支持现有 requirements.txt 和 pyproject.toml,无需修改项目配置即可直接替换 pip。
  • ​跨平台支持:兼容 Windows、macOS、Linux,并通过 ​全局缓存机制 减少重复下载,节省磁盘空间。
  • ​开发者友好:错误信息更清晰,包含依赖冲突的详细跟踪。支持 pip 的高级功能(如可编辑安装、Git 依赖、本地包安装)

三、前置条件

3.1.基础环境及前置条件

  1. 操作系统:无限

3.2.安装UV

  以windows系统为例

(一)直接使用pip安装

pip install uv

(二)使用脚本安装

irm https://astral.sh/uv/install.ps1 | iex

3.3.初始化及安装依赖

# 初始化项目
uv init mcp_test

# 切换目录
cd mcp_test

# 创建虚拟环境
uv venv -p 3.10

# 激活虚拟环境
.venv\Scripts\activate

# 安装依赖
uv add "mcp[cli]"

四、技术实现

4.1.MCP Server实现

# -*-  coding:utf-8 -*-
from mcp.server.fastmcp import FastMCP

DEAULT_TRANSPORT = "stdio"

# Create an MCP server
mcp = FastMCP("Demo")

# Add an addition tool
@mcp.tool()
def add(a: int, b: int) -> int:
    """Add two numbers"""
    print(f'a: {a},b: {b}')
    return a + b

# Add a dynamic greeting resource
@mcp.resource(uri="greeting://",name="greeting")
def get_greeting() -> str:
    """Get a personalized greeting"""
    return f"Hello, world!"

@mcp.resource(uri="greeting://{name}",name="greeting")
def get_greeting(name: str) -> str:
    """Get a personalized greeting"""
    return f"Hello, {name}!"

@mcp.prompt()
def review_code(code: str) -> str:
    return f"Please review this code:\n\n{code}"

if __name__ == "__main__":
    # Initialize and run the server
    print(f"start mcp server,transport: {DEAULT_TRANSPORT}...")  # 记录服务启动日志
    # mcp.run(transport='sse')
    mcp.run(transport=DEAULT_TRANSPORT)

调用:

 直接在pycharm中运行

4.2.STDIO MCP Client实现

# -*-  coding:utf-8 -*-
import sys
import traceback

from mcp import ClientSession, StdioServerParameters, types
from mcp.client.stdio import stdio_client


# Create server parameters for stdio connection
server_params = StdioServerParameters(
    command="python",  
    args=["mcp_server.py"]
)

async def run():
    async with stdio_client(server_params,errlog=sys.stderr) as (read, write):
        async with ClientSession(
            read, write
        ) as session:

                # Initialize the connection
                await session.initialize()

                # List available prompts
                prompts = await session.list_prompts()
                print(f'prompts: {prompts}')

                # Get a prompt
                prompt = await session.get_prompt(
                    "review_code", arguments={"code": "11111"}
                )
                print(f'prompt: {prompt}')

                # List available resources
                resources = await session.list_resources()
                print(f'resources: {resources}')

                resource = await session.read_resource('greeting://test')
                print(f'resource: {resource}')

                # List available tools
                tools = await session.list_tools()
                print(f'tools: {tools}')

                # Call a tool
                result = await session.call_tool("add", arguments={"a": 3, "b": 2})
                print(f'result: {result}')


if __name__ == "__main__":
    import asyncio

    asyncio.run(run())

调用:

 直接在pycharm中运行

4.3.SSE MCP Client实现

# -*-  coding:utf-8 -*-
from mcp import ClientSession
from mcp.client.sse import sse_client


async def run():
    async with sse_client(url='http://localhost:8000/sse') as (read, write):
        async with ClientSession(
            read, write
        ) as session:
            # Initialize the connection
            await session.initialize()

            # List available prompts
            prompts = await session.list_prompts()
            print(f'prompts: {prompts}')

            # Get a prompt
            prompt = await session.get_prompt(
                "review_code", arguments={"code": "11111"}
            )
            print(f'prompt: {prompt}')

            # List available resources
            resources = await session.list_resources()
            print(f'resources: {resources}')

            resource = await session.read_resource('greeting://test')
            print(f'resource: {resource}')

            # List available tools
            tools = await session.list_tools()
            print(f'tools: {tools}')

            # Call a tool
            result = await session.call_tool("add", arguments={"a": 3,"b": 2})
            print(f'result: {result}')

if __name__ == "__main__":
    import asyncio

    asyncio.run(run())

调用:

 直接在pycharm中运行,需要先修改MCP Server中的transport,调整为sse方式。

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

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

相关文章

【区块链安全 | 第三十八篇】合约审计之获取私有数据(二)

文章目录 前言漏洞代码代码审计攻击步骤修复建议审计思路 前言 在【区块链安全 | 第三十七篇】合约审计之获取私有数据(一)中,介绍了私有数据、访问私有数据实例、Solidity 中的数据存储方式等知识,本文通过分析具体合约代码进行…

mac 苍穹外卖 后端初始 SkyApplication 报错

报错内容 java: java.lang.NoSuchFieldError: Class com.sun.tools.javac.tree.JCTree$JCImport does not have member field com.sun.tools.javac.tree.JCTree qualid deepseek 解决 打开 File > Project Structure > Project SDK, 选择 JDK17。我没有 JDK17就下载了一…

Proximal Policy Optimization (PPO)

2.1 策略梯度方法 策略梯度方法计算策略梯度的估计值并将其插入到随机梯度上升算法中。最常用的梯度估计器的形式如下: g ^ E t [ ∇ θ log ⁡ π θ ( a t ∣ s t ) A ^ t ] (1) \hat{g} \mathbb{E}_t \left[ \nabla_{\theta} \log \pi_{\theta}(a_t | s_t) \h…

微信小程序:动态表格实现,表头单元格数据完全从data中获取,宽度自定义,自定义文本框,行勾选,样式效果,横向滚动表格(解决背景色不足的问题)等

一、样式效果 二、代码 1、wxml <view class"line flex flex-center"><view class"none" wx:if"{{info.length 0}}">暂无料号</view><view wx:else class"table-container"><!-- 动态生成表头 -->&…

python-Leetcode 65.搜索旋转排序数组

题目&#xff1a; 整数数组nums按升序排列&#xff0c;数组中的值互不相同 在传递给函数之前&#xff0c;nums在预先未知的某个小标K上进行了旋转&#xff0c;使数组变为[nums[k], nums[k1], ..., nums[n-1], nums[0], nums[1], ..., nums[k-1]]&#xff0c;小标从0开始计数。…

Django学习记录-1

Django学习记录-1 虽然网上教程都很多&#xff0c;但是感觉自己记录一下才属于自己&#xff0c;之后想找也方面一点&#xff0c;文采不佳看的不爽可绕道。 参考贴 从零开始的Django框架入门到实战教程(内含实战实例) - 01 创建项目与app、加入静态文件、模板语法介绍&#xff…

K8s私有仓库拉取镜像报错解决:x509 certificate signed by unknown authority

前言 在Kubernetes环境中使用自签名证书的私有Harbor镜像仓库时&#xff0c;常会遇到证书验证失败的问题。本文将详细讲解如何解决这个常见的证书问题。 环境信息&#xff1a; Kubernetes版本&#xff1a;1.28.2容器运行时&#xff1a;containerd 1.6.20私有仓库&#xff1a…

LabVIEW 长期项目开发

LabVIEW 凭借其图形化编程的独特优势&#xff0c;在工业自动化、测试测量等领域得到了广泛应用。对于长期运行、持续迭代的 LabVIEW 项目而言&#xff0c;其开发过程涵盖架构设计、代码管理、性能优化等多个关键环节&#xff0c;每个环节都对项目的成功起着至关重要的作用。下面…

蓝桥杯真题——好数、R格式

目录 蓝桥杯2024年第十五届省赛真题-好数 【模拟题】 题目描述 输入格式 输出格式 样例输入 样例输出 提示 代码1&#xff1a;有两个案例过不了&#xff0c;超时 蓝桥杯2024年第十五届省赛真题-R 格式 【vector容器的使用】 题目描述 输入格式 输出格式 样例输入…

Windows版-RabbitMQ自动化部署

一键完成Erlang环境变量配置&#xff08;ERLANG_HOME系统变量&#xff09;‌ 一键完成RabbitMQ环境变量配置&#xff08;RabbitMQ系统变量&#xff09;‌ 实现快速安装部署RabbitMQ PS&#xff1a; 需提前下载安装&#xff1a; - otp_win64_25.0.exe (Erlang) - rabbit…

openEuler24.03 LTS下安装Flink

目录 Flink的安装模式下载Flink安装Local模式前提条件解压安装包启动集群查看进程提交作业文件WordCount持续流WordCount 查看Web UI配置flink-conf.yaml简单使用 关闭集群 Standalone Session模式前提条件Flink集群规划解压安装包配置flink配置flink-conf.yaml配置workers配置…

从零开始学java--泛型(1)

泛型 学生成绩可能是数字类型&#xff0c;也可能是字符串类型&#xff0c;如何存放可能出现的两种类型呢&#xff1a; public class Score {String name;String id;Object value; //因为Object是所有类型的父类&#xff0c;因此既可以存放Integer也能存放Stringpublic Score…

【正点原子】STM32MP135去除SD卡引脚复用,出现 /dev/mmcblk1p5 not found!

如果在设备树中直接注释掉 sdmmc1 节点&#xff0c;就会导致系统启动时识别不到真正的 eMMC 设备&#xff0c;进而挂载失败&#xff0c;爆出 /dev/mmcblk1p5 not found 的问题。 正点原子STM32MP135开发板Linux核心板嵌入式ARM双千兆以太网CAN 正确操作是“放空”而不是“删光…

CrystalDiskInfo电脑硬盘监控工具 v9.6.0中文绿色便携版

前言 CrystalDiskInfo是一个不用花钱的硬盘小帮手软件&#xff0c;它可以帮你看看你的电脑硬盘工作得怎么样&#xff0c;健不健康。这个软件能显示硬盘的温度高不高、还有多少地方没用、传输东西快不快等等好多信息。用了它&#xff0c;你就能很容易地知道硬盘现在是什么情况&…

详解模型蒸馏,破解DeepSeek性能谜题

大家好&#xff0c;不少关注 DeepSeek 最新动态的朋友&#xff0c;想必都遇到过 “Distillation”&#xff08;蒸馏&#xff09;这一术语。本文将介绍模型蒸馏技术的原理&#xff0c;同时借助 TensorFlow 框架中的实例进行详细演示。通过本文&#xff0c;对模型蒸馏有更深的认识…

园区网拓扑作业

作业要求&#xff1a; 需求&#xff1a; 需求分析&#xff1a; 1.按照图示的VLAN及IP地址需求&#xff0c;完成相关配需&#xff1a;VLAN 2、3、20、30 已分配子网&#xff0c;需在交换机上创建 VLAN 并配置三层接口作为网关。确保各 VLAN 内设备能互通&#xff0c;跨 VLAN 通…

隔行换色总结

功能效果展示&#xff1a; 第一种思路&#xff1a; 使用数组&#xff0c;将数组的内容渲染到页面上&#xff0c;序号也就是将数组的下标输出到第一个td上&#xff0c;将数组的内容输出到第二个td上&#xff0c;&#xff08;使用拼接字符串&#xff09; 具体操作&#xff1a; …

使用Docker Desktop进行本地打包和推送

使用Docker Desktop进行本地打包和推送 一、Docker Desktop配置二、IDEA配置1.下载Docker插件2.在“Settings”中&#xff0c;配置“Docker”3.选择“Docker Registry”&#xff0c;配置远程仓库。 三、POM配置 一共有三个地方需要配置 一、Docker Desktop配置 在Docker Deskt…

Redis主从复制:告别单身Redis!

目录 一、 为什么需要主从复制&#xff1f;&#x1f914;二、 如何搭建主从架构&#xff1f;前提条件✅步骤&#x1f4c1; 创建工作目录&#x1f4dc; 创建 Docker Compose 配置文件&#x1f680; 启动所有 Redis&#x1f50d; 验证主从状态 &#x1f4a1; 重要提示和后续改进 …

ORM、Mybatis和Hibernate、Mybatis使用教程、parameterType、resultType、级联查询案例、resultMap映射

DAY21.1 Java核心基础 ORM Object Relationship Mapping 对象关系映射 面向对象的程序到—关系型数据库的映射 比如java – MySQL的映射 ORM框架就是实现这个映射的框架 Hibernate、Mybatis、MybatisPlus、Spring Data JPA、Spring JDBC Spring Data JPA的底层就是Hiber…