ThingsBoard Edge 设备控制

news/2024/5/19 14:23:58 标签: 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/

http://www.niftyadmin.cn/n/5434737.html

相关文章

Pytorch NLP入门3：用嵌入表示单词

Pytorch NLP入门3：用嵌入表示单词

初次编辑时间：2024/3/17；最后编辑时间：2024/3/17 本栏目链接：https://blog.csdn.net/qq_33345365/category_12597850.html 本人的其他栏目： pytorch 基础的栏目链接：https://blog.csdn.net/qq_33345365/…
阅读更多...
ioDraw：与 GitHub、gitee、gitlab、OneDrive 无缝对接，绘图文件永不丢失！

ioDraw：与 GitHub、gitee、gitlab、OneDrive 无缝对接，绘图文件永不丢失！

🌟 绘图神器 ioDraw 重磅更新，文件保存再无忧！🎉 无需注册，即刻畅绘！✨ ioDraw 让你告别繁琐注册，尽情挥洒灵感！ 新增文件在线实时保存功能，支持将绘图文件保存到 GitHu…
阅读更多...
GPT-4.5 Turbo详细信息被搜索引擎泄露：有重大改进

GPT-4.5 Turbo详细信息被搜索引擎泄露：有重大改进

3月14日消息，据外电报道，OpenAI 最新人工智能模型 GPT-4.5 Turbo 的详细信息已通过 Bing 和 DuckDuckGo 的搜索引擎索引过早泄露。 GPT-4.5 Turbo 的产品页面在正式发布之前就出现在搜索结果中，引发了人们对 OpenAI 最新型号的特性和功能的猜…
阅读更多...
vulhub中GitLab 远程命令执行漏洞复现（CVE-2021-22205）

vulhub中GitLab 远程命令执行漏洞复现（CVE-2021-22205）

GitLab是一款Ruby开发的Git项目管理平台。在11.9以后的GitLab中，因为使用了图片处理工具ExifTool而受到漏洞CVE-2021-22204的影响，攻击者可以通过一个未授权的接口上传一张恶意构造的图片，进而在GitLab服务器上执行任意命令。 环境启动后&am…
阅读更多...
如何写好Stable Diffusion的prompt

如何写好Stable Diffusion的prompt

Stable Diffusion是一种强大的文本到图像生成模型，其效果在很大程度上取决于输入的提示词（Prompt）。以下是一些关于如何编写有效的Stable Diffusion Prompt的秘诀： 明确描述：尽量清晰地描述你想要的图像内容。使用具体…
阅读更多...
每周一算法：双向深搜

每周一算法：双向深搜

题目描述 达达帮翰翰给女生送礼物，翰翰一共准备了 N N N 个礼物，其中第 i i i 个礼物的重量是 G [ i ] G[i] G[i]。 达达的力气很大，他一次可以搬动重量之和不超过 W W W的任意多个物品。 达达希望一次搬掉尽量重的一些物品，请…
阅读更多...
华为配置Hotspot2.0无线网络示例

华为配置Hotspot2.0无线网络示例

配置Hotspot2.0无线网络示例 组网图形 图1 配置Hotspot2.0无线网络组网图 组网需求配置思路配置注意事项操作步骤配置文件 组网需求 某网络服务商在原有移动网络业务的基础上，新增部署WLAN网络接入业务，为用户提供更好的网络体验。但传统的WLAN网络业…
阅读更多...
GPU密集型计算性能优化的方法和技术

GPU密集型计算性能优化的方法和技术

对GPU密集型计算进行性能优化的方法和技术多种多样。通过一些优化策略和技术需要综合考虑应用程序的具体需求、所使用的GPU硬件、以及编程模型和库的选择。通过不断地分析和调整，可以实现GPU计算性能的持续提升。以下是一些常用的优化策略和技术： 算法优…
阅读更多...
最新文章

Copyright @ 2022~2023