1. 首页
  2. 文章中心
  3. 正点原子

OneNET连接流程

59 阅读 0 评论
我是靠谱客的博主 清秀皮带，最近开发中收集的这篇文章主要介绍OneNET连接流程，觉得挺不错的，现在分享给大家，希望可以做个参考。

概述

OneNET-中国移动物联网开放平台是由中国移动打造的PaaS物联网开放平台。平台能够帮助开发者轻松实现设备接入与设备连接,提供综合性的物联网解决方案,实现物联网设备的数据获取,数据存储,数据展现。本文就介绍如何将传统的设备连接到OneNET。
采用MQTT+JSON格式对接OneNET平台上传温度度的数据，当然我们也可以在平台下发消息来控制设备。

1.操作和实战

注册OneNET：https://open.iot.10086.cn/，注册OneNET账号。注册过程比较简单这里就不再累述。登录之后。打开产品服务 MQTT物联网套件点击立刻使用，如下图所示：
在这里插入图片描述

进入MQTT物联网套件，在该页面点击添加产品，如下图所示：
在这里插入图片描述

从上图中，技术参数根据自己的硬件选择，如果我们的联网硬件为无线产品，则选择wifi;如果我们的联网硬件为有线产品，则选择移动蜂窝网络。协议为MQTTS，操作系统为无，而网络运营商可以全选，最后点击完成就可以创建产品，如下图所示：
在这里插入图片描述

点击上图的产品，进入相关界面，然后点击设备列表创建设备，如下图所示：
在这里插入图片描述

添加完成之后，我们得到一个设备，，如下图所示：
在这里插入图片描述

点击上图中的数据流，这些数据流是由用户添加的，例如显示温湿度等等，如下图所示：
在这里插入图片描述

最后我们得到三元组内容，如下源码所示：

/* 用户需要根据设备信息完善以下宏定义中的三元组内容 */
#define CLIENTID "MQTT"   /* 设备名 */
#define USERNAME "366007" /* 产品ID */
/* 该密码需要onenet提供的token软件计算得出 */
#define PASSWORD "version=2018-10-31&res=products%2F366007%2Fdevices%2FMQTT&et=1672735919&method=md5&sign=qI0pgDJnICGoPdhNi%2BHtfg%3D%3D"

上述的参数是由OneNET来提供，MQTT是刚刚我们创建的设备名称，“366007”是刚刚我们创建的产品ID，而密钥是从产品概述获取，如下图所示：

上述是OneNET平台构建MQTT服务器完成，下面我们讲解代码部分。
在这里插入图片描述

2. MQTT源码包和cjSON源码包下载

MQTT官方网址（http://mqtt.org/）下载MQTT代码包；
cjSON官方网址（https://sourceforge.net/projects/cjson/）下载cjSON代码包；
然后把这些源码移植到我们工程当中，移植步骤如下所示：
(1)添加一下源码到工程当中
在这里插入图片描述

(2)在工程添加一下分组：
在这里插入图片描述

(3)添加这些源码头文件路径：

3. 连接

/* 用户需要根据设备信息完善以下宏定义中的三元组内容 */
#define CLIENTID "MQTT"   /* 设备名 */
#define USERNAME "366007" /* 产品ID */
/* 该密码需要onenet提供的token软件计算得出 */
#define PASSWORD "version=2018-10-31&res=products%2F366007%2Fdevices%2FMQTT&et=1672735919&method=md5&sign=qI0pgDJnICGoPdhNi%2BHtfg%3D%3D"

/* 以下参数的宏定义固定，不需要修改，只修改上方的参数即可 */
#define HOST_NAME     "open.iot.10086.cn"  /*onenet域名 */
#define HOST_PORT     1883
#define DEVICE_SUBSCRIBE   "$sys/"USERNAME"/"CLIENTID"/dp/post/json/+"/* 订阅 */
#define DEVICE_PUBLISH     "$sys/"USERNAME"/"CLIENTID"/dp/post/json"/* 发布 */

订阅和发布的写法根据OneNET的要求而定义。
(2) 在onenet.c文件定义四个函数，分别连接、获取、打开和关闭，如下源码所示：

/*
* @brief  通过TCP方式发送数据到TCP服务器
*/
int lwip_transport_send_packet_buffer(int sock, unsigned char *buf, 
int buflen)
{
    int rc = 0;
    rc = write(sock, buf, buflen);
    return rc;
}

/*
* @brief  阻塞方式接受TCP服务器发送的数据
/
int lwip_transport_getdata(uint8_t* buf, int32_t count)
{
    int rc = recv(mysock, buf, count, 0);
    return rc;
}

/*
* @brief  打开一个网络接口，其实就是和服务器建立一个 TCP 连接。
/
int lwip_transport_open(char* addr, int port)
{
    int* sock = &mysock;
    struct hostent *server;
    struct sockaddr_in serv_addr;
    int timeout = 1000;

    *sock = socket(AF_INET, SOCK_STREAM, 0);
    if(*sock < 0)
      printf("[ERROR] Create socket failedn");
    
    server = gethostbyname(addr);              /* 对阿里云服务器地址解析 */
    if(server == NULL)
      printf("[ERROR] Get host ip failedn");
    
    memset(&serv_addr,0,sizeof(serv_addr));
    serv_addr.sin_family = AF_INET;
    serv_addr.sin_port = htons(port);          /* 设置端口号 */
    memcpy(&serv_addr.sin_addr.s_addr,server->h_addr,server->h_length);
    
    if(connect(*sock,(struct sockaddr *)&serv_addr,sizeof(serv_addr)) < 0)
    {
      printf("[ERROR] connect failedn");
          return -1;
    }
    
setsockopt(mysock, SOL_SOCKET, SO_RCVTIMEO,
            (char*)&timeout,sizeof(timeout));

    return mysock;
}

/*
 @brief  关闭连接
/
int lwip_transport_close(int sock)
{
    int rc;

    rc = shutdown(sock, SHUT_WR);
    rc = recv(sock, NULL, (size_t)0, 0);
    rc = close(sock);

    return rc;
}

这些函数是由用户来实现，例如连接函数，根据自己的硬件编写连接。上述的源码小编以LWIP为例。
(3) 订阅和发布操作

void lwip_demo(void)
{
    mysock = lwip_transport_open((char *)HOST_NAME, HOST_PORT);
    data.clientID.cstring = CLIENTID;
    data.username.cstring = USERNAME;
    data.password.cstring = PASSWORD;
    unsigned char payload_out[200];
    int payload_out_len = 0;
    uint32_t sendtick = xTaskGetTickCount();

    while (1)
{
/* 客户端的发布操作 */
        if ((xTaskGetTickCount() - sendtick) >= (send_duration * 100)) 
        {
            sendtick = xTaskGetTickCount();/* sendtick重新计数 */
            taskENTER_CRITICAL();/* 进入临界区 */
            temp = 30 + rand() % 10 + 1; /* 温度的数据 */
            humid = 54.8 + rand() % 10 + 1; /* 湿度的数据 */
            sprintf((char *)payload_out, "{"id": 123,"dp":
                     { "temperatrue": [{"v": %0.1f,}],"power":
                     [{"v": %0.1f,}]}}", temp, humid);
            payload_out_len = strlen((char *)payload_out);
            topicString.cstring = DEVICE_PUBLISH;   /* 属性上报 发布 */
            len = MQTTSerialize_publish((unsigned char *)buf, 
buflen, 0, req_qos, 
retained, msgid, 
topicString, 
payload_out, 
payload_out_len);
            rc = lwip_transport_send_packet_buffer(mysock, 
(unsigned char *)buf, len);
            taskEXIT_CRITICAL();                    /* 退出临界区 */
            if (rc == len)
                printf("send PUBLISH Successfullyrn");
            else
                printf("send PUBLISH failedrn");

            printf("send temp(%0.1f)&humid(%0.1f) !rn", temp, humid);
            recv_server_flag = 1;
        }
        
        vTaskDelay(100);
        
        switch (msgtypes)
        {

            case CONNECT:  /* 客户端发送服务器的连接操作 */
                printf("进入CONNECT状态rn");
                len = MQTTSerialize_connect((unsigned char *)buf, 
buflen, &data);         /* 获取数据组长发送连接信息  */
                rc = lwip_transport_send_packet_buffer(mysock, 
(unsigned char *)buf, len); /* 发送返回发送数组长度 */

                if (rc == len)
                    printf("发送连接成功rn");
                else
                    printf("发送连接失败rn");

                printf("MQTT连接服务器!rn");
                printf("退出CONNECT状态rnrn");
                msgtypes = 0;
                recv_server_flag = 1;
                break;

            case CONNACK:  /* 服务器发送客户端确认连接请求 */
                if (MQTTDeserialize_connack(&sessionPresent, 
&connack_rc, (unsigned char *)buf, buflen) != 1 
|| connack_rc != 0)  /* 收到回执 */
                {
/* 回执不一致，连接失败 */
                    printf("Unable to connect, return code %drn", connack_rc);   
                }
                else
                {
                    printf("MQTT is concet OK!rn");   /* 连接成功 */
                }
                msgtypes = SUBSCRIBE;   /* 连接成功 执行 订阅 操作 */
                break;

            case SUBSCRIBE:  /* 客户端发送到服务器的订阅操作 */
                topicString.cstring = DEVICE_SUBSCRIBE;
                len = MQTTSerialize_subscribe((unsigned char *)buf, 
buflen, 0, msgid, 1, &topicString, &req_qos);
                rc = lwip_transport_send_packet_buffer(mysock, 
(unsigned char *)buf, len);

                if (rc == len)
                    printf("send SUBSCRIBE Successfullyrn");
                else
                {
                    printf("send SUBSCRIBE failedrn");
                    t++;

                    if (t >= 10)
                    {
                        t = 0;
                        msgtypes = CONNECT;
                    }
                    else
                        msgtypes = SUBSCRIBE;

                    break;
                }
                msgtypes = 0;
                recv_server_flag = 1;
                break;

            case SUBACK:  /* 服务器发送到客户端的订阅确认 */
/* 有回执  QoS */
                rc = MQTTDeserialize_suback(&submsgid, 1, &subcount,
                                                  &granted_qos, (unsigned char *)buf,
                                                   buflen);  
                printf("granted qos is %drn", granted_qos);    /* 打印 Qos */
                msgtypes = 0;
                break;

            case PUBLISH:  /* 服务器的发布操作 */
                /* 服务器的发布数据，自行编写 */
                break;

            case PUBACK:   /* 发布成功 */
                msgtypes = 0;
                break;

            default:
                break;

        }
        
        if (recv_server_flag == 1)
        {
            memset(buf, 0, buflen); 
/* 轮询，读MQTT返回数据，*/
            rc = MQTTPacket_read((unsigned char *)buf, buflen,
                                      lwip_transport_getdata); 
            if (rc > 0) /* 如果有数据，进入相应状态。*/
            {
                msgtypes = rc;
            }
            recv_server_flag = 0;
        }
    }
}
  1. 下载验证：

在这里插入图片描述

最后

以上就是清秀皮带为你收集整理的OneNET连接流程的全部内容，希望文章能够帮你解决OneNET连接流程所遇到的程序开发问题。

如果觉得靠谱客网站的内容还不错，欢迎将靠谱客网站推荐给程序员好友。

本图文内容来源于网友提供，作为学习参考使用，或来自网络收集整理，版权属于原作者所有。
点赞(39)

相关文章

4G DTU+MODBUS温湿度传感器+MQTT连接湖畔云
4G DTU+MODBUS温湿度传感器+MQTT连接湖畔云
java dtu 采集程序_一文教你用DTU主动采集，省去PLC、单片机、RTU等，节约成本
java dtu 采集程序_一文教你用DTU主动采集，省去PLC、单片机、RTU等，节约成本
树莓派数据远程传输学习记录——TCP/IP协议连接OneNet云平台传输数据的方法项目场景：问题描述：解决方案：最后总结：
树莓派数据远程传输学习记录——TCP/IP协议连接OneNet云平台传输数据的方法项目场景：问题描述：解决方案：最后总结：
STM32+ESP8266+MQTT协议连接OneNet物联网平台
STM32+ESP8266+MQTT协议连接OneNet物联网平台
OneNET连接流程
OneNET连接流程
STM32系列(HAL库)——使用ESP8266-01S物联网模块连接Onenet云平台上报DHT11温湿度前言一、前期准备二、CubeMX配置三、Keil5配置四、Onenet云平台配置五、最后一步
STM32系列(HAL库)——使用ESP8266-01S物联网模块连接Onenet云平台上报DHT11温湿度前言一、前期准备二、CubeMX配置三、Keil5配置四、Onenet云平台配置五、最后一步
esp8266作为wifi与手机互传数据 1.esp8266.c代码,另外需要配置usart3与定时器2.esp8266.h代码3.main.c4.手机端的连接 5.连接端口，子网掩码192.168.4.1 端口8000 6.手机端软件
esp8266作为wifi与手机互传数据 1.esp8266.c代码,另外需要配置usart3与定时器2.esp8266.h代码3.main.c4.手机端的连接 5.连接端口，子网掩码192.168.4.1 端口8000 6.手机端软件
在ubuntu中设置使用网络摄像头介绍
在ubuntu中设置使用网络摄像头介绍

评论列表共有 0 条评论

立即
投稿
返回
顶部