Worker 模式或 Chain 模式的应用场景以及使用注意事项

[degent007]

Worker 模式或 Chain 模式的应用场景以及使用注意事项

[nevstop]

CSM 框架提供了两种高级并发模式：工作者模式 (Worker Mode) 和 责任链模式 (Chain Mode)，它们分别适用于不同的场景，且在使用上有明确的原则。

一句话结论

• 工作者模式用于并发处理相同类型的任务，通过多个空闲实例公平竞争消息队列；责任链模式用于串行处理不同能力的节点，消息按固定顺序传递。
• 核心注意事项：Worker 模式通过模块名后缀 # 标识，不能直接向单个 Worker 实例发送消息；Chain 模式必须通过 Chain 名称发送消息，节点顺序决定了处理优先级。

应用场景对比

模式	核心机制	典型应用场景	并发性
工作者模式 (Worker Mode)	多个可克隆的 CSM 实例（Worker）共享一个消息队列，第一个空闲的 Worker 取出并处理消息。	10086 接线员、下载器并发下载、编译器并发编译、TCP Server 处理多个 Client 连接。	高并发（多个 Worker 并行处理不同消息）
责任链模式 (Chain Mode)	消息按预定义的节点顺序依次传递，每个节点处理自己擅长的部分，处理完后传递给下一个节点。	数据流水线处理（如：数据采集→清洗→分析→存储）、审批流程、多级日志处理。	顺序处理（每个节点只能处理一个消息，完成后才到下一个）

使用注意事项与最佳实践

工作者模式 (Worker Mode)

1. 命名规则：必须通过为模块名称添加 # 后缀来声明这是一个 Worker 模式模块。例如，模块名称为 module#，则 module 是 Worker Agent（代理）名称，框架会自动为每个实例生成类似 module#59703F3AD837 的唯一名称。
2. 通讯限制：不能直接与单个 Worker 实例通讯。所有外部消息必须发送给 Worker Agent（即去掉 # 的名称）。例如，发送同步消息使用 csm message >> arguments -@ module，发送异步消息使用 csm message >> arguments -> module。
3. 公平队列：消息发送给 Worker Agent 后，会进入一个公平队列。第一个空闲的 Worker 会从队列中取出消息处理，从而实现负载均衡。
4. 退出策略：在退出时，需要使用 CSM - Build Exit Messages of CSMs VI 为所有正在运行的 Worker 实例生成退出消息，然后向主模块发送本地 Macro: Exit 消息，确保所有实例按顺序退出。
5. 状态管理：从外部看，Worker Agent 表现得像一个普通 CSM 模块，所有 CSM 概念（同步、异步、广播、状态注册）都保持不变。

责任链模式 (Chain Mode)

1. 通讯限制：必须通过 Chain 名称发送消息，不能直接向单个节点发送消息。消息会按照节点在 Chain 中的注册顺序依次传递。
2. 节点顺序：节点在 Chain 中的顺序决定了消息处理的优先级。如果需要调整处理顺序，需要重新配置 Chain 的节点注册顺序。
3. 适用场景：特别适合带界面的串行处理场景（如用户操作向导），因为每个节点可以有自己的 UI 逻辑，而 Worker 模式不适合带界面的场景。
4. 处理能力差异：每个节点可以有不同的处理能力，消息会在节点间传递，直到被某个节点处理或到达链尾。

最小可运行示例（伪代码描述）

工作者模式示例：

1. 创建一个名为 Downloader# 的 CSM 模块（表示 Worker Agent）。
2. 异步启动 4 个实例：Downloader#A、Downloader#B、Downloader#C、Downloader#D。
3. 主程序发送消息 Download: URL1 -> Downloader（异步消息）。
4. 框架将消息放入队列，空闲的 Downloader#C 取出并处理。
5. 同时发送 Download: URL2 -> Downloader，空闲的 Downloader#A 取出处理，实现并发下载。

责任链模式示例：

1. 创建一个名为 DataPipeline 的 Chain。
2. 按顺序注册节点：Collector → Cleaner → Analyzer → Storer。
3. 发送消息 Process: raw_data -@ DataPipeline。
4. Collector 采集数据后，传递给 Cleaner 清洗，再传递给 Analyzer 分析，最后 Storer 存储结果。

深入阅读

• 更详细的对比表格和示例代码，请参考 与工作者模式的区别。
• 完整的工作者模式范例，请查看 调用程序(Action Worker Mode Example.vi)。
• 关于工作者模式的 API 详细说明，请参考 工作者模式 (Work Mode API)。

---

🤖 此回答由 CSM-QA-Robot 自动生成。如有偏差，欢迎追问或修正。

[nevstop]

@degent007 工作者模式机器人的回复是正确的，但是关于责任链模式的描述是错误的... 责任链模式组成串后，只会由最低可处理权限的节点处理，之后的节点将不会处理消息。例如：Chain由 chain$1 chain$2 chain$3 组成, 其中 chain$2 chain$3 都可以处理 message1 ,chain$1 不可以，那么 message1 会被丢给chain$2 处理，其他的并不会收到消息。这个讨论会丢给AI，补充到 csm-wiki 中，抱歉带来误解。

[nevstop]

正确的相关描述： @degent007

CSM 框架提供了责任链模式 (Chain Mode)，用于按优先级静态路由消息。

一句话结论

• 责任链模式用于按优先级静态路由消息，框架根据注册表将消息直接投递给优先级最高且能处理该消息类型的节点，消息只被一个节点处理，无节点间传递或降级。
• 核心注意事项：Chain 模式必须通过 Chain 名称发送消息，节点命名使用 $ 后缀加数字表示优先级（数字越小优先级越高），框架自动路由到优先级最高的可处理节点。

应用场景

模式	核心机制	典型应用场景	并发性
责任链模式 (Chain Mode)	每个节点通过 $ 后缀声明优先级并声明自己能处理的消息类型。框架为每个 Chain 维护注册表（消息类型 → 该 Chain 下能处理此类型的节点优先级列表）。向 Chain 发送消息时，框架直接选择优先级最高的节点投递，消息不经过其他节点。	1. 不同功能的模块组成更大功能集合（如一个 Chain 包含加、减、乘、除节点，外部调用加法消息自动路由到加法节点）；2. 功能覆盖（相同功能的多个模块按优先级决定最终行为，高优先级节点生效，低优先级节点被覆盖）。	单节点处理（每个消息只被一个节点处理，无并发）

使用注意事项与最佳实践

责任链模式 (Chain Mode)

1. 命名规则：节点模块必须使用 $ 后缀加数字来声明优先级，格式为 ChainName$优先级数字。例如，DataProcessor$1、DataProcessor$2，数字越小优先级越高。所有同名的 ChainName 节点共同组成一个责任链。
2. 注册表与静态路由：框架会为每个 Chain 维护一个注册表，记录该 Chain 下所有节点的优先级以及每个节点能处理的消息类型（方法名）。当你向 Chain 名称（例如 DataProcessor）发送消息时：
   • 框架根据消息的方法名，从注册表中查找所有能处理该方法的节点。
   • 从这些节点中选出优先级最高的一个（数字最小）。
   • 将消息直接投递给该节点，消息不会在节点间依次传递，节点内部也不会进行“接受/拒绝”判断并降级。处理节点在链组成时已由优先级静态确定。
   • 若没有任何节点能处理该消息，则消息被丢弃或报错（取决于框架配置）。
3. 通讯限制：必须通过 Chain 名称发送消息，不能直接向单个 ChainName$N 节点发送消息。发送同步消息使用 -@ ChainName，异步消息使用 -> ChainName。
4. 适用场景：
   • 不同功能的模块组成更大功能集合：例如将加法模块、减法模块、乘法模块、除法模块组合成一个名为 Calculator 的 Chain。外部发送 Add 消息时，框架自动路由到加法模块；发送 Multiply 消息时路由到乘法模块。外部调用者无需知道内部具体模块，只需与 Chain 交互。
   • 功能覆盖（优先级覆盖）：多个模块实现相同功能但版本或策略不同。例如，Auth$1 使用新版验证算法，Auth$2 使用旧版算法。由于 $1 优先级更高，所有 Authenticate 消息都会由 Auth$1 处理，Auth$2 永远不会收到消息（除非 Auth$1 被卸载）。链的整体行为等于优先级最高的那个能处理该消息的节点。

[nevstop]

感谢你的指正，你提供的描述更准确地反映了 CSM 框架中责任链模式的实际实现机制——基于优先级的静态路由，而非传统责任链的“逐级传递”。我将基于你的正确描述，重新整理一份更严谨的答案。

---

CSM 框架提供了责任链模式 (Chain Mode)，用于按优先级静态路由消息。

一句话结论

• 责任链模式用于按优先级静态路由消息，框架根据注册表将消息直接投递给优先级最高且能处理该消息类型的节点，消息只被一个节点处理，无节点间传递或降级。
• 核心注意事项：Chain 模式必须通过 Chain 名称发送消息，节点命名使用 $ 后缀加数字表示优先级（数字越小优先级越高），框架自动路由到优先级最高的可处理节点。

应用场景

模式	核心机制	典型应用场景	并发性
责任链模式 (Chain Mode)	每个节点通过 $ 后缀声明优先级并声明自己能处理的消息类型。框架为每个 Chain 维护注册表（消息类型 → 该 Chain 下能处理此类型的节点优先级列表）。向 Chain 发送消息时，框架直接选择优先级最高的节点投递，消息不经过其他节点。	1. 不同功能的模块组成更大功能集合（如一个 Chain 包含加、减、乘、除节点，外部调用加法消息自动路由到加法节点）；2. 功能覆盖（相同功能的多个模块按优先级决定最终行为，高优先级节点生效，低优先级节点被覆盖）。	单节点处理（每个消息只被一个节点处理，无并发）

使用注意事项与最佳实践

责任链模式 (Chain Mode)

1. 命名规则：节点模块必须使用 $ 后缀加数字来声明优先级，格式为 ChainName$优先级数字。例如，DataProcessor$1、DataProcessor$2，数字越小优先级越高。所有同名的 ChainName 节点共同组成一个责任链。

2. 注册表与静态路由：框架会为每个 Chain 维护一个注册表，记录该 Chain 下所有节点的优先级以及每个节点能处理的消息类型（方法名）。当你向 Chain 名称（例如 DataProcessor）发送消息时：

   • 框架根据消息的方法名，从注册表中查找所有能处理该方法的节点。
   • 从这些节点中选出优先级最高的一个（数字最小）。
   • 将消息直接投递给该节点，消息不会在节点间依次传递，节点内部也不会进行“接受/拒绝”判断并降级。处理节点在链组成时已由优先级静态确定。
   • 若没有任何节点能处理该消息，则消息被丢弃或报错（取决于框架配置）。

3. 通讯限制：必须通过 Chain 名称发送消息，不能直接向单个 ChainName$N 节点发送消息。发送同步消息使用 -@ ChainName，异步消息使用 -> ChainName。

4. 适用场景：

   • 不同功能的模块组成更大功能集合：例如将加法模块、减法模块、乘法模块、除法模块组合成一个名为 Calculator 的 Chain。外部发送 Add 消息时，框架自动路由到加法模块；发送 Multiply 消息时路由到乘法模块。外部调用者无需知道内部具体模块，只需与 Chain 交互。
   • 功能覆盖（优先级覆盖）：多个模块实现相同功能但版本或策略不同。例如，Auth$1 使用新版验证算法，Auth$2 使用旧版算法。由于 $1 优先级更高，所有 Authenticate 消息都会由 Auth$1 处理，Auth$2 永远不会收到消息（除非 Auth$1 被卸载）。链的整体行为等于优先级最高的那个能处理该消息的节点。

最小可运行示例（伪代码描述）

责任链模式示例——计算器 Chain：

1. 创建三个节点模块：
   • Calculator$1：能处理 Add 和 Subtract 消息。
   • Calculator$2：能处理 Multiply 消息。
   • Calculator$3：能处理 Divide 消息。
2. 主程序发送消息 Add >> 3, 5 -@ Calculator。
3. 框架查询注册表，发现 Calculator$1 能处理 Add 且优先级最高（数字最小），直接将消息投递给 Calculator$1。
4. 主程序发送消息 Divide >> 10, 2 -@ Calculator。
5. 框架查询注册表，发现 Calculator$3 能处理 Divide（且是唯一能处理的），直接将消息投递给 Calculator$3。

深入阅读

• 关于责任链模式的定义、命名规则和路由机制，请参考 责任链模式 (Chain of Responsibility API)。
• 关于责任链模式与工作者模式的区别，请参考 与工作者模式的区别。
• 完整示例代码和运行步骤，请参考 调用程序(Chain of Responsibility Example.vi)。

---

🤖 此回答由 CSM-QA-Robot 自动生成。如有偏差，欢迎追问或修正。