GitHub_Trending/ty/typescript-sdk状态恢复：任务中断与续传机制实现

杨洲泳Egerton

450人浏览 · 2025-09-28 01:27:09

杨洲泳Egerton · 2025-09-28 01:27:09 发布

GitHub_Trending/ty/typescript-sdk状态恢复：任务中断与续传机制实现

【免费下载链接】typescript-sdk The official Typescript SDK for Model Context Protocol servers and clients 项目地址: https://gitcode.com/GitHub_Trending/ty/typescript-sdk

在分布式系统中，网络不稳定或服务重启常导致任务中断。本文详解GitHub_Trending/ty/typescript-sdk如何通过会话管理和事件存储实现任务状态恢复，确保长时运行工具在异常中断后无缝续传。

核心实现原理

会话标识与会话管理

SDK采用会话ID（Session ID）唯一标识客户端连接，通过StreamableHTTPClientTransport生成并存储会话信息。关键实现位于：

// 会话ID生成示例（src/client/streamableHttp.ts）
this.sessionId = options.sessionId || randomUUID();

事件存储与恢复令牌

系统通过InMemoryEventStore记录任务执行事件，使用lastEventId跟踪进度。中断后客户端可凭此令牌恢复：

// 事件存储接口定义
interface EventStore {
  append(event: TaskEvent): Promise<void>;
  getEvents(since?: string): Promise<TaskEvent[]>;
}

任务续传流程实现

中断检测与状态保存

当连接异常关闭时，SDK自动保存当前任务状态至事件存储：

// 连接关闭时的状态保存逻辑
async close() {
  if (this.#pendingRequests.size > 0) {
    await this.#savePendingRequests();
  }
  this.#connection.close();
}

恢复连接与任务续传

客户端重连时携带lastEventId请求未完成事件，服务端据此恢复任务执行：

// 任务续传请求示例
client.request({
  method: 'tools/call',
  params: { name: 'run-notifications', arguments: { count: 3 } }
}, schema, {
  resumptionToken: lastEventId,  // 携带恢复令牌
  onresumptiontoken: (id) => lastEventId = id
});