Java 开发如何通过 IoT 边缘 ModuleSDK 进行协议转换

news2025/7/18 8:57:09

操作场景

使用 ModuleSDK 开发插件应用，接入其他协议设备（如 HTTP 请求数据），将其他协议的数据转化为 MQTT 协议 JSON 数据上报到 IoTDA。

代码解析

项目结构如下

ModbusDriver 代码解析

片段一

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

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

复制代码

片段二

此为模拟 http 请求的代码，随机数模拟设备数采。

    private void startCollection() {
        scheduler.scheduleAtFixedRate(() -> {
            String s = null;
            //todo 采集点位数据，保存到points
            try {
                //1、主动发HTTP请求采集子设备数据
//                s = HttpUtils.doGet("http://127.0.0.1:8080/module/sdk", null);
//                System.out.println(s);
//                Module module = JSON.parseObject(s, Module.class);
                //2、模拟设备数采数据
                 //构造上报参数 设备id.服务id.属性
                Module module = new Module();
                module.setStatus(String.valueOf(Math.random()));
                module.setTemp(String.valueOf(Math.random()));
                points.put("bf40f0c4-4022-41c6-a201-c5133122054a.BasicData.status", module.getStatus());
                points.put("bf40f0c4-4022-41c6-a201-c5133122054a.BasicData.temp", module.getTemp());
            } catch (Exception exception) {
                System.out.println("http请求异常");
            }
            //上报数据
            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": "10.69.33.154:502",
  "devices": [{
    "id": "bf40f0c4-4022-41c6-a201-c5133122054a",
    "product_id": "6247f7e36fe7862a3aa0d803",
    "name": "TEST1",
    "slave_id": 1,
    "services": [{
      "service_id": "BasicData",
      "properties": [{
        "property_name": "status",
        "register_address": 0,
        "data_type": "string"
      },{
        "property_name": "temp",
        "register_address": 1,
        "data_type": "string"
      }]
    }]
  }]
}

复制代码

片段四

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

{
  "bf40f0c4-4022-41c6-a201-c5133122054a": "bf40f0c4-4022-41c6-a201-c5133122054a"
}

复制代码

片段五

平台对部署此应用模块下的设备下发命令后，回调此函数。

    @Override
    public CommandRsp onDeviceCommandCalled(String requestId, Command command) {
        // command json体
        //{
        //    "object_device_id": "bf40f0c4-4022-41c6-a201-c5133122054a", 设备id
        //    "service_id": "BasicData", 模型service_id
        //    "command_name": "Control",  命令下发名称
        //    "paras": {                   命令下发参数
        //    "State": "1"
        //}
        //}
        // 响应示例
        return new CommandRsp(200, "supported ok", null);
    }

复制代码

片段六

平台对部署此应用模块下的设备的影子属性配置后,回调此函数。

    @Override
    public IotResult onDevicePropertiesSet(String requestId, PropsSet propsSet) {
        //propsSet的json结构体
        //    {
        //        "object_device_id": "bf40f0c4-4022-41c6-a201-c5133122054a", 设备id
        //        "services": [
        //        {
        //            "service_id": "$config",  模型service_id
        //            "properties": {
        //            "password": ""            模型属性
        //        }
        //        },
        //        {
        //            "service_id": "BasicData",   模型service_id
        //            "properties": {              模型属性
        //            "status": "123",
        //             "temp": "123"
        //        }
        //        }
        //]
        //    }
        // 响应
        return new IotResult(200, "supported");
    }

复制代码

片段七

子设备收到属性获取的请求后,调用此函数。

设备接入后，可通过 IOTDA 提供的接口触发此函数，请参考IOTDA接口指引。

    @Override
    public PropsGetRsp onDevicePropertiesGet(String requestId, PropsGet propsGet) {
        //propsGet的json结构体
        //{
        //    "objectDeviceId": "bf40f0c4-4022-41c6-a201-c5133122054a",
        //    "serviceId": "BasicData"
        //}
        return new PropsGetRsp();
    }

复制代码

片段八

边缘设备的影子属性配置后,回调此函数。

    @Override
    public void onDeviceShadowReceived(String requestId, ShadowGetRsp shadowGetRsp) {
        //    {
        //        "objectDeviceId": "bf40f0c4-4022-41c6-a201-c5133122054a", 设备id
        //        "shadow": [
        //        {
        //            "desired": {
        //            "eventTime": "2022-05-07T07:44:53Z[UTC]",
        //                "properties": {
        //                "status": "22222222222",             设备影子期望属性
        //                    "temp": "11111111111111"         设备影子期望属性
        //            }
        //        },
        //            "reported": {
        //            "eventTime": "2022-05-07T07:34:15Z[UTC]",
        //                "properties": {
        //                "status": "1595803812",          设备上报属性
        //                    "temp": "-947623559"         设备上报属性
        //            }
        //        },
        //            "serviceId": "BasicData",            模型服务id
        //            "version": 19
        //        }
        //]
        //    }
    }

复制代码

片段九

平台对部署此应用模块下的节点的添加边缘设备后,回调此函数。

注意：

部署边缘设备的模块 id 是集成了 ModuleSDK 应用的模块 ID。

    @Override
    public void onSubDevicesAdded(String eventId, AddSubDevicesEvent addSubDevicesEvent) {
        //  addSubDevicesEvent的json结构体
        //    {
        //        "devices": [
        //        {
        //            "description": "",              描述
        //            "deviceId": "bf40f0c4-4022-41c6-a201-c5133122054a",     设备id
        //            "extensionInfo": {
        //            "module_id": "user_ot_test"       模块id
        //        },
        //            "fwVersion": "",
        //            "name": "TEST1",
        //            "nodeId": "bf40f0c4-4022-41c6-a201-c5133122054a",        设备id
        //            "parentDeviceId": "720259701929160704",  父设备id
        //            "productId": "6247f7e36fe7862a3aa0d803",  模型id
        //            "status": "INACTIVE",              状态
        //            "swVersion": ""
        //        }
        //],
        //        "version": 13
        //    }
        //保存本地设备Id与云端设备Id映射关系
    }

复制代码

片段十

平台对部署此应用模块下的节点的删除边缘设备后,回调此函数。

注意：

部署边缘设备的模块 id 是集成了 ModuleSDK 应用的模块 ID。

    @Override
    public void onSubDevicesDeleted(String eventId, DeleteSubDevicesEvent deleteSubDevicesEvent) {
        // deleteSubDevicesEvent的json结构体
        //    {
        //        "devices": [
        //        {
        //            "description": "",
        //            "deviceId": "bf40f0c4-4022-41c6-a201-c5133122054a",
        //            "fwVersion": "",
        //            "name": "",
        //            "nodeId": "bf40f0c4-4022-41c6-a201-c5133122054a",
        //            "parentDeviceId": "720259701929160704",
        //            "productId": "",
        //            "status": "",
        //            "swVersion": ""
        //        }
        //],
        //        "version": 14
        //    }
    }

复制代码

片段十一

收到获取模型的请求，调用此函数。

    @Override
    public void onGetProductsResponse(String eventId, GetProductsRspEvent response) {
        //使用 driverClient.getProducts()可获得模型数据
        //try {
        //    GetProductsEvent event = new GetProductsEvent();   
        //event.setProductIds(Collections.singletonList("6247f7e36fe7862a3aa0d803"));
        //   driverClient.getProducts("12345", event);
        //} catch (JsonException e) {
        //    log.error("getProducts exception:" + e);
        //}
        // response的json结构体
        //    {
        //        "products": [
        //        {
        //            "dataFormat": "json",
        //            "description": "",
        //            "deviceType": "moduleSDK测试",            模型名字
        //            "industry": "",
        //            "name": "moduleSDK测试",
        //            "productId": "6247f7e36fe7862a3aa0d803",      模型id
        //            "protocolType": "MQTT",
        //            "serviceCapabilities": [
        //            {
        //                "commands": [
        //                {
        //                    "commandName": "Control",    命令名称
        //                    "paras": [                   命令配置
        //                    {
        //                        "dataType": "string",
        //                        "max": "2147483647",
        //                        "maxLength": 200,
        //                        "min": "1",
        //                        "paraName": "State",
        //                        "required": true,
        //                        "step": 0.0,
        //                        "unit": ""
        //                    }
        //                        ]
        //                }
        //                ],
        //                "description": "",
        //                "option": "Optional",
        //                "properties": [                 属性配置
        //                {
        //                    "dataType": "string",
        //                    "maxLength": 50,
        //                    "method": "R",
        //                    "propertyName": "temp",
        //                    "required": false,
        //                    "step": 0.0
        //                },
        //                {
        //                    "dataType": "string",
        //                    "maxLength": 50,
        //                    "method": "RW",
        //                    "propertyName": "status",
        //                    "required": false,
        //                    "step": 0.0
        //                }
        //                ],
        //                "serviceId": "BasicData",
        //                "serviceType": "BasicData"
        //            },
        //            {
        //                "description": "mqtt_config",
        //                "option": "Optional",
        //                "properties": [
        //                {
        //                    "dataType": "string",
        //                    "description": "mqtt设备接入平台密码",
        //                    "max": "32",
        //                    "maxLength": 10240,
        //                    "method": "RW",
        //                    "min": "8",
        //                    "propertyName": "password",
        //                    "required": false,
        //                    "step": 0.0
        //                }
        //                ],
        //                "serviceId": "$config",
        //                "serviceType": "$config"
        //            }
        //        ]
        //        }
        //]
        //    }
    }

复制代码

注册节点

注册节点，请参照注册边缘节点。

设备建模

1.访问IoT边缘，单击“立即使用”进入 IoT 边缘控制台。

2.在左侧导航中选择“设备建模”，单击页面右上角“创建产品”。

3.填写参数信息，如图所示，单击“立即创建”。

4.进入产品详情页，单击“自定义模型”，添加“BasicData”服务 ID，并“确认”。

5.展开服务列表，依次添加“temp”、“status”两个属性。

6.单击添加命令，添加 Control 命令名称。

7.单击新增下发参数，填写对应参数。

说明：

产品 ID、服务 ID、属性名称需要与代码中示例保持一致。

项目打包

打包参考项目打包

将 modbusdriver 进行打包得到 modbusdriver.jar。

制作镜像包

将 jar 文件打包成镜像文件上，请参照制作镜像包或插件包。

dockerfile 内容参照如下（具体可参考编写高效的Dockerfile ）。

FROM registry-cbu.huawei.com/csopenjdk/openjdk

RUN mkdir -p /opt/iot/edge/monitor / && chmod -R 777 /opt/

COPY monitor /opt/iot/edge/monitor

USER root

EXPOSE 8080

CMD ["java", "-jar", "/opt/iot/edge/monitor/monitor-app.jar", "run"]

#构造镜像

#docker build -t edge_monitor:1.0.0 /home --no-cache

#打标签

#docker tag edge_monitor:1.0.0 swr.cn-north-4.myhuaweicloud.com/iot_edge_test/ot_test:v1

#推送

#docker push swr.cn-north-4.myhuaweicloud.com/iot_edge_test/ot_test:v1

#打成镜像包

#docker save swr.cn-north-4.myhuaweicloud.com/iot_edge_test/ot_test:v1 > ot_test.tar

添加应用

以容器镜像方式为例，镜像包上传到容器镜像服务 SWR 后，创建应用。

1.在 IoT 边缘单击创建应用，进入软件部署配置、运行配置，并确认发布。

2.在左侧导航栏，单击“应用管理”，选择“应用名称”进入页面，查看应用为“已发布”状态。

部署应用

部署应用，具体请参考部署应用，进入我们的节点详情页安装应用。

添加边缘设备

1.进入边缘节点概览页，在左侧导航中选择“边缘设备”，单击“添加边缘设备”。

  • 所属产品：选择设备建模中创建的产品

  • 设备标识码：与代码示例保持一致

  • 设备名称：与代码示例保持一致

  • 模块 ID: 与部署应用的模块 id 保持一致

2.单击“确认”，添加设备完成。

启动 HTTP 服务端，进入设备详情页可看到上报的数据。设备状态显示未激活。如需更改可参照集成ModuleSDK后，上报数据成功后，设备状态显示为未激活，如何上报子设备状态？

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

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈，一经查实，立即删除！

相关文章

[附源码]Nodejs计算机毕业设计基于Web课堂签到管理系统Express(程序+LW)

[附源码]Nodejs计算机毕业设计基于Web课堂签到管理系统Express(程序+LW)

该项目含有源码、文档、程序、数据库、配套开发软件、软件安装教程。欢迎交流 项目运行 环境配置&#xff1a; Node.js Vscode Mysql5.7 HBuilderXNavicat11VueExpress。 项目技术&#xff1a; Express框架 Node.js Vue 等等组成&#xff0c;B/S模式 Vscode管理前后端分…
阅读更多...
web开发框可以为提升办公效率赋能吗？

web开发框可以为提升办公效率赋能吗？

提升办公效率可以引用专业的web开发框架&#xff0c;值得一提的是&#xff0c;随着数字化时代的到来&#xff0c;要想做好数据管理&#xff0c;低代码开发平台功不可没&#xff0c;在做好数据管理的过程中发挥了重要的应用价值。研发低代码开发平台&#xff0c;流辰信息一直都以…
阅读更多...
从BI到ABI，守正创新的思迈特软件持续推进国产BI产业创新

从BI到ABI，守正创新的思迈特软件持续推进国产BI产业创新

‍‍数据智能产业创新服务媒体——聚焦数智 改变商业近年来&#xff0c;国内外数字化转型加速渗透&#xff0c;企业客户已不再满足“用上”数据&#xff0c;能否“用好”数据、提升管理效率成为企业数字化转型的核心诉求。在提升企业管理效率的工具中&#xff0c;商业智能&…
阅读更多...
Linux C编程一站式学习笔记1

Linux C编程一站式学习笔记1

Linux C编程一站式学习笔记 chap1程序的基本概念 打算重学计算机&#xff0c;重学C语言 这本书的前言写的真好 实在是惭愧… 文章目录Linux C编程一站式学习笔记 chap1程序的基本概念一.程序和编程语言1.什么是程序2.程序由指令组成3.编程语言编译执行过程解释执行过程本节总结…
阅读更多...
力扣(LeetCode)1697. 检查边长度限制的路径是否存在(C++)

力扣(LeetCode)1697. 检查边长度限制的路径是否存在(C++)

并查集离线查询 由于评测系统对 vectorvectorvector 的排序可能较慢&#xff0c;使用结构体保存 vectorvectorvector &#xff0c;接下来的查询和边集就对结构体操作。 结构体的属性 aaa 点 、 bbb 点 、ccc 长度、 ddd 顺序。重载 <<< &#xff0c;排序时按照 ccc …
阅读更多...
ssm+Vue计算机毕业设计校园图书漂流系统（程序+LW文档）

ssm+Vue计算机毕业设计校园图书漂流系统（程序+LW文档）

ssmVue计算机毕业设计校园图书漂流系统&#xff08;程序LW文档&#xff09; 项目运行 环境配置&#xff1a; Jdk1.8 Tomcat7.0 Mysql HBuilderX&#xff08;Webstorm也行&#xff09; Eclispe&#xff08;IntelliJ IDEA,Eclispe,MyEclispe,Sts都支持&#xff09;。 项目技…
阅读更多...
C++基础篇之什么是 数据结构

C++基础篇之什么是 数据结构

&#x1f4d2;博客主页&#xff1a; ​​开心档博客主页​​ &#x1f389;欢迎关注&#x1f50e;点赞&#x1f44d;收藏⭐留言&#x1f4dd; &#x1f4cc;本文由开心档原创&#xff01; &#x1f4c6;51CTO首发时间&#xff1a;&#x1f334;2022年12月12日&#x1f334; ✉…
阅读更多...
12.1、后渗透测试--提权

12.1、后渗透测试--提权

meterpreter提权方式&#xff1a; getsystem自动提权bypassuac提权migrate1、getsystem自动提权 meterpreter > getsystemgetsystem工作原理&#xff1a;getsystem创建一个新的Windows服务&#xff0c;设置为SYSTEM运行&#xff0c;当它启动时连接到一个命名管道。getsystem…
阅读更多...
Java 线程池详解

Java 线程池详解

线程池&#xff08;thread pool&#xff09;&#xff1a;一种线程使用模式。线程过多会带来调度开销&#xff0c;进而影响缓存局部性和整体性能。而线程池维护着多个线程&#xff0c;对线程统一管理。 使用线程池的优势 提高效率&#xff0c;创建好一定数量的线程放在池中&am…
阅读更多...
技术分享 | 被测系统架构与数据流分析

技术分享 | 被测系统架构与数据流分析

深入了解测试过程中被测系统的架构与数据流&#xff0c;有助于理解业务逻辑&#xff0c;梳理业务用例以及促进部门协同。 更深的理解业务逻辑是指要分析公司是做什么的&#xff0c;公司的重要的商务决策是什么&#xff0c;公司内部数据流是怎么运行的&#xff0c;有哪些常见的…
阅读更多...
数字孪生重点商业实践展示

数字孪生重点商业实践展示

数字孪生是一个系统或一组对象的虚拟表示。数字孪生背后的技术旨在准确反映系统的生命周期和应用程序&#xff0c;并使用机器学习、模拟和人工智能的组合来帮助在现实生活中运行之前对使用、问题或效率进行建模。如今&#xff0c;数字孪生技术的爆火离不开人们对其商业价值的看…
阅读更多...
[C语言]指针进阶

[C语言]指针进阶

[C语言]指针进阶 文章目录[C语言]指针进阶1.字符指针&#xff1a;2.指针数组&#xff1a;3.数组指针&#xff1a;4.&数组名VS数组名:5.数组指针的使用:6.数组参数、指针参数:6.1一维数组传参:6.2二维数组传参:6.3一级指针传参:6.4二级指针传参:7.函数指针:7.1如何保存函数的…
阅读更多...
Ubuntu20.04下notify-send和cron结合使用

Ubuntu20.04下notify-send和cron结合使用

问题背景 今天学到一个Linux下一个很有趣的弹窗通知组件&#xff0c;名字叫notify-send&#xff0c;可以用如下方式简单调用。 notify-send hello-world可以立马看到效果。 不仅如此&#xff0c;他的图标、文字的样式等都可以定制&#xff0c;如&#xff1a; notify-send -u…
阅读更多...
Python 编程的入门不二之选——Python编程：从入门到实践

Python 编程的入门不二之选——Python编程：从入门到实践

最好的Python入门教材 你好&#xff0c;我是小雨青年&#xff0c;一名程序员。 今天我为你推荐一本Python入门级书籍——《Python编程&#xff1a;从入门到实践》&#xff08;第二版&#xff09;。 Python 是一种流行的、适用于各种领域的编程语言。对于初学者来说&#xff…
阅读更多...
新来了个同事，设计模式用的是真优雅呀，代码如诗

新来了个同事，设计模式用的是真优雅呀，代码如诗

之前有小伙伴私信我说看源码的时候感觉源码很难&#xff0c;不知道该怎么看&#xff0c;其实这有部分原因是因为没有弄懂一些源码实现的套路&#xff0c;也就是设计模式&#xff0c;所以本文我就总结了9种在源码中非常常见的设计模式&#xff0c;并列举了很多源码的实现例子&am…
阅读更多...
十二月十三号作业驱动作业

十二月十三号作业驱动作业

成功移植内核源码 开发板可以挂在linux操作系统 添加led驱动到内核源码drivers/char目录下 打开linux内核源码进入drivers/char目录下打开Kconfig文件&#xff0c;对Kconfig文件进行分析 vi Kconfig 2.添加自己的LED灯驱动程序选项 10 config LED_DRIVER …
阅读更多...
[C语言]指针初阶

[C语言]指针初阶

[C语言]指针初阶 文章目录[C语言]指针初阶1.指针def:2.指针变量&#xff1a;3.指针和内存的关系&#xff1a;4.指针和指针类型:4.1指针类型&#xff1a;5.指针-整数:6.指针的解引用:7.野指针&#xff1a;7.1成因&#xff1a;7.2如何规避野指针:8.指针运算:8.1指针-整数&#xf…
阅读更多...
C++11 多线程编程

C++11 多线程编程

因为之前有学习过c11的并发库&#xff0c;最近在搞项目准备复习&#xff0c;本节开始就重温一下这块内容打算连着写上几篇博客去记录一下.. 题外话get几个概念 1.进程是资源分配的基本单位&#xff0c;线程是调度的基本单位&#xff0c;注意基本二字&#xff0c;这并不意味着进…
阅读更多...
jdk8-获取本机ip、判断ip范围、ip与long互转等

jdk8-获取本机ip、判断ip范围、ip与long互转等

在配置nginx的ip白名单时候&#xff0c;会通过ip段进行配置&#xff08;如 10.10.10.10/24&#xff09;,就在思考这种配置怎么通过代码解析并判断&#xff0c;故通过搜索网络内容&#xff0c;并通过java编写测试代码。代码及说明来源网络&#xff0c;并进行了部分调整。故有疑问…
阅读更多...
谷歌神秘项目曝光，能写代码还会改bug的AI，这。。。。

谷歌神秘项目曝光，能写代码还会改bug的AI，这。。。。

做一个程序员&#xff0c;压力有多大&#xff1f;反正&#xff0c;最近的一个传闻&#xff0c;是让码农们瑟瑟发抖...... 传说谷歌正在研发一个秘密的新项目&#xff0c;教AI写代码。据说&#xff0c;学会之后&#xff0c;AI不仅能写代码&#xff0c;还会修复bug。 写代码这件…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023