甜橘子，专注成都网站制作网站设计与营销型网站建设与优化
QQ :532337155
电话：028-86922220
本篇内容主要讲解“MQTT如何连接RRPC通讯”，感兴趣的朋友不妨来看看。本文介绍的方法操作简单快捷，实用性强。下面就让小编来带大家学习“MQTT如何连接RRPC通讯”吧!
创新互联不只是一家网站建设的网络公司；我们对营销、技术、服务都有自己独特见解，公司采取“创意+综合+营销”一体化的方式为您提供更专业的服务！我们经历的每一步也许不一定是最完美的，但每一步都有值得深思的意义。我们珍视每一份信任，关注我们的成都网站制作、成都网站设计、外贸营销网站建设质量和服务品质，在得到用户满意的同时，也能得到同行业的专业认可，能够为行业创新发展助力。未来将继续专注于技术创新，服务升级，满足企业一站式全网整合营销推广需求，让再小的高端网站设计也能产生价值！
什么是RRPC通信
MQTT协议是基于PUB/SUB的异步通信模式，不适用于服务端同步控制设备端返回结果的场景。物联网平台基于MQTT协议制定了一套请求和响应的同步机制，无需改动MQTT协议即可实现同步通信。物联网平台提供API给服务端，设备端只需要按照固定的格式回复PUB消息，服务端使用API，即可同步获取设备端的响应结果。
RRPC：Revert-RPC。RPC（Remote Procedure Call）采用客户机/服务器模式，用户不需要了解底层技术协议，即可远程请求服务。RRPC则可以实现由服务端请求设备端并能够使设备端响应的功能。
RRPC 请求消息：云端下发给设备端的消息。
RRPC 响应消息：设备端回复给云端的消息。
RRPC 消息ID：云端为每次RRPC调用生成的唯一消息ID。
RRPC 订阅Topic：设备端订阅RRPC消息时传递的Topic，含有通配符。
具体流程如下：
物联网平台收到来自用户服务器的RRPC调用，下发一条RRPC请求消息给设备。消息体为用户传入的数据，Topic为物联网平台定义的Topic，其中含有唯一的RRPC消息ID。
设备收到下行消息后，按照指定Topic格式（包含之前云端下发的唯一的RRPC消息ID）回复一条RRPC响应消息给云端，云端提取出Topic中的消息ID，和之前的RRPC请求消息匹配上，然后回复给用户服务器。
如果调用时设备不在线，云端会给用户服务器返回设备离线的错误；如果设备没有在超时时间内（8秒内）回复RRPC响应消息，云端会给用户服务器返回超时错误。
RRPC通信相关Topic格式如下：
RRPC请求消息Topic：/sys/${YourProductKey}/${YourDeviceName}/rrpc/request/${messageId}
RRPC响应消息Topic：/sys/${YourProductKey}/${YourDeviceName}/rrpc/response/${messageId}
RRPC订阅Topic：/sys/${YourProductKey}/${YourDeviceName}/rrpc/request/+
以上内容来自https://help.aliyun.com/document_detail/90567.html
由上面可以看出需要在topic中获得messageId，然后在发送回去
如果你的ML302模块还没有连上阿里云可以看一下这个，中移4G模块-ML302-OpenCpu开发-(MQTT连接阿里云)
https://blog.csdn.net/qq_33259323/article/details/108638945
https://www.bilibili.com/read/cv7876527
int example_subscribe_rrpc(void *handle){
int res = 0;
const char *fmt = "/sys/%s/%s/rrpc/request/+";
char *topic = NULL;
int topic_len = 0;
topic_len = strlen(fmt) + strlen(DEMO_PRODUCT_KEY) + strlen(DEMO_DEVICE_NAME) + 1;
topic = HAL_Malloc(topic_len);
if (topic == NULL) {
cm_printf("[ALIYUN]: memory not enough\n");
return -1;
}
memset(topic, 0, topic_len);
HAL_Snprintf(topic, topic_len, fmt, DEMO_PRODUCT_KEY, DEMO_DEVICE_NAME);
cm_printf("topic:%s \r\n",topic);
res = IOT_MQTT_Subscribe(handle, topic, IOTX_MQTT_QOS0, example_message_arrive_rrpc, NULL);
if (res < 0) {
cm_printf("[ALIYUN]: subscribe failed\n");
HAL_Free(topic);
return -1;
}
HAL_Free(topic);
return 0;
}char DEMO_RRPC_SessionId[19];
void example_message_arrive_rrpc(void *pcontext, void *pclient, iotx_mqtt_event_msg_pt msg){
iotx_mqtt_topic_info_t *topic_info = (iotx_mqtt_topic_info_pt) msg->msg;
char * sendMessage = NULL;
const char * sendMessage_fmt = "%d";
int sendMessage_len = 20;
int cm_test_read_gpio = 0;
cm_printf("example_message_arrive_rrpc \n");
switch (msg->event_type) {
case IOTX_MQTT_EVENT_PUBLISH_RECEIVED:
/* print topic name and topic message */
cm_printf("[ALIYUN]: Message Arrived:");
cm_printf("Topic : %.*s", topic_info->topic_len, topic_info->ptopic);
cm_printf("Payload: %.*s", topic_info->payload_len, topic_info->payload);
cm_printf("\n");
// 提取sessionId
strncpy(DEMO_RRPC_SessionId,topic_info->ptopic+46,19);
cm_printf("[ALIYUN]: sessionId: %s",DEMO_RRPC_SessionId);
//接收到的数据：topic_info->payload
//干啥干啥干啥
// 发送
example_publish_rrpc(sendMessage);
break;
default:
break;
}
}int example_publish_rrpc(unsigned char * payload)
{
int res = 0;
const char *fmt = "/sys/%s/%s/rrpc/response/%s";
char *topic = NULL;
int topic_len = 0;
//char *payload = "{\"message\":\"hello!\"}";]
cm_printf("MQTT发送信息：%s",payload);
topic_len = strlen(fmt) + strlen(DEMO_PRODUCT_KEY) + strlen(DEMO_DEVICE_NAME) + 1 +strlen(DEMO_RRPC_SessionId);
topic = HAL_Malloc(topic_len);
if (topic == NULL) {
cm_printf("[ALIYUN]: memory not enough\n");
return -1;
}
memset(topic, 0, topic_len);
HAL_Snprintf(topic, topic_len, fmt, DEMO_PRODUCT_KEY, DEMO_DEVICE_NAME,DEMO_RRPC_SessionId);
cm_printf("[ALIYUN]: example_publish_rrpc: %s",topic);
res = IOT_MQTT_Publish_Simple(0, topic, IOTX_MQTT_QOS0, payload, strlen(payload));
if (res < 0) {
cm_printf("[ALIYUN]: publish failed, res = %d\n", res);
HAL_Free(topic);
return -1;
}
HAL_Free(topic);
return 0;
}到此，相信大家对“MQTT如何连接RRPC通讯”有了更深的了解，不妨来实际操作一番吧！这里是创新互联网站，更多相关内容可以进入相关频道进行查询，关注我们，继续学习！