ThingsBoard Edge 设备控制

news2025/1/11 7:06:15

文章目录

    • 一、RPC 功能
      • 1.服务端 RPC
      • 2.客户端 RPC
      • 3.MQTT RPC API
        • 3.1.服务端RPC
        • 3.2.客户端RPC
    • 二、设备控制
      • 1.环境准备
      • 2.创建设备
      • 3.服务端PRC
        • 3.1.RPC消息主题
        • 3.2.程序源码
        • 3.3.创建仪表板
        • 3.4.边缘分配仪表板
        • 3.5.测试
      • 4.客户端RPC
        • 4.1.RPC消息主题
        • 4.2.程序源码
        • 4.3.规则链
        • 4.4.测试

  • ThingsBoard
# ThingsBoard

https://iothub.org.cn/docs/iot/
https://iothub.org.cn/docs/iot/tb-edge/edge-rpc/

一、RPC 功能

1.服务端 RPC

服务端 RPC 分：单向 RPC、双向 RPC。

服务端 RPC 调用可以分为单向和双向：

  • 单向 RPC 请求直接发送请求，并且不对设备响应做任何处理。

    在这里插入图片描述

  • 双向 RPC 请求会发送到设备，并且超时期间内接收到来自设备的响应。

    在这里插入图片描述

2.客户端 RPC

客户端 RPC 从设备端发送到平台
在这里插入图片描述

3.MQTT RPC API

3.1.服务端RPC

客户端订阅服务端RPC命令必须SUBSCRIBE消息发送下面主题：

v1/devices/me/rpc/request/+

订阅后客户端会收到一条命令作为对相应主题的PUBLISH命令：

v1/devices/me/rpc/request/$request_id

$request_id表示请求的整型标识符。

客户端PUBLISH下面主题进行响应：

v1/devices/me/rpc/response/$request_id
3.2.客户端RPC

将RPC命令发送到服务端必须PUBLISH消息发送到下面主题：

v1/devices/me/rpc/request/$request_id

$request_id表示请求的整型标识符服务端必须发布到下面主题：

v1/devices/me/rpc/response/$request_id

二、设备控制

1.环境准备

  1. 创建测试设备 edge-device
  2. 创建测试工程 tb-rpc

1.程序配置

mqtt:
  broker-url: tcp://192.168.202.166:1883
  client-id: emq-client-rpc
  username: lMrdczEw1rJHhBejzumZ
  password:

2.创建设备

在 ThingsBoard 服务端创建设备配置 test-edge

在 Edge 端创建设备 edge-device
在这里插入图片描述
在这里插入图片描述
在这里插入图片描述

在服务端查看设备
在这里插入图片描述

# 访问令牌
lMrdczEw1rJHhBejzumZ

3.服务端PRC

3.1.RPC消息主题

客户端订阅服务端RPC命令必须SUBSCRIBE消息发送下面主题：

v1/devices/me/rpc/request/+

订阅后客户端会收到一条命令作为对相应主题的PUBLISH命令：

v1/devices/me/rpc/request/$request_id

$request_id表示请求的整型标识符。

客户端PUBLISH下面主题进行响应：

v1/devices/me/rpc/response/$request_id
3.2.程序源码

ServerRpc

@Component
public class ServerRpc {


    @Autowired
    private EmqClient emqClient;

    @Autowired
    private MqttProperties properties;


    @PostConstruct
    public void init(){
        //连接服务端
        emqClient.connect(properties.getUsername(),properties.getPassword());
        //订阅一个主题
        emqClient.subscribe("v1/devices/me/rpc/request/+", QosEnum.QoS1);
    }
    
}

MessageCallback

@Component
public class MessageCallback implements MqttCallback {
    
    
    /**
     * 应用收到消息后触发的回调
     * @param topic
     * @param message
     * @throws Exception
     */
    @Override
    public void messageArrived(String topic, MqttMessage message) throws Exception {
        log.info("订阅者订阅到了消息,topic={},messageid={},qos={},payload={}",
                topic,
                message.getId(),
                message.getQos(),
                new String(message.getPayload()));

        // 订阅者订阅到了消息,topic=v1/devices/me/rpc/request/7,messageid=6,qos=1,payload={"method":"setValue","params":false}
        // 订阅后客户端会收到一条命令作为对相应主题的PUBLISH命令：
        // v1/devices/me/rpc/request/$request_id
        String[] buff = topic.split("/");
        String request_id = buff[buff.length-1];


        // 客户端PUBLISH下面主题进行响应：
        // v1/devices/me/rpc/response/$request_id
        emqClient.publish("v1/devices/me/rpc/response/" + request_id, "{}", QosEnum.QoS1,false);

    }
3.3.创建仪表板
  • 在服务端创建仪表板
    在这里插入图片描述
    在这里插入图片描述
    在这里插入图片描述
    在这里插入图片描述
3.4.边缘分配仪表板

  • 在服务端给 Edge 分配仪表板
    在这里插入图片描述
    在这里插入图片描述
    在这里插入图片描述

  • 在 Edge 端查看仪表板
    在这里插入图片描述
    在这里插入图片描述

3.5.测试
  • 在 Edge 端发送 RPC 命令
    在这里插入图片描述
    在这里插入图片描述
2023-08-20 16:35:34.249  INFO 21332 --- [emq-client-2222] com.iiotos.mqtt.MessageCallback          : 订阅者订阅到了消息,topic=v1/devices/me/rpc/request/15,messageid=1,qos=1,payload={"method":"setValue","params":false}

2023-08-20 16:35:34.252  INFO 21332 --- [emq-client-2222] com.iiotos.mqtt.MessageCallback          : 消息发布完成,messageid=2,topics=[v1/devices/me/rpc/response/15]

4.客户端RPC

4.1.RPC消息主题

将RPC命令发送到服务端必须PUBLISH消息发送到下面主题：

v1/devices/me/rpc/request/$request_id

$request_id表示请求的整型标识符服务端必须发布到下面主题：

v1/devices/me/rpc/response/$request_id

请求参数

{"method": "getServerValue", "params": ""}
4.2.程序源码

ClientRpc

package com.iiotos.rpc;


import com.iiotos.mqtt.EmqClient;
import com.iiotos.mqtt.MqttProperties;
import com.iiotos.mqtt.QosEnum;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component;

import javax.annotation.PostConstruct;


@Component
public class ClientRpc {


    @Autowired
    private EmqClient emqClient;

    @Autowired
    private MqttProperties properties;


    @PostConstruct
    public void init(){
        //连接服务端
        emqClient.connect(properties.getUsername(),properties.getPassword());
        //订阅一个主题
        emqClient.subscribe("v1/devices/me/rpc/response/+", QosEnum.QoS1);

    }


    @Scheduled(fixedRate = 3000)
    public void publish(){

        String data = getData();

        emqClient.publish("v1/devices/me/rpc/request/1",data,QosEnum.QoS1,false);
    }

    
    private String getData(){

        String data = "{\n" +
                "\t\"method\": \"getServerValue\",\n" +
                "\t\"params\": \"\"\n" +
                "}";

        return data;

    }

}
4.3.规则链
  • 在服务端创建规则链
    在这里插入图片描述
    在这里插入图片描述
msg.result='server receive rpc requuest!!!'
return { msg: msg, metadata: metadata, msgType: msgType };

在这里插入图片描述

  • 在 Edge 端 查看规则链
    在这里插入图片描述
4.4.测试

在这里插入图片描述

2023-08-20 17:46:46.216  INFO 20548 --- [emq-client-2222] com.iiotos.mqtt.MessageCallback          : 消息发布完成,messageid=7,topics=[v1/devices/me/rpc/request/1]


2023-08-20 17:46:46.269  INFO 20548 --- [emq-client-2222] com.iiotos.mqtt.MessageCallback          : 订阅者订阅到了消息,topic=v1/devices/me/rpc/response/1,messageid=6,qos=1,payload={"method":"getServerValue","params":"","result":"server receive rpc requuest!!!"}
  • ThingsBoard
# ThingsBoard

https://iothub.org.cn/docs/iot/
https://iothub.org.cn/docs/iot/tb-edge/edge-rpc/

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

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

相关文章

Selenium-webdriver_manager判断是否已经下载过驱动（复用缓存驱动）

Selenium-webdriver_manager判断是否已经下载过驱动（复用缓存驱动）

1,谷歌浏览器默认位置 2，ChromeDriverManager 下载的驱动位置 其中admin为机器的用户名 def installDriver(self):"""判断是否需要下载driver""""""找到本机谷歌浏览器版本""""""C:\P…
阅读更多...
软考81-上午题-【面向对象技术3-设计模式】-行为型设计模式01

软考81-上午题-【面向对象技术3-设计模式】-行为型设计模式01

一、行为型设计模式一览 二、责任链模式 2-1、意图 使多个对象都有机会处理请求，从而避免请求的发送者和接收者之间的耦合关系。将这些对象连成一条链，并沿着这条链传递该请求，直到有一个对象处理它为止。 1-2、结构 1-3、代码实现 1-4、适…
阅读更多...
Kubectl常用命令

Kubectl常用命令

管理资源（查看、创建、更新、删除） 查看node资源 kubectl get nodes查看命名空间 kubectl get ns查看service资源 -n 指明所属的命名空间，不写默认看命名空间为default下的所有service kubectl get svc -n default查看pod资源 -n 指明所…
阅读更多...
万界星空科技商业开源MES,技术支持+项目合作

万界星空科技商业开源MES,技术支持+项目合作

商业开源的一套超有价值的JAVA制造执行MES系统源码 亲测 带本地部署搭建教程 教你如何在本地运行运行起来。 开发环境：jdk11tomcatmysql8springbootmaven 可以免费使用，需要源码价格便宜，私信我获取。 一、系统概述： MES制造执…
阅读更多...
网络安全实训Day5

网络安全实训Day5

写在前面 昨天忘更新了......讲的内容不多，就一个NAT。 之前记的NAT的内容：blog.csdn.net/Yisitelz/article/details/131840119 网络安全实训-网络工程 NAT 公网地址与私网地址 公网地址 可以在互联网上被寻址，由运营商统一分配全球唯一的I…
阅读更多...
Coursera上Golang专项课程2：Functions, Methods, and Interfaces in Go 学习笔记

Coursera上Golang专项课程2：Functions, Methods, and Interfaces in Go 学习笔记

Functions, Methods, and Interfaces in Go Course Certificate 本文是学习 Functions, Methods, and Interfaces in Go 这门课的学习笔记，如有侵权，请联系删除。 文章目录 Functions, Methods, and Interfaces in GoMODULE 1: FUNCTIONS AND ORGANIZ…
阅读更多...
云原生部署手册02：将本地应用部署至k8s集群

云原生部署手册02：将本地应用部署至k8s集群

（一）部署集群镜像仓库 1. 集群配置 首先看一下集群配置： (base) ➜ ~ multipass ls Name State IPv4 Image master Running 192.168.64.5 Ubuntu 22.04 LTS1…
阅读更多...
多进程数据库不适合作为hive的元数据库

多进程数据库不适合作为hive的元数据库

简介 “今天发现一个比较奇怪的现象，因为博主不熟悉mysql，所以在安装hive的使用了postgresql作为hive的元数据库，在测试几个连接工具对hive进行链接，后面再测试的时候发现链接不上了，并且报错日志如下：” …
阅读更多...
利用生成式人工智能进行功能管理测试

利用生成式人工智能进行功能管理测试

就 DevOps 而言，生成式 AI与功能管理测试的新兴集成标志着一次重大演变。我们将认真研究这项技术如何彻底改变我们创建测试环境的方式。 使用人工智能生成测试使我们能够模拟大量的用户场景和环境，这意味着我们可以开发和部署不仅好而且很棒的功能&…
阅读更多...
django实现api接口

django实现api接口

（前期准备）第一步：虚拟环境 在windows上使用virtualenvwrapper。 pip install virtualenvwrapper-win 接着，添加环境变量。 echo %WORKON_HOME% 接下来就是创建虚拟环境，假如创建myenv mkvirtualenv myenv 进入…
阅读更多...
线程的基本使用

线程的基本使用

线程 使用线程方法 继承Thread类，重写run方法实现Runnable接口，重写run方法 继承Thread vs 实现Runnable的区别 从java的设计来看，通过继承Thread或者实现Runnable接口来创建线程本质上没有区别,从jdk帮助文档可以看到Thread类本身就实现…
阅读更多...
如何在不带备份的情况下恢复 Android 手机照片？

如何在不带备份的情况下恢复 Android 手机照片？

你的 Android 手机出了什么问题？ Android 手机上的垃圾文件过多。 您的 Android 手机屏幕黑屏。 您的手机蓝屏死机。 您的设备卡在启动屏幕上。 电话停止工作。 手机一直关机。 ... 您是否遇到过以上情况并将您的 Android 手机恢复出厂设置？如果是这样&…
阅读更多...
最后的挣扎 - Qt For Android on HuaWei Mate 60Pro (v4.0.0)

最后的挣扎 - Qt For Android on HuaWei Mate 60Pro (v4.0.0)

简介 为什么叫最后的挣扎, 其实都知道即将到来的 HarmonyOS NEXT 将抛弃Android支持，纯血HarmonyOS 将上线， 此时再说Qt for android支持Huawei HarmonyOS的设备其实并没有多少意思， 但恐怕在大多数基础软件完成兼容前， 很多人还是…
阅读更多...
【Godot 4.2】常见几何图形、网格、刻度线点求取函数及原理总结

【Godot 4.2】常见几何图形、网格、刻度线点求取函数及原理总结

概述 本篇为ShapePoints静态函数库的补充和辅助文档。ShapePoints函数库是一个用于生成常见几何图形顶点数据（PackedVector2Array）的静态函数库。生成的数据可用于_draw和Line2D、Polygon2D等进行绘制和显示。因为不断地持续扩展，ShapePoint…
阅读更多...
定位及解决OOM

定位及解决OOM

一、定义 内存溢出：OutOfMemoryError，是指因内存不够，导致操作新对象没有剩余空间。会导致频繁fullgc出现STW从而导致性能下降。 内存泄漏：指用malloc或new申请了一块内存，但是没有通过free或delete将内存释放&#…
阅读更多...
cmd常用指令

cmd常用指令

cmd全称Command Prompt，中文译为命令提示符。 命令提示符是在操作系统中，提示进行命令输入的一种工作提示符。 在不同的操作系统环境下，命令提示符各不相同。 在windows环境下，命令行程序为cmd.exe，是一个32位的命令…
阅读更多...
全域电商数据API接口采集突破堆人头的方式的数据采集实现高效稳定大批量的电商商品数据采集

全域电商数据API接口采集突破堆人头的方式的数据采集实现高效稳定大批量的电商商品数据采集

全域电商，是近几年的新趋势，几乎所有商家都在布局全域，追求全域增长。但商家发现，随着投入成本的上涨，利润却没有增加。 其中最为突出的是——商家为保证全域数据的及时更新，通过堆人头的方式完成每日取数…
阅读更多...
vulhub中GitLab 任意文件读取漏洞复现（CVE-2016-9086）

vulhub中GitLab 任意文件读取漏洞复现（CVE-2016-9086）

GitLab是一款Ruby开发的Git项目管理平台。在8.9版本后添加的“导出、导入项目”功能，因为没有处理好压缩包中的软连接，已登录用户可以利用这个功能读取服务器上的任意文件。 环境运行后，访问http://your-ip:8080即可查看GitLab主页&#xff0…
阅读更多...
cartographer学习与使用

cartographer学习与使用

记录一下在配置和使用cartographer建图时遇到的各种问题吧。 我的数据 配置文件&#xff1a; my_rslidar.launch <launch> <param name"/use_sim_time" value"false" /> <!--启动建图节点--> <node name"cartographer_n…
阅读更多...
设计模式学习笔记 - 设计原则与思想总结：1.总结回顾面向对象、设计原则、编程规范、重构技巧等知识点

设计模式学习笔记 - 设计原则与思想总结：1.总结回顾面向对象、设计原则、编程规范、重构技巧等知识点

概述 对前面的内容的回顾&#xff0c;温故而知新&#xff0c;包括&#xff1a;面向对象、设计原则、规范与重构三个模块的内容。 1.代码质量评判标准 如何评价代码质量的高低&#xff1f; 代码质量的评价具有很强的主观性&#xff0c;描述代码质量的词汇也有很多&#xff0c…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023