OpenClaw05_回声机制针对中文版本openClaw进行源码阅读当前项目针对【回声机制防重】进行解读文章目录OpenClaw05_回声机制1-参考地址2-知识整理3-动手实操1-回声机制防重2-回声机制防重-理解场景防止机器人重复发送相同消息代码示例演示控制台输出核心机制图解关键设计亮点实际应用场景1-参考地址github版本OpenClawCNgitee版本OpenClawCNmac进行openclaw卸载参考openClaw源码拆解系列2-知识整理1OpenClaw源码-回声机制防重-源码2OpenClaw源码-回声机制防重-理解3-动手实操1-回声机制防重造这些词的人真的都是些神人本来写一个会话防重大家都能理解又造一个新词[回声EchoTracker]export type EchoTracker { // 记录文本并添加到去重集合用于回声检测 // text: 要记录的文本内容可为空字符串或 undefined // opts: 包含附加配置的选项对象 rememberText: ( text: string | undefined, opts: { // 可选的合并后消息体内容 combinedBody?: string; // 可选的与合并消息体关联的会话键 combinedBodySessionKey?: string; // 是否记录详细的调试日志 logVerboseMessage?: boolean; }, ) void; // 判断给定的键是否存在于最近发送的记录中 has: (key: string) boolean; // 从最近发送的记录中移除指定键 forget: (key: string) void; // 根据提供的参数构建唯一标识符 buildCombinedKey: (params: { sessionKey: string; combinedBody: string }) string; }; // 工厂函数创建并初始化一个回声追踪器实例 // params: 配置参数对象 export function createEchoTracker(params: { // 最大允许的条目数量默认为 100 maxItems?: number; // 可选的日志输出回调函数用于详细信息的记录 logVerbose?: (msg: string) void; }): EchoTracker { // 使用 Set 数据结构存储最近发送的文本键值自动去重且保持顺序插入 const recentlySent new Setstring(); // 计算实际有效的最大容量确保至少为 1 const maxItems Math.max(1, params.maxItems ?? 100); // 内部辅助函数构建唯一的组合键字符串 // p: 包含会话键和合并后的消息内容的参数对象 const buildCombinedKey (p: { sessionKey: string; combinedBody: string }) // 拼接为格式combined:会话键合并后的内容 combined:${p.sessionKey}:${p.combinedBody}; // 内部辅助函数修剪集合大小移除旧数据以符合容量限制 const trim () { // 当集合中的元素数量超过最大限制时循环移除元素 while (recentlySent.size maxItems) { // 获取迭代器中第一个元素的值即最早添加的元素 const firstKey recentlySent.values().next().value as string | undefined; // 如果没有找到键则中断循环 if (!firstKey) break; // 从集合中删除该键 recentlySent.delete(firstKey); } }; // 实现 rememberText 方法的具体逻辑 const rememberText: EchoTracker[rememberText] (text, opts) { // 如果文本为空直接跳过记录 if (!text) return; // 将基础文本添加到记录集合中 recentlySent.add(text); // 如果同时提供了合并后的消息体和对应的会话键则额外添加组合键 if (opts.combinedBody opts.combinedBodySessionKey) { recentlySent.add( // 调用内部函数构建组合键并加入集合 buildCombinedKey({ sessionKey: opts.combinedBodySessionKey, combinedBody: opts.combinedBody, }), ); } // 如果开启了详细日志模式则输出当前添加到检测集的信息 if (opts.logVerboseMessage) { params.logVerbose?.( // 输出日志已添加到回声检测集当前大小 文本前 50 个字符 Added to echo detection set (size now: ${recentlySent.size}): ${text.substring(0, 50)}..., ); } // 执行修剪逻辑确保内存占用受控 trim(); }; // 返回实现的 EchoTracker 接口对象 return { // 注册记忆文本的方法 rememberText, // 检查键存在性的方法 has: (key) recentlySent.has(key), // 移除指定键的方法 forget: (key) { recentlySent.delete(key); }, // 暴露构建组合键的能力 buildCombinedKey, }; }2-回声机制防重-理解场景防止机器人重复发送相同消息假设你开发了一个 AI 客服机器人用户问今天天气怎么样机器人回复了答案。如果用户快速点击了两次发送按钮或者网络抖动导致重试机器人可能会重复发送完全相同的回复造成糟糕的用户体验。EchoTracker就是用来**检测并防止这种回声重复发送**的工具。代码示例演示import{createEchoTracker}from./echoTracker;// 1. 创建追踪器最多记 50 条带调试日志consttrackercreateEchoTracker({maxItems:50,logVerbose:(msg)console.log([EchoTracker]${msg})});// 模拟机器人发送消息 // 场景机器人要发送一条回复constreplyText今天北京晴天气温15-22度适合外出;constsessionIduser_123_session;// 当前会话ID// 2. 发送前检查这条消息最近发过吗if(tracker.has(replyText)){console.log(⚠️ 检测到重复内容跳过发送);}else{// 3. 记录这条消息表示我要发了tracker.rememberText(replyText,{combinedBody:replyText,// 完整消息内容combinedBodySessionKey:sessionId,// 关联到具体会话logVerboseMessage:true// 记录详细日志});// 4. 实际发送消息...sendToUser(replyText);console.log(✅ 消息已发送并记录);}// 模拟重复触发 // 5. 假设用户快速双击再次触发相同逻辑if(tracker.has(replyText)){console.log(⚠️ 检测到重复内容跳过发送);// ← 这次会走进这里}else{tracker.rememberText(replyText,{...});sendToUser(replyText);}// 其他功能演示 // 6. 使用组合键检测用于更复杂的场景constcomplexKeytracker.buildCombinedKey({sessionKey:user_123,combinedBody:订单查询: #8848});console.log(complexKey);// combined:user_123:订单查询: #8848// 7. 手动遗忘某条记录比如用户要求重新发送时tracker.forget(replyText);// 移除记录允许再次发送控制台输出[EchoTracker] Added to echo detection set (size now: 1): 今天北京晴天气温15-22度适合外出... ✅ 消息已发送并记录 ⚠️ 检测到重复内容跳过发送 combined:user_123:订单查询: #8848核心机制图解用户点击发送 ──┐ │ ▼ ┌───────────────┐ │ 检查 has() │◄──────── 查 Set 中是否存在 │ 是否重复 │ └───────┬───────┘ │ ┌───────┴───────┐ ▼ ▼ 是重复 否新消息 │ │ ▼ ▼ 跳过发送 rememberText() ──► 加入 Set 调用 trim() 维护容量 可选输出调试日志关键设计亮点特性说明自动去重Set数据结构天然去重同一文本只存一份LRU 淘汰超过maxItems时自动删除最早的记录不是随机删双键记录同时记录原始文本 combined:会话ID:内容组合键支持多维度查重调试友好logVerbose回调让开发者能看到追踪器内部状态手动干预forget()允许业务逻辑主动清除记录如用户要求重发实际应用场景IM 机器人— 防止网络重试导致的重复消息Webhook 处理器— 避免重复处理相同的推送事件消息队列消费— 幂等性保障防止重复消费表单提交防重— 快速双击提交按钮的保护这个工具本质上是一个带容量控制的短期记忆缓存专门用来回答我最近有没有处理过这个这个问题。
OpenClaw05_回声机制
发布时间：2026/7/12 14:58:56
OpenClaw05_回声机制针对中文版本openClaw进行源码阅读当前项目针对【回声机制防重】进行解读文章目录OpenClaw05_回声机制1-参考地址2-知识整理3-动手实操1-回声机制防重2-回声机制防重-理解场景防止机器人重复发送相同消息代码示例演示控制台输出核心机制图解关键设计亮点实际应用场景1-参考地址github版本OpenClawCNgitee版本OpenClawCNmac进行openclaw卸载参考openClaw源码拆解系列2-知识整理1OpenClaw源码-回声机制防重-源码2OpenClaw源码-回声机制防重-理解3-动手实操1-回声机制防重造这些词的人真的都是些神人本来写一个会话防重大家都能理解又造一个新词[回声EchoTracker]export type EchoTracker { // 记录文本并添加到去重集合用于回声检测 // text: 要记录的文本内容可为空字符串或 undefined // opts: 包含附加配置的选项对象 rememberText: ( text: string | undefined, opts: { // 可选的合并后消息体内容 combinedBody?: string; // 可选的与合并消息体关联的会话键 combinedBodySessionKey?: string; // 是否记录详细的调试日志 logVerboseMessage?: boolean; }, ) void; // 判断给定的键是否存在于最近发送的记录中 has: (key: string) boolean; // 从最近发送的记录中移除指定键 forget: (key: string) void; // 根据提供的参数构建唯一标识符 buildCombinedKey: (params: { sessionKey: string; combinedBody: string }) string; }; // 工厂函数创建并初始化一个回声追踪器实例 // params: 配置参数对象 export function createEchoTracker(params: { // 最大允许的条目数量默认为 100 maxItems?: number; // 可选的日志输出回调函数用于详细信息的记录 logVerbose?: (msg: string) void; }): EchoTracker { // 使用 Set 数据结构存储最近发送的文本键值自动去重且保持顺序插入 const recentlySent new Setstring(); // 计算实际有效的最大容量确保至少为 1 const maxItems Math.max(1, params.maxItems ?? 100); // 内部辅助函数构建唯一的组合键字符串 // p: 包含会话键和合并后的消息内容的参数对象 const buildCombinedKey (p: { sessionKey: string; combinedBody: string }) // 拼接为格式combined:会话键合并后的内容 combined:${p.sessionKey}:${p.combinedBody}; // 内部辅助函数修剪集合大小移除旧数据以符合容量限制 const trim () { // 当集合中的元素数量超过最大限制时循环移除元素 while (recentlySent.size maxItems) { // 获取迭代器中第一个元素的值即最早添加的元素 const firstKey recentlySent.values().next().value as string | undefined; // 如果没有找到键则中断循环 if (!firstKey) break; // 从集合中删除该键 recentlySent.delete(firstKey); } }; // 实现 rememberText 方法的具体逻辑 const rememberText: EchoTracker[rememberText] (text, opts) { // 如果文本为空直接跳过记录 if (!text) return; // 将基础文本添加到记录集合中 recentlySent.add(text); // 如果同时提供了合并后的消息体和对应的会话键则额外添加组合键 if (opts.combinedBody opts.combinedBodySessionKey) { recentlySent.add( // 调用内部函数构建组合键并加入集合 buildCombinedKey({ sessionKey: opts.combinedBodySessionKey, combinedBody: opts.combinedBody, }), ); } // 如果开启了详细日志模式则输出当前添加到检测集的信息 if (opts.logVerboseMessage) { params.logVerbose?.( // 输出日志已添加到回声检测集当前大小 文本前 50 个字符 Added to echo detection set (size now: ${recentlySent.size}): ${text.substring(0, 50)}..., ); } // 执行修剪逻辑确保内存占用受控 trim(); }; // 返回实现的 EchoTracker 接口对象 return { // 注册记忆文本的方法 rememberText, // 检查键存在性的方法 has: (key) recentlySent.has(key), // 移除指定键的方法 forget: (key) { recentlySent.delete(key); }, // 暴露构建组合键的能力 buildCombinedKey, }; }2-回声机制防重-理解场景防止机器人重复发送相同消息假设你开发了一个 AI 客服机器人用户问今天天气怎么样机器人回复了答案。如果用户快速点击了两次发送按钮或者网络抖动导致重试机器人可能会重复发送完全相同的回复造成糟糕的用户体验。EchoTracker就是用来**检测并防止这种回声重复发送**的工具。代码示例演示import{createEchoTracker}from./echoTracker;// 1. 创建追踪器最多记 50 条带调试日志consttrackercreateEchoTracker({maxItems:50,logVerbose:(msg)console.log([EchoTracker]${msg})});// 模拟机器人发送消息 // 场景机器人要发送一条回复constreplyText今天北京晴天气温15-22度适合外出;constsessionIduser_123_session;// 当前会话ID// 2. 发送前检查这条消息最近发过吗if(tracker.has(replyText)){console.log(⚠️ 检测到重复内容跳过发送);}else{// 3. 记录这条消息表示我要发了tracker.rememberText(replyText,{combinedBody:replyText,// 完整消息内容combinedBodySessionKey:sessionId,// 关联到具体会话logVerboseMessage:true// 记录详细日志});// 4. 实际发送消息...sendToUser(replyText);console.log(✅ 消息已发送并记录);}// 模拟重复触发 // 5. 假设用户快速双击再次触发相同逻辑if(tracker.has(replyText)){console.log(⚠️ 检测到重复内容跳过发送);// ← 这次会走进这里}else{tracker.rememberText(replyText,{...});sendToUser(replyText);}// 其他功能演示 // 6. 使用组合键检测用于更复杂的场景constcomplexKeytracker.buildCombinedKey({sessionKey:user_123,combinedBody:订单查询: #8848});console.log(complexKey);// combined:user_123:订单查询: #8848// 7. 手动遗忘某条记录比如用户要求重新发送时tracker.forget(replyText);// 移除记录允许再次发送控制台输出[EchoTracker] Added to echo detection set (size now: 1): 今天北京晴天气温15-22度适合外出... ✅ 消息已发送并记录 ⚠️ 检测到重复内容跳过发送 combined:user_123:订单查询: #8848核心机制图解用户点击发送 ──┐ │ ▼ ┌───────────────┐ │ 检查 has() │◄──────── 查 Set 中是否存在 │ 是否重复 │ └───────┬───────┘ │ ┌───────┴───────┐ ▼ ▼ 是重复 否新消息 │ │ ▼ ▼ 跳过发送 rememberText() ──► 加入 Set 调用 trim() 维护容量 可选输出调试日志关键设计亮点特性说明自动去重Set数据结构天然去重同一文本只存一份LRU 淘汰超过maxItems时自动删除最早的记录不是随机删双键记录同时记录原始文本 combined:会话ID:内容组合键支持多维度查重调试友好logVerbose回调让开发者能看到追踪器内部状态手动干预forget()允许业务逻辑主动清除记录如用户要求重发实际应用场景IM 机器人— 防止网络重试导致的重复消息Webhook 处理器— 避免重复处理相同的推送事件消息队列消费— 幂等性保障防止重复消费表单提交防重— 快速双击提交按钮的保护这个工具本质上是一个带容量控制的短期记忆缓存专门用来回答我最近有没有处理过这个这个问题。
