网站里怎样做物流跟踪功能,唐山诚达建设集团网站,山东人才招聘信息网官网,建筑行业人才网文章目录 一、RPC 功能1.服务端 RPC2.客户端 RPC3.MQTT RPC API3.1.服务端RPC3.2.客户端RPC 二、设备控制1.环境准备2.创建设备3.服务端PRC3.1.RPC消息主题3.2.程序源码3.3.创建仪表板3.4.边缘分配仪表板3.5.测试 4.客户端RPC4.1.RPC消息主题4.2.程序源码4.3.规则链4.4.测试 Th… 文章目录 一、RPC 功能1.服务端 RPC2.客户端 RPC3.MQTT RPC API3.1.服务端RPC3.2.客户端RPC 二、设备控制1.环境准备2.创建设备3.服务端PRC3.1.RPC消息主题3.2.程序源码3.3.创建仪表板3.4.边缘分配仪表板3.5.测试 4.客户端RPC4.1.RPC消息主题4.2.程序源码4.3.规则链4.4.测试 ThingsBoard
# ThingsBoardhttps://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_id3.2.客户端RPC
将RPC命令发送到服务端必须PUBLISH消息发送到下面主题
v1/devices/me/rpc/request/$request_id$request_id表示请求的整型标识符服务端必须发布到下面主题
v1/devices/me/rpc/response/$request_id二、设备控制
1.环境准备
创建测试设备 edge-device创建测试工程 tb-rpc
1.程序配置
mqtt:broker-url: tcp://192.168.202.166:1883client-id: emq-client-rpcusername: lMrdczEw1rJHhBejzumZpassword:2.创建设备
在 ThingsBoard 服务端创建设备配置 test-edge
在 Edge 端创建设备 edge-device
在服务端查看设备
# 访问令牌
lMrdczEw1rJHhBejzumZ3.服务端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_id3.2.程序源码
ServerRpc
Component
public class ServerRpc {Autowiredprivate EmqClient emqClient;Autowiredprivate MqttProperties properties;PostConstructpublic 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*/Overridepublic void messageArrived(String topic, MqttMessage message) throws Exception {log.info(订阅者订阅到了消息,topic{},messageid{},qos{},payload{},topic,message.getId(),message.getQos(),new String(message.getPayload()));// 订阅者订阅到了消息,topicv1/devices/me/rpc/request/7,messageid6,qos1,payload{method:setValue,params:false}// 订阅后客户端会收到一条命令作为对相应主题的PUBLISH命令// v1/devices/me/rpc/request/$request_idString[] buff topic.split(/);String request_id buff[buff.length-1];// 客户端PUBLISH下面主题进行响应// v1/devices/me/rpc/response/$request_idemqClient.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 : 订阅者订阅到了消息,topicv1/devices/me/rpc/request/15,messageid1,qos1,payload{method:setValue,params:false}2023-08-20 16:35:34.252 INFO 21332 --- [emq-client-2222] com.iiotos.mqtt.MessageCallback : 消息发布完成,messageid2,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 {Autowiredprivate EmqClient emqClient;Autowiredprivate MqttProperties properties;PostConstructpublic 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.resultserver 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 : 消息发布完成,messageid7,topics[v1/devices/me/rpc/request/1]2023-08-20 17:46:46.269 INFO 20548 --- [emq-client-2222] com.iiotos.mqtt.MessageCallback : 订阅者订阅到了消息,topicv1/devices/me/rpc/response/1,messageid6,qos1,payload{method:getServerValue,params:,result:server receive rpc requuest!!!}ThingsBoard
# ThingsBoardhttps://iothub.org.cn/docs/iot/
https://iothub.org.cn/docs/iot/tb-edge/edge-rpc/
