驱动开发实战之TcpClient
场景模拟
假设你有一批非标设备需要对接,你需要根据设备方提供的协议,为IoTGateway开发驱动,进行数据交互。
文章比较长也可以到官网会有更好的体验,地址:
http://iotgateway.net/docs/iotgateway/driver/tcpclient
请先浏览上一篇驱动简介:
http://iotgateway.net/docs/iotgateway/driver/drvier
协议概述
对方提供了如下协议文档:
设备作为TCPServer,端口6666 字节序:Little-Endian,即低地址存放低位
请求回复
需要你主动发起读取请求:0x01 02 03 04 设备回复:0x08 01 41 D6 3D 71 1A 20
参数说明
总字节数
(byte[0])即0x08:用于简单的校验
运行状态
(byte[1])即0x01:1为运行;其他为停止
设备温度
(byte[2]-byte[5])即0x41 D6 3D 71:单精度浮点数值26.78
电机转速
(byte[6]-byte[7])即0x1A 20:对应16进制无符号整型,倍率0.01值66.88
驱动开发
创建驱动项目
在解决方案->Drivers文件夹,右键添加->新建项目->C#类库
项目名DriverSimTcpClient,放在
iotgateway\Plugins\Drivers
路径下修改Class1为SimTcpClient
双击项目,修改配置
iotgateway\Plugins\Drivers\DriverSimTcpClient\DriverSimTcpClient.csproj
<Project Sdk="Microsoft.NET.Sdk"><PropertyGroup><TargetFramework>net6.0</TargetFramework><OutputPath>../../../IoTGateway/bin/Debug/net6.0/drivers</OutputPath><CopyLocalLockFileAssemblies>true</CopyLocalLockFileAssemblies><ImplicitUsings>enable</ImplicitUsings><Nullable>enable</Nullable></PropertyGroup><ItemGroup><PackageReference Include="SimpleTCP.Core" Version="1.0.4" /></ItemGroup><ItemGroup><ProjectReference Include="..\..\PluginInterface\PluginInterface.csproj" /></ItemGroup> </Project>
说明:
OutputPath节点指定了生成项目的文件夹
SimpleTCP.Core是一个TCP客户端库(你也可以自己写)
ProjectReference节点引用了PluginInterface项目
CopyLocalLockFileAssemblies节点可以确保你引用的nuget拷贝到driver文件夹下 :::
编写项目代码:
iotgateway\Plugins\Drivers\DriverSimTcpClient\SimTcpClient.cs
using PluginInterface;
using SimpleTCP;
using System;
using System.Text;
namespace DriverSimTcpClient
{[DriverSupported("SimTcpServerDevice")][DriverInfoAttribute("SimTcpClient", "V1.0.0", "Copyright iotgateway© 2022-06-04")]public class SimTcpClient : IDriver{/// <summary>/// tcp客户端/// </summary>private SimpleTcpClient? client;/// <summary>/// 缓存最新的服务器返回的原始数据/// </summary>private byte[] latestRcvData;#region 配置参数[ConfigParameter("设备Id")]public Guid DeviceId { get; set; }[ConfigParameter("IP地址")]public string IpAddress { get; set; } = "127.0.0.1";[ConfigParameter("端口号")]public int Port { get; set; } = 6666;/// <summary>/// 为了演示枚举类型在web端的录入,这里没用到 但是你可以拿到/// </summary>[ConfigParameter("连接类型")]public ConnectionType ConnectionType { get; set; } = ConnectionType.Long;[ConfigParameter("超时时间ms")]public int Timeout { get; set; } = 300;[ConfigParameter("最小通讯周期ms")]public uint MinPeriod { get; set; } = 3000;#endregionpublic SimTcpClient(Guid deviceId){DeviceId = deviceId;}/// <summary>/// 判断连接状态/// </summary>public bool IsConnected{get{//客户端对象不为空并且客户端已连接则返回truereturn client != null && client.TcpClient.Connected;}}/// <summary>/// 进行连接/// </summary>/// <returns>连接是否成功</returns>public bool Connect(){try{//进行连接client = new SimpleTcpClient().Connect(IpAddress, Port);client.DataReceived += Client_DataReceived;}catch (Exception){return false;}return IsConnected;}/// <summary>/// 收到服务端数据/// </summary>/// <param name="sender"></param>/// <param name="e"></param>private void Client_DataReceived(object? sender, Message e){//如果收到的数据校验正确,则放在内存中if (e.Data.Length == 8 && e.Data[0] == 0x08)latestRcvData = e.Data;}/// <summary>/// 断开连接/// </summary>/// <returns>断开是否成功</returns>public bool Close(){try{client.DataReceived -= Client_DataReceived;//断开连接client?.Disconnect();return !IsConnected;}catch (Exception){return false;}}/// <summary>/// 释放/// </summary>public void Dispose(){try{//释放资源client?.Dispose();}catch (Exception){}}/// <summary>/// 发送数据/// </summary>private byte[] sendCmd = new byte[4] { 0x01, 0x02, 0x03, 0x04 };/// <summary>/// 解析并返回/// </summary>/// <param name="ioarg">ioarg.Address为起始变量字节编号;ioarg.ValueType为类型</param>/// <returns></returns>[Method("读模拟设备数据", description: "读模拟设备数据,开始字节和长度")]public DriverReturnValueModel Read(DriverAddressIoArgModel ioarg){var ret = new DriverReturnValueModel { StatusType = VaribaleStatusTypeEnum.Good };ushort startIndex;//判断地址是否为整数if (!ushort.TryParse(ioarg.Address, out startIndex)){ret.StatusType = VaribaleStatusTypeEnum.Bad;ret.Message = "起始字节编号错误";return ret;}//连接正常则进行读取if (IsConnected){try{//发送请求client?.Write(sendCmd);//等待恢复,这里可以优化Thread.Sleep(Timeout);if (latestRcvData == null){ret.StatusType = VaribaleStatusTypeEnum.Bad;ret.Message = "没有收到数据";}else{//解析数据,并返回switch (ioarg.ValueType){case DataTypeEnum.UByte:case DataTypeEnum.Byte:ret.Value = latestRcvData[startIndex];break;case DataTypeEnum.Int16:var buffer16 = latestRcvData.Skip(startIndex).Take(2).ToArray();ret.Value = BitConverter.ToInt16(new byte[] { buffer16[0], buffer16[1] }, 0);break;case DataTypeEnum.Float://拿到有用的数据var buffer32 = latestRcvData.Skip(startIndex).Take(4).ToArray();//大小端转换一下ret.Value = BitConverter.ToSingle(new byte[] { buffer32[3], buffer32[2], buffer32[1], buffer32[0] }, 0);break;default:break;}}}catch (Exception ex){ret.StatusType = VaribaleStatusTypeEnum.Bad;ret.Message = $"读取失败,{ex.Message}";}}else{ret.StatusType = VaribaleStatusTypeEnum.Bad;ret.Message = "连接失败";}return ret;}public async Task<RpcResponse> WriteAsync(string RequestId, string Method, DriverAddressIoArgModel Ioarg){RpcResponse rpcResponse = new() { IsSuccess = false, Description = "设备驱动内未实现写入功能" };return rpcResponse;}}public enum ConnectionType{Long,Short}
}
注册驱动
生成
DriverSimTcpClient
项目iotgateway\IoTGateway\bin\Debug\net6.0\drivers\net6.0
路径下可以看到生成了DriverSimTcpClient.dll运行IoTGateway,访问本地518端口
添加驱动
网关配置->驱动管理->添加
注意:添加驱动后需要重启一下项目,后面会优化
创建设备
采集配置->设备维护->添加设备
添加变量
采集配置->设备维护->添加设备
手动添加或者通过excel批量导入下面变量
变量名 | 方法 | 地址 | 类型 | 表达式 | 设备名 |
---|---|---|---|---|---|
运行状态 | Read | 1 | uint8 | 模拟设备 | |
设备温度 | Read | 2 | float | 模拟设备 | |
电机转速 | Read | 6 | int16 | raw*0.01 | 模拟设备 |
开始采集
采集配置->设备维护->编辑设备
启动TcpServer
运行你熟悉的TCPServer测试工具,启动端口6666,网关客户端连接后发送响应报文
查看数据
驱动开发实战之TcpClient相关推荐
- 嵌入式linux驱动开发实战教程,嵌入式Linux驱动开发实战视频教程
嵌入式Linux驱动开发实战教程(内核驱动.看门狗技术.触摸屏.视频采集系统) 适合人群:高级 课时数量:109课时 用到技术:嵌入式 Linux 涉及项目:驱动开发.看门狗技术.触摸屏.视频采集 咨 ...
- IMX6ULL驱动开发实战连载-01搭建开发环境
哈喽,大家好.我是小仲.板子在3.31号就收到了,但是,由于最近一直很忙,拖到了现在才开始搭建环境.接下来的一段时间,会基于野火IMX6ULL开发板写一系列教程,主要侧重于驱动和内核的调试技巧.这方面 ...
- Linux驱动开发:字符设备驱动开发实战
Linux驱动开发:字符设备驱动开发实战 一.工程创建 VSCode 创建工程,设置 C/C++ 配置,导入 linux kernel 源码目录,方便 vscode 写代码自动补全,vscode 配置 ...
- 领域驱动设计和开发实战
领域驱动设计和开发实战 http://www.infoq.com/cn/articles/ddd-in-practice
- mini2440 linux移植开发实战指南,Linux-2.6.32.2内核在mini2440上的移植---移植SD卡驱动...
移植环境(红色粗字体字为修改后内容,蓝色粗体字为特别注意内容) 1,主机环境:VMare下CentOS 5.5 ,1G内存. 2,集成开发环境:Elipse IDE 3,编译编译环境:arm-linu ...
- linux驱动开发 - 07_pinctrl 和 gpio 子系统实战
文章目录 1 gpio 子系统 API 函数 2 gpio 相关的 OF 函数 3 程序编写 3.1 修改设备树文件 3.2 添加 LED 设备节点 3.3 LED 灯驱动程序编写 3.4 编写测试 ...
- 《STM32库开发实战指南:基于STM32F103(第2版)》——2.1节仿真器简介
本节书摘来自华章社区<STM32库开发实战指南:基于STM32F103(第2版)>一书中的第2章,第2.1节仿真器简介,作者刘火良 杨森,更多章节内容可以访问云栖社区"华章社区& ...
- 《Linux嵌入式实时应用开发实战(原书第3版)》——3.5 Linux文件系统
本节书摘来自华章计算机<Linux嵌入式实时应用开发实战(原书第3版)>一书中的第3章,第3.5节,作者:(美)Doug Abbott 更多章节内容可以访问云栖社区"华章计算机& ...
- 嵌入式linux驱动开发之点亮led(驱动编程思想之初体验)
这节我们就开始开始进行实战啦!这里顺便说一下啊,出来做开发的基础很重要啊,基础不好,迟早是要恶补的.个人深刻觉得像这种嵌入式的开发对C语言和微机接口与原理是非常依赖的,必须要有深厚的基础才能hold的 ...
最新文章
- C# 入门经典 第三版 下载。
- Python中的map()函数和reduce()函数的用法
- linux 常用命令摘录
- php正则表达式实例详解,正则表达式实例解析
- 两台centos之间免密传输 scp
- Java 并发编程之同步工具类栅栏 CyclicBarrier
- 卸任四家锤子公司法定代表人后:罗永浩退出聊天宝股东行列
- JSP标准标签库、通用标签
- hdoj_1421搬寝室
- Error, some other host already uses address 192.168.0.202错误解决方法
- Security+ 学习笔记10 软件质量保证
- 接口测试之发包工具介绍
- java统计中英文字数 Java问题通用解决代码
- System.Transactions.Diagnostics.DiagnosticTrace 的类型初始值设定项引发异常。配置系统未能初始化
- 锐捷wifi魔盒自动优选服务器,锐捷校园网用python实现自动登录(需要有自己的账号)...
- linux下的二进制文件查看器
- 计算机类中英附录,欧盟gmp附录11-计算机系统(中英文对照)-20210410004737.docx-原创力文档...
- 安卓开发使用ttf文字_Android应用使用自定义字体
- javascript实现繁体简体转换
- 道阻且长,行则将至:搞科研,我们是认真的——数据院四周年系列报道之科研篇...