代码解析

更新时间：2024-07-01 GMT+08:00

项目结构如下

点击放大

表1 类相关说明
类名称	描述
Device	设备类，包含设备的id，产品id，slaveId及能力定义。
Main	主启动类。
ModbusCfg	modbus配置。
ModbusDriver	业务主体类，该类含边侧设备添加，设备同步，数据收集及上报等演示。
Property	设备属性。
Service	设备能力。

ModbusDriver代码解析

片段一

通过DriverClient.createFromEnv初始化客户端，调用driverClient来完成数据的发送。

   
          public ModbusDriver() throws GeneraException {
        driverClient = DriverClient.createFromEnv();
    }

    public void start() throws Exception {
        //设置回调，打开客户端
        driverClient.setGatewayCallback(this);
        driverClient.open();
        loadConfig();
        startCollection();
    }

片段二

此为从变量points中获取设备数采结果，进行设备数据上报。

   
    
      
          private void startCollection() {
    scheduler.scheduleAtFixedRate(new Runnable() {
        @Override
        public void run() {
            //todo 采集modbus点位数据，保存到points

            //上报数据
            List<DeviceService> devices = new LinkedList<>();
            for (Device device : modbusCfg.getDevices()) {
                List<ServiceData> services = new LinkedList<>();
                for (Service service : device.getServices()) {
                    Map<String, Object> properties = new HashMap<>();
                    for (Property property : service.getProperties()) {
                        String key = device.getId() + "." + service.getServiceId() + "." + property.getPropertyName();
                        properties.put(property.getPropertyName(), points.get(key));
                    }
                    services.add(new ServiceData(service.getServiceId(), properties, ZonedDateTime.now()));
                }
                String deviceId = deviceIds.get(device.getId());
                if (deviceId != null) {
                    devices.add(new DeviceService(deviceId, services));
                }
            }
            try {
                driverClient.reportSubDevicesProperties(new SubDevicesPropsReport(devices));
            } catch (Exception e) {
                System.out.println(e.getMessage());
            }
        }
    }, 0, modbusCfg.getPeriod(), TimeUnit.SECONDS);

}

     

   
  

片段三

查看“modbus.json”文件，点位上报数据关系对应：设备id.模型id.服务id.属性名；设备id需要与添加边缘设备时设置的“设备标识码”一致。

{
  "period": 10,
  "server": "192.168.1.2:502",
  "devices": [{
    "id": "8616ac9b-1e66-4fbf-8871-1ca4cb7103fc",
    "product_id": "c6b39067b0325db34663d3ef421a42f6",
    "name": "light_1",
    "slave_id": 1,
    "services": [{
      "service_id": "light",
      "properties": [{
        "property_name": "switch",
        "register_address": 1234,
        "data_type": "bool"
      }]
    }]
  }, {
    "id": "c1ae5e25-23c6-4e01-b64f-7b00b4066667",
    "product_id": "c6b39067b0325db34663d3ef421a42f6",
    "name": "light_2",
    "slave_id": 2,
    "services": [{
      "service_id": "light",
      "properties": [{
        "property_name": "switch",
        "register_address": 5678,
        "data_type": "bool"
      }]
    }]
  }]
}

片段四

查看“device_ids.json”文件，设备id需要与添加边缘设备时设置的“设备标识码”一致。

{
  "8616ac9b-1e66-4fbf-8871-1ca4cb7103fc": "bf40f0c4-4022-41c6-a201-c5133122054a"
}

父主题： 集成ModuleSDK进行协议转换

上一篇：操作场景

下一篇：注册节点

意见反馈

文档内容是否对您有帮助？

有帮助没帮助

提供反馈

提交成功！非常感谢您的反馈，我们会继续努力做到更好！您可在我的云声建议查看反馈及问题处理状态。

系统繁忙，请稍后重试

在使用文档中是否遇到以下问题

内容与产品页面不一致

内容不易理解

缺失示例代码

步骤不可操作

搜不到想要的内容

缺少最佳实践

意见反馈（选填）

0/500

请至少选择一项反馈信息并填写问题反馈

字符长度不能超过500

直接提交取消

如您有其它疑问，您也可以通过华为云社区问答频道来与我们联系探讨

智能客服提问云社区提问

代码解析

相关文档

意见反馈

文档内容是否对您有帮助？

7*24

备案

专业服务

退订

建议反馈

售前咨询热线

文档反馈