农村建设投诉网站首页南京制作网页培训学校

农村建设投诉网站首页,南京制作网页培训学校,网络域名怎么查,免费网站qq抓取在开发官方 PHP MCP SDK 的客户端通信功能时#xff0c;开发团队遇到了一个看似无法优雅解决的架构挑战。传统的异步方案、回调模式和状态机都无法在不牺牲代码简洁性的前提下实现需求。最终#xff0c;PHP 纤程#xff08;Fibers#xff09;成为了这个问题的完美解决方案。…在开发官方 PHP MCP SDK 的客户端通信功能时开发团队遇到了一个看似无法优雅解决的架构挑战。传统的异步方案、回调模式和状态机都无法在不牺牲代码简洁性的前提下实现需求。最终PHP 纤程Fibers成为了这个问题的完美解决方案。该功能在 PR #109 中引入其实现展示了 PHP 纤程最优雅的使用案例之一。但这不仅仅是关于一个问题的故事更是关于一个自 PHP 8.1 以来一直隐藏在众目睽睽之下、却被大量误解和未充分利用的强大 PHP 特性。本文将深入探讨PHP 纤程到底是什么以及它们不是什么何时以及为何应该使用它们如何理解协作式多任务使用纤程的真实世界实现可以在自己代码中使用的模式文章较长建议准备好咖啡慢慢看。关于纤程的误解首先要解决房间里的大象PHP 纤程不是异步 PHP。它们不是并行机制不是线程也不是让 PHP 同时运行多个任务。当 PHP 8.1 在 2021 年 11 月引入纤程支持时许多开发者都感到困惑。太好了又一个异步东西大家这样想。这种困惑是可以理解的因为纤程最显眼的使用场景一直是在 ReactPHP 和 AmPHP 等异步库中。ReactPHP 甚至有一个名为 async 的包使用纤程让异步代码看起来像同步代码// 纤程之前回调地狱$promise-then(function($result) {return anotherAsyncCall($result);})-then(function($finalResult) {echo $finalResult;});// 使用纤程看起来是同步的$result await($promise);$finalResult await(anotherAsyncCall($result));echo $finalResult;看到这个很容易认为纤程 异步魔法。但这忽略了更大的图景。纤程的本质是协作式多任务。它们赋予代码暂停执行、执行其他操作、然后在完全保留所有变量、调用栈和执行上下文的情况下精确地回到离开的位置继续执行的能力。是的这对异步库非常有用。但在需要受控中断和恢复的纯同步代码中它同样有用。而这正是大多数 PHP 开发者错过的机会。纤程采用缓慢的原因不是因为它们不够有用而是因为大多数开发者不知道何时使用它们。而这正是本文要解决的问题。理解纤程基础知识在深入复杂示例之前让我们先建立坚实的基础。纤程到底是什么它如何工作什么是协作式多任务理解纤程的一个好类比是将标准 PHP 脚本想象成单轨道上的火车。它从 A 站开到 B 站通常在到达 B 之前不能停止。纤程允许火车在轨道中间停下来让乘客下车或让乘客上洗手间休息在此期间甚至让另一列火车使用这条轨道然后在所有行李变量和内存状态完好无损的情况下精确地从停下的地方恢复。另一个类比是想象你在做饭的同时读书。你读几页书然后定时器响了你标记页面搅拌锅里的东西再回到刚才读到的地方继续阅读。这就是协作式多任务。关键词是协作。你读者/厨师决定何时切换任务。没有人强行打断你而是在合适的时候自愿交出控制权。在编程术语中抢占式多任务操作系统强制中断你的代码线程、进程协作式多任务你的代码决定何时交出控制权协程、纤程纤程是 PHP 对协作式多任务的实现。它们让你能够开始执行一段代码在任何点暂停它挂起做其他事情精确地从离开的地方恢复根据需要重复任意多次纤程的结构让我们看一个简单的例子?php$fiber new Fiber(function(): string {echo 1. 纤程启动\n;$value Fiber::suspend(pause-1);echo 3. 纤程恢复收到: $value\n;$value2 Fiber::suspend(pause-2);echo 5. 纤程再次恢复收到: $value2\n;return final-result;});echo 0. 启动纤程之前\n;$suspended1 $fiber-start();echo 2. 纤程挂起返回: $suspended1\n;$suspended2 $fiber-resume(data-1);echo 4. 纤程再次挂起返回: $suspended2\n;$result $fiber-resume(data-2);echo 6. 纤程返回: $result\n;输出0. 启动纤程之前1. 纤程启动2. 纤程挂起返回: pause-13. 纤程恢复收到: data-14. 纤程再次挂起返回: pause-25. 纤程再次恢复收到: data-26. 纤程返回: final-result这里特意包含了数字以便读者看清执行如何在纤程内外跳转。suspend 让它跳出纤程resume 让它跳回纤程为了更清晰让我们分解一下发生了什么创建new Fiber(function() {...}) 创建纤程但尚未执行启动$fiber-start() 开始执行直到第一个 Fiber::suspend()挂起Fiber::suspend(pause-1) 暂停执行并将控制权返回给调用者恢复$fiber-resume(data-1) 从挂起处继续执行返回当纤程完成时resume() 返回最终值魔法在于执行上下文切换。当纤程挂起时所有局部变量都被保留调用栈被保存执行跳回到调用 start() 或 resume() 的地方传递给 suspend() 的值返回给调用者当你恢复时执行跳回纤程内部传递给 resume() 的值成为 suspend() 的返回值一切继续就像什么都没发生过一个让纤程变得强大的关键洞察在纤程内部运行的代码不需要知道它在纤程中。看看这个function processData(int $id): string {$data fetchData($id); // 这可能会挂起$result transform($data); // 这也可能会挂起return $result;}// 在纤程内调用$fiber new Fiber(fn() processData(42));$fiber-start();从 processData 的角度来看它只是在调用函数并返回结果。它不知道 fetchData() 和 transform() 可能在幕后挂起纤程。复杂性是隐藏的。这正是纤程非常适合构建隐藏复杂行为的干净 API 的原因。异步库中的纤程现在我们理解了基础知识让我们看看为什么有些人会将纤程与异步代码联系起来。这也会在我们处理主要问题之前展示一个具体的使用案例。异步问题PHP 中的传统异步编程看起来像这样// 使用 promises纤程之前function fetchUserData(int $userId): PromiseInterface {return $this-httpClient-getAsync(/users/$userId)-then(function($response) {return json_decode($response-getBody());})-then(function($userData) use ($userId) {return $this-cache-setAsync(user:$userId, $userData);})-then(function() use ($userId) {return User $userId cached;});}这能工作但很难阅读和理解。使用 catch() 的错误处理会变得混乱。调试很痛苦。而且感觉不像 PHP。纤程解决方案有了纤程像 ReactPHP 这样的库可以提供这样的方式// 使用纤程PHP 8.1 之后function fetchUserData(int $userId): string {$response await($this-httpClient-getAsync(/users/$userId));$userData json_decode($response-getBody());await($this-cache-setAsync(user:$userId, $userData));return User $userId cached;}好多了但 await() 是如何工作的呢让我们看一个简化版本namespace React\Async;function await(PromiseInterface $promise): mixed {// 挂起纤程并注册 promise 回调$result Fiber::suspend([type await,promise $promise]);// 恢复时我们将得到结果或异常if ($result instanceof \Throwable) {throw $result;}return $result;}如果你感兴趣像 PHPStan 这样的工具可以让你添加一些泛型魔法这样 await() 就能准确知道从你的 Promise 返回什么。这种强大的静态分析感觉就像魔法。多酷啊以下是发生的过程用户代码调用 await($promise)在纤程内部await() 调用 Fiber::suspend() 传递 promise事件循环看到挂起的纤程和 promise事件循环在纤程挂起时照常继续处理其他事情当 promise 解决时循环调用 $fiber-resume($value)执行在 await() 中继续返回值用户代码得到值就像它是同步的纤程在等待异步操作时挂起但用户的代码看起来完全是同步的。更进一步真正透明的异步但我们可以走得更远像 AmPHP 这样的库通过创建围绕异步操作的纤程感知包装器将其提升到新的水平。你不需要单独的 getAsync() 和 await() 调用只需要看起来完全同步的方法// AmPHP 方法不需要 await()function fetchUserData(int $userId): string {$response $this-httpClient-get(/users/$userId); // 看起来同步实际异步$userData json_decode($response-getBody());$this-cache-set(user:$userId, $userData); // 看起来同步实际异步return User $userId cached;}等等什么没有 await() 调用这是如何工作的魔法在于 get() 和 set() 内部使用纤程。这是一个简化的例子class HttpClient {public function get(string $url): Response {// 创建异步操作$promise $this-performAsyncRequest(GET, $url);// 挂起当前纤程并将 promise 传递给事件循环$response \Fiber::suspend([type await,promise $promise]);if ($response instanceof \Throwable) {throw $response;}return $response;}}从用户的角度来看他们只是调用了 get() 并得到了响应。他们完全不知道这是异步的。这就是纤程的精髓让异步操作完全透明。用户编写看起来像阻塞的同步 PHP 代码。库使用纤程在幕后处理所有异步复杂性。比较这些方法让我们看看演变过程// 1. 传统异步与 promises无纤程$promise $this-httpClient-getAsync(/users/$userId)-then(fn($response) json_decode($response-getBody()))-then(fn($userData) $this-cache-setAsync(user:$userId, $userData))-then(fn() User $userId cached);// 2. 使用 await() 辅助函数的异步使用纤程$response await($this-httpClient-getAsync(/users/$userId));$userData json_decode($response-getBody());await($this-cache-setAsync(user:$userId, $userData));return User $userId cached;// 3. 完全透明的异步纤程隐藏在库中$response $this-httpClient-get(/users/$userId);$userData json_decode($response-getBody());$this-cache-set(user:$userId, $userData);return User $userId cached;注意方法 #3 看起来与同步代码完全一样这就是正确使用纤程的力量。库开发者处理一次复杂性。每个用户都受益于一个干净的、看起来同步的 API实际上在底层是异步的。为什么这导致了误解因为纤程最显眼的用途是让异步代码看起来同步开发者假设纤程本身就是异步机制。但纤程本身不做任何异步操作。它们只是提供挂起/恢复机制使得看起来同步的异步代码成为可能。事件循环仍在做实际的异步工作。纤程只是让 API 更好用。这个区别至关重要纤程是管理执行流的工具而不是实现并行或异步的工具。真正的问题MCP SDK 中的客户端通信现在让我们进入本文的核心问题。在开发 Model Context Protocol (MCP) 的 PHP 实现时开发团队遇到了一个似乎无法优雅解决的设计挑战。什么是 MCPModel Context Protocol 是连接 AI 助手如 Claude与外部工具和数据源的标准。一个 MCP 服务器暴露工具AI 可以调用的函数例如搜索数据库、发送邮件资源AI 可以读取的数据例如项目文件、API 文档提示AI 可以使用的模板该协议是双向的 JSON-RPC支持不同的传输方式STDIO、HTTP SSE、自定义。挑战MCP 规范包含服务器在请求处理期间与客户端通信的功能日志记录向客户端发送日志消息进度更新更新客户端关于长时间运行操作的进度采样请求客户端使用其 LLM 生成文本这些不仅仅是响应类型。不问题是它们需要在工具执行期间发生。例如客户端: 嘿服务器运行 analyze_dataset 工具服务器: 开始... [发送日志]服务器: 25% 完成 [发送进度]服务器: 50% 完成 [发送进度]服务器: 生成摘要需要你的 LLM [发送采样请求]客户端: 这是生成的摘要 [响应采样]服务器: 完成这是完整结果 [发送最终响应]服务器需要在执行过程中发送消息等待来自客户端的响应在收到响应后继续执行让所有这些感觉起来很自然API 需求在 MCP SDK 方面优先事项之一是使其极其易用。开发团队希望开发者这样编写工具$server-addTool(function (string $dataset, ClientGateway $client): array {$client-log(LoggingLevel::Info, 开始分析);foreach ($steps as $step) {$client-progress($progress, 1, $step);doWork($step);}$summary $client-sample(总结这些数据...);return [status complete, summary $summary];},name: analyze_dataset);看看这段代码。它很漂亮。它很简单。它看起来完全是同步的。没有回调没有 promises没有 async/await 语法没有 yield 生成器。只是普通的 PHP。但在底层这需要向客户端发送 JSON-RPC 通知日志、进度发送 JSON-RPC 请求并等待响应采样与任何传输方式工作无论是否阻塞无论你使用原生 PHP、ReactPHP、Swoole 还是 RoadRunner 都能工作如何实现为什么传统方法行不通开发团队花了几个小时考虑不同的解决方案选项 1让一切都异步