--- sidebar_position: 2 title: tcpclient demo --- ## 场景模拟 假设你有一批非标设备需要对接，对方提供了如下协议文档： ### 协议概述 > 设备作为**tcpserver**，端口**6666** > 字节序:**little-endian**，即低地址存放低位 ### 请求回复 > 需要你主动发起读取**请求**:**0x01 02 03 04** > 设备**回复**:**0x08 01 41 d6 3d 71 1a 20** ### 参数说明 1. **总字节数** > (*byte[0]*)即0x08:用于简单的校验 2. **运行状态** > (*byte[1]*)即0x01:1为运行;其他为停止 3. **设备温度** > (*byte[2]-byte[5]*)即0x41 d6 3d 71：单精度浮点数值26.78 4. **电机转速** > (*byte[6]-byte[7]*)即0x1a 20：对应16进制无符号整型，倍率0.01值66.88 ## 驱动开发 我们根据上面的协议，开发驱动。请先浏览上一篇**驱动简介** ### 创建驱动项目 1. 在亚博平台下载的解决方案->drivers文件夹，右键添加->新建项目->c#类库  2. 项目名**driversimtcpclient**，放在```iotgateway\plugins\drivers```路径下  3. 修改*class1*为*simtcpclient* 4. 双击项目，修改配置  ```xml title="iotgateway\plugins\drivers\driversimtcpclient\driversimtcpclient.csproj" net6.0 ../../../iotgateway/bin/debug/net6.0/drivers true enable enable ``` :::info 说明 > outputpath节点指定了生成项目的文件夹 > > *simpletcp.core*是一个tcp客户端库(你也可以自己写) > > projectreference节点引用了*plugininterface*项目 > > copylocallockfileassemblies节点可以确保你引用的nuget拷贝到driver文件夹下 ::: ### 编写项目代码 ``` csharp title="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 { /// /// tcp客户端 /// private simpletcpclient? client; /// /// 缓存最新的服务器返回的原始数据 /// 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; /// /// 为了演示枚举类型在web端的录入，这里没用到 但是你可以拿到 /// [configparameter("连接类型")] public connectiontype connectiontype { get; set; } = connectiontype.long; [configparameter("超时时间ms")] public int timeout { get; set; } = 300; [configparameter("最小通讯周期ms")] public uint minperiod { get; set; } = 3000; #endregion public simtcpclient(guid deviceid) { deviceid = deviceid; } /// /// 判断连接状态 /// public bool isconnected { get { //客户端对象不为空并且客户端已连接则返回true return client != null && client.tcpclient.connected; } } /// /// 进行连接 /// /// 连接是否成功 public bool connect() { try { //进行连接 client = new simpletcpclient().connect(ipaddress, port); client.datareceived = client_datareceived; } catch (exception) { return false; } return isconnected; } /// /// 收到服务端数据 /// /// /// private void client_datareceived(object? sender, message e) { //如果收到的数据校验正确，则放在内存中 if (e.data.length == 8 && e.data[0] == 0x08) latestrcvdata = e.data; } /// /// 断开连接 /// /// 断开是否成功 public bool close() { try { client.datareceived -= client_datareceived; //断开连接 client?.disconnect(); return !isconnected; } catch (exception) { return false; } } /// /// 释放 /// public void dispose() { try { //释放资源 client?.dispose(); } catch (exception) { } } /// /// 发送数据 /// private byte[] sendcmd = new byte[4] { 0x01, 0x02, 0x03, 0x04 }; /// /// 解析并返回 /// /// ioarg.address为起始变量字节编号;ioarg.valuetype为类型 /// [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 writeasync(string requestid, string method, driveraddressioargmodel ioarg) { rpcresponse rpcresponse = new() { issuccess = false, description = "设备驱动内未实现写入功能" }; return rpcresponse; } } public enum connectiontype { long, short } } ``` ### 注册驱动 1. 生成```driversimtcpclient ```项目 > ```iotgateway\iotgateway\bin\debug\net6.0\drivers\net6.0```路径下可以看到生成了*driversimtcpclient.dll* 2. 运行iotgateway，访问本地518端口 3. 添加驱动 > 网关配置->驱动管理->添加  :::warning 注意 > 添加驱动后需要重启一下项目，后面会优化 ::: ### 创建设备 1. 采集配置->设备维护->添加设备  ### 添加变量 1. 采集配置->设备维护->添加设备 > 手动添加或者通过excel批量导入下面变量 | 变量名 | 方法 | 地址 | 类型 | 表达式 | 设备名 | | ------- | ----- | ----- | ----| ------ | ------ | | 运行状态 | read | 1 |uint8 | |模拟设备 | | 设备温度 | read | 2 |float | |模拟设备 | | 电机转速 | read | 6 |int16 |raw*0.01 |模拟设备 | ## 开始采集 采集配置->设备维护->编辑设备  ## 启动tcpserver 运行你熟悉的tcpserver测试工具，启动端口6666，网关客户端连接后发送响应报文  ## 查看数据