ThingsBoard Edge 设备控制

文章目录

    • 一、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/

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

如若内容造成侵权/违法违规/事实不符，请联系我们进行投诉反馈qq邮箱809451989@qq.com，一经查实，立即删除！

相关文章

十四、GPT

十四、GPT

在GPT-1之前，传统的 NLP 模型往往使用大量的数据对有监督的模型进行任务相关的模型训练，但是这种有监督学习的任务存在两个缺点：预训练语言模型之GPT 需要大量的标注数据，高质量的标注数据往往很难获得，因为在很多任务…
阅读更多...
Qt for Mac阻止MacOS系统休眠

Qt for Mac阻止MacOS系统休眠

Qt开发的应用程序如果电脑休眠了会影响软件的使用，因此在软件的使用过程中需要防止电脑休眠，在Win上有专门的API进行处理，在Mac上也必需使用Mac平台自身的API，本篇介绍在Mac平台下使用Qt阻止Mac系统休眠。 要调用Mac系统的API&am…
阅读更多...
vulhub中GitLab 任意文件读取漏洞复现（CVE-2016-9086）

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

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

PC电脑如何使用HDMI连接小米电视当显示屏

使用HDMI连接好当时和电脑，HDMI2.0会更清晰；小米电视会自动弹窗提示你有HDMI 接口连接，或者你进入信号源进行选择即可；需要平时我们电脑的显示器正常连接，然后按 win p ，选择 扩展 屏幕； 进入设…
阅读更多...
27-2 文件上传漏洞 - 前端绕过

27-2 文件上传漏洞 - 前端绕过

环境准备：构建完善的安全渗透测试环境：推荐工具、资源和下载链接_渗透测试靶机下载-CSDN博客 前端绕过思路 - 禁用 JavaScript: 背景： 当前开发行业大多采用前后端分离模式，后端使用多种开发语言如 PHP、Java 等，而前端主要使用 JavaScript（JS）。因此，禁用 JavaScrip…
阅读更多...
开设新量子计算中心！IonQ 全力加速量子商业化

开设新量子计算中心！IonQ 全力加速量子商业化

内容来源：量子前哨（ID：Qforepost） 编辑丨慕一 编译/排版丨浪味仙 沛贤 深度好文：1000字丨8分钟阅读 近日，量子计算公司IonQ对外宣布，将在华盛顿开设一家新量子中心。公告里还提出&#xff0c…
阅读更多...
html5黑色大气的个人博客全屏滚动个人主页源码HTML+JS+CSS

html5黑色大气的个人博客全屏滚动个人主页源码HTML+JS+CSS

html5黑色大气的个人博客全屏滚动个人主页源码HTMLJSCSS
阅读更多...
软件测试 自动化测试selenium 基础篇

软件测试 自动化测试selenium 基础篇

文章目录 1. 什么是自动化测试？1.1 自动化分类 2. 什么是 Selenium ？3. 为什么使用 Selenium ？4. Selenium 工作原理5. Selenium 环境搭建 1. 什么是自动化测试？ 将人工要做的测试工作进行转换，让代码去执行测试工作 …
阅读更多...
【Frida】04_Frida中使用TypeScript脚本（采坑）

【Frida】04_Frida中使用TypeScript脚本（采坑）

▒ 目录 ▒ 🛫 导读需求开发环境演示目标 1️⃣ 操作步骤安装node 20.10.0在 VSCode 中打开项目目录初始化一个 NodeJS 项目安装 TypeScript初始化 TypeScript 项目安装依赖配置 TypeScript编写代码编译设置编译脚本运行，查看结果 2️⃣ 采坑frida-compi…
阅读更多...
旧华硕电脑开机非常慢 电脑开机黑屏很久才显示品牌logo导致整体开机速度非常的慢怎么办

旧华硕电脑开机非常慢 电脑开机黑屏很久才显示品牌logo导致整体开机速度非常的慢怎么办

前提条件 电池需要20％（就是电池没有报废）且电脑接好电源，千万别断电，电脑会变成砖头的 解决办法 更新bios即可解决，去对应品牌官网下载最新的bios版本就行了 网上都是一些更新驱动啊
阅读更多...
深度学习 精选笔记（12）卷积神经网络-理论基础1

深度学习 精选笔记（12）卷积神经网络-理论基础1

学习参考： 动手学深度学习2.0Deep-Learning-with-TensorFlow-bookpytorchlightning ①如有冒犯、请联系侵删。 ②已写完的笔记文章会不定时一直修订修改(删、改、增)，以达到集多方教程的精华于一文的目的。 ③非常推荐上面（学习参考&#x…
阅读更多...
JS原型和原型链的理解

JS原型和原型链的理解

原型链图，图中Parent是构造函数，p1是通过Parent实例化出来的一个对象 前置知识 js中对象和函数的关系，函数其实是对象的一种 函数、构造函数的区别，任何函数都可以作为构造函数，但是并不能将任意函数叫做构造函数&…
阅读更多...
【Godot4.2】颜色完全使用手册

【Godot4.2】颜色完全使用手册

概述 本篇简单汇总Godot中的颜色的构造和使用，内容包括了： RGB、RGBA，HSV以及HTML16进制颜色值、颜色常量等形式构造颜色颜色的运算以及取反、插值用类型化数组、紧缩数组或PNG图片形式存储多个颜色 构造颜色 因为颜色是一种视觉元素&…
阅读更多...
Vue中使用Lodash

Vue中使用Lodash

Vue中使用Lodash 前言安装Lodash引用方法vue中使用1、cloneDeep 深拷贝2、uniq 数组去重3、uniqWith 数组对象去重 isEqual 深度比对4、intersection 提取数组相同元素5、chunk 数组切分6、compact去除假值7、reject:根据条件删除指定的值8、find:查找结果的第一个值9、filter：…
阅读更多...
VsCode 配置go开发环境之下载go tools

VsCode 配置go开发环境之下载go tools

ctrl shift P 选择 go install/update tools，下载go tools 报错， 提升dial err。 将GOPROXY 和 GOSUMDB 按照如下配置，重启IDE即可成功下载 set GOPROXYhttps://goproxy.cn set GOSUMDBoff
阅读更多...
(18)C#采集微信群群成员列表信息-微信UI自动化(.Net)

(18)C#采集微信群群成员列表信息-微信UI自动化(.Net)

往期知识回顾 (1)C#开启探索微信自动化之路-微信UI自动化 (2)C#创建微信窗体自动化实例-微信UI自动化 (3)C#针对系统热键管理-微信UI自动化 (4)C#采集微信通讯录和联系人-微信UI自动化 (5)C#实现针对微信窗体鼠标静默点击-微信UI自动化 (6)C#搜索微信通讯录联系人-微信UI…
阅读更多...
什么是API安全性以及为什么它很重要？

什么是API安全性以及为什么它很重要？

API指的是应用程序接口（Application Programming Interface），是一组定义和描述不同软件组件如何通信以及相互操作的规范。它允许不同的软件系统之间共享数据和功能，使它们能够相互连接和交互。 API可以是不同软件之间的通信桥梁&…
阅读更多...
进入docker容器中安装软件失败解，国外源慢，时间不同步，执行命令权限不够等问题解决办法

进入docker容器中安装软件失败解，国外源慢，时间不同步，执行命令权限不够等问题解决办法

进入docker容器中安装软件失败解，时间不同步, 国外源慢，执行命令权限不够 等问题解决办法 首先我进入docker容器中，为了安装一个软件，引出了很多报错问题，报错如下： 1、无法用 ifconfig 或者 ip addr 的方…
阅读更多...
HAProxy高性能负载均衡器

HAProxy高性能负载均衡器

一、HAProxy基础知识 （一）HAProxy概述 HAProxy是一款基于事件驱动、单进程模型设计的四层与七层负载均衡器，它能够在TCP/UDP层面以及HTTP(S)等应用层协议上实现高效的流量分发。HAProxy不仅适用于Web服务器负载均衡，还能应用于数据…
阅读更多...
vulhub中DNS域传送漏洞复现

vulhub中DNS域传送漏洞复现

DNS协议支持使用axfr类型的记录进行区域传送，用来解决主从同步的问题。如果管理员在配置DNS服务器的时候没有限制允许获取记录的来源，将会导致DNS域传送漏洞。 环境搭建 Vulhub使用Bind9来搭建dns服务器，但不代表只有Bind9支持AXFR记录。运行…
阅读更多...
最新文章

Copyright @ 2022~2023