单进程、模块化、每工站独立运行时、每设备独立通讯队列、流程用状态机 + Channel 的架构详解

zhxup606

91人浏览 · 2026-09-03 15:08:08

zhxup606 · 2026-09-03 15:08:08 发布

单进程、模块化、每工站独立运行时、每设备独立通讯队列、流程用状态机 + Channel 的架构详解，以及状态机专项详解。

这是一种典型的工业自动化 / 产线控制 / 设备调度软件常见设计（也可用于机器人工作站、测试台、装配线等）。核心目标是：在单进程内实现高内聚、低耦合、可扩展、易调试的实时流程控制，同时保证设备通讯隔离与工站独立性。

1. 整体架构要点

特性	含义与好处	实现要点
单进程	整个系统跑在一个 OS 进程里	共享内存、无跨进程 IPC 开销；用线程 / goroutine / 协程做并发；崩溃影响全局，需严格异常隔离与看门狗
模块化	按职责拆分为独立模块（工站、设备、通讯、流程、日志、配置等）	接口清晰、可单独替换/测试；通过依赖注入或注册表组装
每个工站独立运行时	每个工站有自己独立的执行循环 / 状态机 / 线程（或 goroutine）	工站之间互不阻塞；可独立启停、暂停、复位；支持并行处理不同产品
每个设备单独通讯队列	每个物理设备（PLC、机器人、相机、扫码枪、气缸等）有独立消息队列	发送/接收隔离，避免一个设备阻塞其他设备；支持优先级、超时、重试；队列通常是线程安全的 channel / queue
流程使用状态机 + Channel	工站/整体流程用有限状态机驱动，状态间与模块间通过 Channel 传递事件/数据	流程清晰、可可视化、易调试；Channel 解耦生产者与消费者

典型数据流示意（简化）：

外部触发 / 传感器 → 设备通讯层（每设备独立队列） 
→ 事件推入 Channel 
→ 工站独立运行时（状态机）消费事件并驱动状态转换 
→ 状态机发出命令 → 再通过设备队列下发 
→ 完成/异常事件回流

2. 各层职责简述

单进程 + 模块化：主程序启动后加载配置，创建所有工站模块、设备代理、全局事件总线（或 Channel 集合）。所有模块在同一进程地址空间，通过接口或 Channel 交互。
工站独立运行时：每个工站是一个独立的“小系统”，内部有自己的主循环或状态机线程。工站之间通过有限的共享 Channel 或事件总线交换产品信息、完成信号、互锁信号。这样 A 工站卡死不会直接拖死 B 工站。
设备独立通讯队列：设备层通常做成“设备代理”（Device Proxy）。每个代理维护：
- 发送队列（命令）
- 接收队列（反馈/状态）
- 超时、重试、心跳逻辑
- 与真实硬件的通讯（串口、TCP、EtherCAT、OPC UA 等）
  好处是通讯抖动、重连、协议解析都封装在设备内部，不影响上层流程。
状态机 + Channel：流程逻辑不写成“一堆 if-else + sleep”，而是明确的状态 + 事件驱动。Channel 作为状态机的输入事件源和输出命令通道。

3. 状态机详解（重点）

状态机（Finite State Machine, FSM）是流程控制的核心。工业场景几乎都用事件驱动有限状态机。

3.1 基本组成

状态（State）：系统当前所处的明确位置。例如：Idle、WaitingProduct、Processing、WaitingDeviceDone、Error、Paused、Resetting。
事件（Event）：触发状态变化的外部或内部信号。例如：ProductArrived、DeviceDone、Timeout、ErrorOccurred、StartCmd、ResetCmd。
转换（Transition）：在某个状态下收到某个事件后，转到新状态，并可执行动作。
动作（Action）：进入状态、退出状态、或转换时执行的代码（发命令、记日志、更新数据等）。
守卫条件（Guard）：转换是否允许的额外判断（可选）。

经典表达方式：

当前状态 + 事件 [+ 守卫] → 动作 + 新状态

3.2 常见工业工站状态机示例（简化）

以一个“装配工站”为例：

状态：
  Idle
  WaitingProduct
  Processing
  WaitingRobot
  WaitingVision
  Completed
  Error
  Paused

主要转换：
  Idle + Start → WaitingProduct
  WaitingProduct + ProductArrived → Processing
  Processing + StartRobot → WaitingRobot
  WaitingRobot + RobotDone → WaitingVision
  WaitingVision + VisionOK → Completed
  WaitingVision + VisionNG → Error
  任何状态 + Pause → Paused
  Paused + Resume → 回到原状态（或特定恢复状态）
  任何状态 + ErrorOccurred → Error
  Error + Reset → Idle

3.3 与 Channel 的配合方式

状态机本身不直接轮询设备，而是：

设备层把反馈放入设备专属队列，再转成统一事件，推入工站的输入 Channel。
工站运行时（独立线程/goroutine）阻塞或 select 在输入 Channel 上。
收到事件后，状态机执行转换逻辑，必要时向设备输出 Channel / 队列发命令。
超时通常用定时器事件实现（另开定时器，到期后往 Channel 推 Timeout 事件）。

伪代码风格（概念）：

loop:
  event = receive from InputChannel (或 select 多路)
  switch currentState:
    case WaitingRobot:
      if event == RobotDone:
        doAction("启动视觉")
        currentState = WaitingVision
      elif event == Timeout:
        doAction("报警")
        currentState = Error
    case Error:
      if event == Reset:
        doAction("复位所有设备")
        currentState = Idle
  ...

3.4 状态机实现常见模式

显式状态机（推荐工业用）：用枚举/常量定义状态，用 switch-case 或状态表（二维表：状态 × 事件 → 动作+新状态）实现。清晰、可审计、易画图。
层次状态机（Hierarchical FSM）：状态可嵌套（如 Processing 下再分 SubStep1、SubStep2），适合复杂工站。
状态模式（面向对象）：每个状态一个类，实现 Handle(event) 方法。灵活但状态多时类爆炸。
库支持：很多语言有现成库（如 Python 的 transitions、C++ 的 Boost.Statechart / SML、Go 自己写或用第三方、PLC 本身就有状态机思想）。