Skip to Content
Week 17 - 采集引擎Day 7 - 多设备采集服务验收

Day 7 - 多设备采集服务验收

建议用时:150-210 分钟

你将学会什么

  • 明确数据流和生命周期
  • 单设备失败不影响其他设备
  • 输出采集健康指标

把驱动、调度、队列、缓存、数据库和 UI 更新串成可启动、可停止、可观察的服务。 今天的 3 个例子都要亲手敲,不能只复制,也不能只看运行结果。

标为 Program.cs 的最小例子可以放进控制台练习项目;标为 Service、ViewModel、XAML 或 SQL 文件的例子,要在本周项目中按前一天已经建立的模型继续敲。文件名和上下文不同,不要把所有片段塞进同一个 Program.cs

学习衔接

这是 Week 17 的第 7 天。先使用前面已经掌握的 C#、异步、异常、接口和 MVVM,只增加今天这一层上位机能力。

今天的最低通过线

顺序必须掌握怎么证明
1明确数据流和生命周期能用自己的话解释并完成对应例子
2单设备失败不影响其他设备能用自己的话解释并完成对应例子
3输出采集健康指标能用自己的话解释并完成对应例子

先用大白话理解

把驱动、调度、队列、缓存、数据库和 UI 更新串成可启动、可停止、可观察的服务。

学习时固定按这个顺序:

先看数据是什么 -> 再看最小代码 -> 对照运行结果 -> 修改一个参数 -> 故意制造错误 -> 最后组合进上位机项目

例子 1:完整数据流

文件:architecture.txt

驱动读取 -> TagSample -> 有界 Channel -> 最新值缓存 -> 报警服务 -> SQLite 批量写入 +缓存快照 -> UI 节流刷新

运行结果或界面效果:

每个模块只有一个主要职责

必须改一次: 指出哪些步骤允许丢数据,哪些不允许。

例子 2:健康指标

文件:Program.cs

public record CollectorMetrics(long Received, long Stored, long Dropped, int QueueLength, TimeSpan LastCycle); var metrics = new CollectorMetrics(1000, 998, 2, 15, TimeSpan.FromMilliseconds(120));

运行结果或界面效果:

能看到接收、保存、丢弃、队列和周期耗时

必须改一次: 加上在线设备数。

例子 3:安全停止顺序

文件:Program.cs

schedulerCts.Cancel(); await schedulerTask; channel.Writer.Complete(); await storageTask; await driverManager.DisconnectAllAsync();

运行结果或界面效果:

先停生产者,再排空消费者,最后断开驱动

必须改一次: 异常退出时也执行同样清理。

常见错误和修法

  1. 停止时先销毁数据库再停采集
  2. 一台设备异常让 Task.WhenAll 整体退出
  3. 没有指标无法判断采集是否堆积

修错顺序固定为:先看第一条异常和行号,再看输入数据,再看原始字节或状态,最后才怀疑框架。

小白重复敲写训练

  1. 不看上面的代码,重新敲“完整数据流”。
  2. 不看上面的代码,重新敲“健康指标”。
  3. 不看上面的代码,重新敲“安全停止顺序”。
  4. 完成改动任务:指出哪些步骤允许丢数据,哪些不允许。
  5. 完成改动任务:加上在线设备数。
  6. 完成改动任务:异常退出时也执行同样清理。

每日小测

  1. 今天的知识在上位机里解决什么问题?
  2. 三个例子分别输入了什么,输出了什么?
  3. 如果运行结果不对,你第一步检查什么?
  4. 哪一段代码负责停止、超时或错误处理?

小测答案

答案不能只背一句话。回到三个例子,用代码中的变量、方法和输出逐项说明。能脱离页面说清楚,才算真的理解。

今日作业

  1. 新建空项目,不复制地重做三个例子。
  2. 每个例子都完成“必须改一次”。
  3. 故意制造一个错误,记录错误文字和修复办法。
  4. 把今天代码提交到自己的练习仓库。

作业验收

  • 三个例子都能运行或显示预期界面。
  • 能解释关键数据从哪里来、经过什么处理、最后去哪里。
  • 失败时不会让程序无提示崩溃。
  • 能说出今天内容如何进入“多设备统一采集服务”。