C#实现数据采集系统-多设备采集

系统功能升级-多设备采集

数据采集系统在网络环境下,性能足够,可以实现1对多采集,需要支持多个设备进行同时采集功能,现在就开发多设备采集功能

修改多设备配置

设备配置

  1. DeviceLink 改成List集合的DeviceLinks
  2. 删掉Points,将点位集合放到对应的设备中去
    public class DaqOption{//单设备//public DeviceLink DeviceLink { get; set; }//多设备public List<DeviceLink> DeviceLinks { get; set; }public MqttConfig MqttConfig { get; set; }public ServiceConfig ServiceConfig { get; set; }//public List<RegisterPoint> Points { get; set; }public DaqOption() { }}/// <summary>/// 设备链路类/// </summary>public class DeviceLink{public string UID { get; set; }public string Ip { get; set; }public int Port { get; set; }public int SlaveId { get; set; } = 1;/// <summary>/// 采集周期 单位:S   200ms 0.2s/// </summary>public double AcqTimeSpan { get; set; }//增加public List<RegisterPoint> Points { get; set; }public DeviceLink(){Points = new List<RegisterPoint>();}}

同时配置文件也跟着变化,DeviceLinks改成数组形式,变成两个设备的配置

{"DeviceLinks": [{"UID": "device01","Ip": "127.0.0.1","Port": 502,"SlaveId": 1,"AcqTimeSpan": 1},{"UID": "device02","Ip": "127.0.0.1","Port": 503,"SlaveId": 1,"AcqTimeSpan": 1}],"MqttConfig": {//...},"ServiceConfig": {//...}
}

数据点位配置

RegisterPoint中增加设备Id的属性,用于区分,这个数据点位属于哪个设备

    public class RegisterPoint{//...public string DeviceId { get; set; }}

配置加载

DaqOptionBuilder修改配置加载,主要就是点位的加载,多设备配置的加载,按上面的配置修改后,自动反序列化加载。

点位的加载,需要读入新加的设备Id,然后根据设备id在DeviceLinks中查找到对应的设备,然后将点位加入到对应设备的点位集合Points中去。

 public class DaqOptionBuilder{//...public DaqOption Build(){var str = File.ReadAllText(_path + "\\Config.json");var option = JsonSerializer.Deserialize<DaqOption>(str);List<RegisterPoint> points = new List<RegisterPoint>();var lines = File.ReadAllLines(_path + "\\AllPoint.csv").ToList();lines.RemoveAt(0);foreach (var line in lines){var values = line.Split(',');var point = new RegisterPoint{UID = values[0],Name = values[1],Type = Type.GetType("System." + values[2]),RegisterType = values[3],Address = int.Parse(values[4]),Length = int.Parse(values[5]),DeviceId = values[6] //读入点位对应的设备ID};//查找对应的设备,将点位加入进去option.DeviceLinks.FirstOrDefault(x => x.UID == point.DeviceId)?.Points.Add(point);}return option;}}

主服务修改

多设备属性修改

修改DaqService服务类中,原来设备对象_deviceLink_points,改成设备集合_deviceLinks,然后对应的服务类中同步修改

 public class DaqService{// 原来// private DeviceLink _deviceLink;// private List<RegisterPoint> _points;//新private List<DeviceLink> _deviceLinks;public DaqService(DaqOption option){//...//修改_deviceLinks = option.DeviceLinks;//...}}

功能修改

在启动和定时推送中,都改成循环_deviceLinks来实现功能

 public void Start(){foreach (var item in _deviceLinks){ModbusTcp modbusTcp = new ModbusTcp(item);modbusTcp.ValueUpdated += ModbusTcp_ValueUpdated;modbusTcp.DoMitor();}mqttControllor = new MqttControllor(_option.MqttConfig);mqttControllor.MqttConnect();if (_serviceConfig.IsPushScheduled){_timer.Start();}}private void Timer_Elapsed(object? sender, ElapsedEventArgs e){foreach (var link in _deviceLinks){try{DeviceMessage deviceMessage = new DeviceMessage() { DeviceId = link.UID };foreach (var point in link.Points){Console.WriteLine($"Point:{point.UID}-->Value:{point.Value}");deviceMessage.Data.Add(point.UID, point.Value);}var str1 = JsonSerializer.Serialize(deviceMessage);mqttControllor.Publish("Device/" + link.UID + "/Time", str1);}catch (Exception ex){Console.WriteLine(ex.Message);}}}

在变化推送中,可以直接使用点位中DeviceId 替代原设备ID(_deviceLink.UID

 //事件方法private void ModbusTcp_ValueUpdated(RegisterPoint point, object value){if (_serviceConfig.IsPushChanged){try{DeviceMessage device = new DeviceMessage { DeviceId = point.DeviceId };device.Data.Add(point.UID, value);var data = JsonSerializer.Serialize(device);mqttControllor.Publish($"Device/{point.DeviceId}/Update", data); //采集立刻推送}catch (Exception ex){Console.WriteLine(ex.Message);}Console.WriteLine($"Point:{point.UID}-->Value:{value}");}}

完整的服务代码

 public class DaqService{private DaqOption _option;private List<DeviceLink> _deviceLinks;private ServiceConfig _serviceConfig;MqttControllor mqttControllor { get; set; }private Timer _timer;public DaqService(DaqOption option){_option = option;_deviceLinks = option.DeviceLinks;_serviceConfig = option.ServiceConfig;if (_serviceConfig.IsPushScheduled){_timer = new Timer(_serviceConfig.PushTimeSpan * 1000);_timer.Elapsed += Timer_Elapsed;}}public void Start(){foreach (var item in _deviceLinks){ModbusTcp modbusTcp = new ModbusTcp(item);modbusTcp.ValueUpdated += ModbusTcp_ValueUpdated;modbusTcp.DoMitor();}mqttControllor = new MqttControllor(_option.MqttConfig);mqttControllor.MqttConnect();if (_serviceConfig.IsPushScheduled){_timer.Start();}}private void Timer_Elapsed(object? sender, ElapsedEventArgs e){foreach (var link in _deviceLinks){try{DeviceMessage deviceMessage = new DeviceMessage() { DeviceId = link.UID };foreach (var point in link.Points){Console.WriteLine($"Point:{point.UID}-->Value:{point.Value}");deviceMessage.Data.Add(point.UID, point.Value);}var str1 = JsonSerializer.Serialize(deviceMessage);mqttControllor.Publish("Device/" + link.UID + "/Time", str1);}catch (Exception ex){Console.WriteLine(ex.Message);}}}//事件方法private void ModbusTcp_ValueUpdated(RegisterPoint point, object value){if (_serviceConfig.IsPushChanged){try{DeviceMessage device = new DeviceMessage { DeviceId = point.DeviceId };device.Data.Add(point.UID, value);var data = JsonSerializer.Serialize(device);mqttControllor.Publish($"Device/{point.DeviceId}/Update", data); //采集立刻推送}catch (Exception ex){Console.WriteLine(ex.Message);}Console.WriteLine($"Point:{point.UID}-->Value:{value}");}}}

最终实现效果

在这里插入图片描述

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/news/877643.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

二、什么是Vue中的响应式?Vue的响应式原理

什么是Vue中的响应式 Vue中的响应式&#xff0c;简而言之就是当数据发生变化时&#xff0c;页面跟随变化。使用过Vue的v-model都有比较深刻的感受&#xff0c;我们在代码中修改双向绑定的数据后&#xff0c;页面上的数据也会自动更新&#xff0c;页面跟随变化 我们看个例子&am…

Java ArrayList和LinkedList

ArrayList ArrayList是Java中最常用的数据结构之一&#xff0c;它是一个动态数组的实现&#xff0c;允许你在程序中存储和管理一个可变大小的对象列表&#xff0c;我们可以添加或删除元素。 ArrayList 继承了 AbstractList &#xff0c;并实现了 List 接口。 基本概念 Arra…

【Linux】ARM服务器命令行安装虚拟机

在Arm服务器上安装虚拟机操作笔记 一、基础环境准备1、环境准备2、检查KVM支持3、启动并启用libvirtd服务4、创建虚拟网络&#xff08;可选&#xff09;5、使用virt-manager创建虚拟机&#xff08;支持KVM&#xff09;6、管理虚拟机9、监控和日志 二、软虚拟化替代方案1、查看虚…

6. type *(0)的神奇之处

表达式 type * (0) 在 C/C 编程中是一个常见的技巧&#xff0c;通常用于内核编程和一些系统编程场景中。这种语法形式的主要作用是获取特定类型指针的虚拟地址 0&#xff0c;从而进行类型转换或执行其他计算。接下来我们会深入分析这个表达式的具体含义和应用。 1. 表达式的基…

GPT4o编写步进电机控制代码

我给出的要求如下&#xff1a; 基于STM32F407 HAL库&#xff0c;写一个步进电机控制程序&#xff0c;需要控制8个步进电机&#xff0c;我会给出描述步进电机的结构体变量&#xff0c;基于这些变量需要你做出以下功能&#xff0c;电机脉冲通过定时器中断翻转脉冲引脚的电平实现…

安科瑞电气防火在线保护器 ASCP210系列适用于汽车充电桩

安科瑞电气防火限流式保护器 传统保护方式采用电磁脱扣式断路器&#xff0c;检测到短路时&#xff0c;脱扣器动作&#xff0c;分断时间在毫米级&#xff0c;无法阻断短路电流。较好的方式是采用响应速度快的限流技术和器件。 电弧也有克星&#xff0c;可以微秒被扼杀在摇篮中&…

Vscode——如何实现 Ctrl+鼠标左键 跳转函数内部的方法

一、对于Python代码 安装python插件即可实现 二、对于C/C代码 安装C/C插件即可实现

【MySQL进阶之路】数据的查询

目录 建表 全列查询 指定列查询 查询表达式 指定别名 结果去重 WHERE 条件查询 模糊查询 结果排序 筛选分页结果 不同子句的执行顺序 个人主页&#xff1a;东洛的克莱斯韦克-CSDN博客 建表 CREATE TABLE grades( id INT UNSIGNED PRIMARY KEY AUTO_INCREMENT, name …

视觉巡线小车(STM32+OpenMV)——技术总结

在现代机器人技术中&#xff0c;视觉巡线是一种常见的导航方式&#xff0c;它允许机器人通过识别和跟踪地面上的线路来自主导航。本文将总结使用STM32微控制器和OpenMV视觉模块来实现视觉巡线小车的关键技术和步骤。 引言 视觉巡线小车是一种基于视觉识别技术的智能机器人&am…

CF 966 Div3 F. Color Rows and Columns

原题链接&#xff1a;Problem - F - Codeforces 题意&#xff1a;多测&#xff0c;每组测试数据给出n和k&#xff0c;n代表有n个长方形&#xff0c;k代表需要的到k分&#xff0c;每个长方形都有宽和高&#xff0c;每次可以填涂一个格子&#xff0c;如果填满一列或者一行就可以…

前端技巧——复杂表格在html当中的实现

应用场景 有时候我们的表格比较复杂&#xff0c;表头可能到处割裂&#xff0c;我们还需要写代码去完成这个样式&#xff0c;所以学会在原生html处理复杂的表格还是比较重要的。 下面我们来看这一张图&#xff1a; 我们可以看到有些表头项的规格不太一样&#xff0c;有1*1 2*…

雅菲奥朗 FinOps 认证培训:开启企业云财务管理转型之路

前言&#xff1a; 在当今快速变化的商业环境中&#xff0c;企业面临着前所未有的IT财务挑战。随着云计算和数字化转型的推进&#xff0c;传统的财务管理方式已经不能满足“企业上云”的需求。FinOps&#xff0c;即“云财务管理”应运而生&#xff0c;成为帮助企业实现IT财务流…

Oracle Index Partition索引分区的管理

Oracle索引分区的管理是数据库管理中的重要任务之一&#xff0c;它涉及索引的创建、维护、重建以及优化等多个方面。以下是对Oracle索引分区管理的详细解析&#xff1a; 一、索引分区的概念 索引分区&#xff08;Partitioned Index&#xff09;是针对分区表而言的&#xff0c…

虚幻引擎游戏开发 | 程序化生成道具位置 Randomize Height

当地图上有无数个收集物【如水晶】&#xff0c;一键随机化高度 应用前 应用后 这时候水晶的高度是离散型地在0和110两个数中平均概率地选择。 如果要有权重地分布高度&#xff0c;减少高位水晶的比例&#xff08;由于过多连续跳跃会让玩家无聊和难以持续专注&#xff09;可以加…

R语言统计分析——回归中的异常观测值

参考资料&#xff1a;R语言实战【第2版】 一个全面的回归分析要覆盖对异常值的分析&#xff0c;包括离群点、高杠杆点和强影响点。这些数据点需要更深入的研究&#xff0c;因为它们在一定程度上与其他观点不同&#xff0c;可能对结果产生较大的负面影响。 1、离群点 离群点是指…

[ACL 2024] Revisiting Knowledge Distillation for Autoregressive Language Models

Contents IntroductionMethodRethinking Knowledge Distillation for Autoregressive LMsImproving Knowledge Distillation with Adaptive Teaching Modes ExperimentsReferences Introduction 作者提出 Autoregressive KD with Adaptive Teaching Modes (ATKD)&#xff0c;通…

拦截器实现 Mybatis Plus 打印含参数的 SQL 语句

1.实现拦截器 package com.sample.common.interceptor;import com.baomidou.mybatisplus.extension.plugins.inner.InnerInterceptor; import lombok.extern.slf4j.Slf4j; import org.apache.ibatis.executor.Executor; import org.apache.ibatis.mapping.BoundSql; import or…

java之类和对象的介绍

1.面向对象和面向过程的概念&#xff1a; 面向对象&#xff1a;面向对象是解决问题的一种思想&#xff0c;主要依靠对象之间的交互完成一件事。 面向过程&#xff1a;注重完成一件事情的过程&#xff0c;后续代码维护扩展较为麻烦。 以洗衣服为例&#xff0c;面向对象为传统…

模糊测试技术与高效模糊测试策略设计(第一篇)

一、概述 模糊测试&#xff08;Fuzzing&#xff09;是一种自动化测试技术&#xff0c;通过向目标软件输入大量随机或异常数据来发现潜在的安全漏洞。这种技术在软件安全研究中至关重要&#xff0c;尤其适用于发现未知漏洞。本文将详细讲解如何使用模糊测试工具&#xff0c;以及…

软件测试 |属性获取与断言

1.断言简介 断言时候UI自动化测试的三要素之一&#xff0c;是UI自动化测试中不可或缺的部分。我们使用定位器到定位元素后&#xff0c;通过测试脚本进行业务交互操作时&#xff0c;想要验证交互操作过程中的结果正确性就需要用到断言。 2.常规的UI自动化测试中使用的断言 在…