二十八、W5100S/W5500+RP2040树莓派Pico<MQTT连接OneNET控制板载LED>

文章目录

  • 1. 前言
  • 2. 简介
    • 2.1 初步了解OneNET物联网平台创建产品步骤
    • 2.2 OneNET物模型讲解
  • 3 WIZnet以太网芯片
  • 4 示例概述
    • 4.1 流程图
    • 4.2 准备工作核心
    • 4.3 连接方式
    • 4.4 主要代码概述
    • 4.5 结果演示
  • 5 注意事项
  • 6 相关链接

1. 前言

  物联网平台提供安全可靠的设备连接通信能力,支持设备数据采集上云,规则引擎流转数据和云端数据下发设备端。此外,也提供方便快捷的设备管理能力,支持物模型定义,数据结构化存储,和远程调试、监控、运维。本章讲解OneNET物联网平台的使用方法,并讲解使用设备连接OneNET物联网平台。

  在以太网应用中使用 W5500 + MQTT应用协议让用户可以更加方便地在设备之间实现OneNET远程连接和通信。本教程将介绍W5500以太网MQTT连接OneNET的应用以及注意事项,帮助读者更好地掌握这一技术。

2. 简介

2.1 初步了解OneNET物联网平台创建产品步骤

  如何在OneNET平台创建产品:

  OneNET网址:中移坤灵 - 中国移动物联网开放平台 (10086.cn)

  1. 进入之后,登录账号,然后点击右上角开发者中心,再点击产品开发界面下的创建产品,然后选择对应的参数即可。

    在这里插入图片描述

  2. 点击产品详情,在物模型界面添加一个自定义功能点

    在这里插入图片描述

  3. 点击下一步,在设备开发的Topic管理页面中记录物模型topic

    这里需要记录的四个topic对应的功能如下表所示:

    Topic名设备操作权限作用
    $sys/70TwP2gxl5/{device-name}/thing/property/post发布设备上报属性
    $sys/70TwP2gxl5/{device-name}/thing/property/post/reply订阅云端回复上报状态
    $sys/70TwP2gxl5/{device-name}/thing/property/set订阅云端设置设备属性
    $sys/70TwP2gxl5/{device-name}/thing/property/set_reply发布设备回复设置

    在这里插入图片描述

  4. 一直点击下一步,然后发布产品即可。

  5. 之后在设备接入管理的设备管理界面下添加一个测试设备,

    在这里插入图片描述

  6. 然后记录以下参数:

    参数
    产品ID70TwP2gxl5
    设备名W5100S_W5500
    设备密钥SXFUeWlDUjJqamN4bGNndWRHNmZYc0Eyc2ZTNWh2bWo=
  7. 生成MQTT连接参数

    连接地址和端口号如下图所示:

    在这里插入图片描述

    其他参数如下图所示:

    在这里插入图片描述

计算password工具:https://open.iot.10086.cn/doc/iot_platform/images/tools/token.exe

打开之后按照下图所示生成password:

在这里插入图片描述

2.2 OneNET物模型讲解

1.定义

  物模型是对设备的数字化抽象描述,描述该型号设备是什么,能做什么,能对外提供哪些服务。
  物模型将物理空间中的实体设备数字化,在云端构建该实体的数据模型,即将物理空间的实体在云端进行格式化表示。

在这里插入图片描述

  如上图所示,物模型属于应用协议之上的语法语义层。在物联网平台中,物模型完成对终端产品形态,产品功能的结构化定义,包括终端设备业务数据的格式和传输规则

  物模型功能模块在物联网平台中的位置如图所示:

在这里插入图片描述

  物模型在业务逻辑属于物联网平台的设备管理模块。用于实现不同设备能够以统一的物模型标准对接应用平台,不同应用之间能够以统一物模型标准进行数据互通。

2.设备抽象模型

  物模型基础功能分为三类:属性、服务、事件,功能点数量不超过100个。

功能类型说明
属性用于描述设备的动态特征,包括运行时的状态,应用可发起对属性的读取和设置请求。
服务用于描述终端设备可被外部调用的能力,可设置输入参数和输出参数。服务可实现复杂的业务逻辑,例如执行某项特定的任务;支持同步或异步返回结果。
事件设备运行时可以被触发的上行消息,如设备运行的记录信息,设备异常时发出的告警、故障信息等;可包含多个输出参数。

3 WIZnet以太网芯片

  WIZnet 主流硬件协议栈以太网芯片参数对比

ModelEmbedded CoreHost I/FTX/RX BufferHW SocketNetwork Performance
W5100STCP/IPv4, MAC & PHY8bit BUS, SPI16KB4Max.25Mbps
W6100TCP/IPv4/IPv6, MAC & PHY8bit BUS, Fast SPI32KB8Max.25Mbps
W5500TCP/IPv4, MAC & PHYFast SPI32KB8Max 15Mbps
  1. W5100S/W6100 支持 8bit数据总线接口,网络传输速度会优于W5500。
  2. W6100 支持IPv6,与W5100S 硬件兼容,若已使用W5100S的用户需要支持IPv6,可以Pin to Pin兼容。
  3. W5500 拥有比 W5100S更多的 Socket数量以及发送与接收缓存。

4 示例概述

4.1 流程图

  程序的运行框图如下所示:

在这里插入图片描述

4.2 准备工作核心

软件

  • Visual Studio Code
  • WIZnet UartTool
  • OneNET平台

硬件

  • W5100S IO模块 + RP2040 树莓派Pico开发板 或者 WIZnet W5100S-EVB-Pico开发板
  • Micro USB 接口的数据线
  • TTL 转 USB
  • 网线

4.3 连接方式

  • 通过数据线连接PC的USB口(主要用于烧录程序,也可以虚拟出串口使用)

  • 通过TTL串口转USB,连接UART0 的默认引脚:

    • RP2040 GPIO0(UART0 TX) <----> USB_TTL_RX
    • RP2040 GPIO1(UART0 RX) <----> USB_TTL_TX
  • 使用模块连接RP2040 进行接线时

    • RP2040 GPIO16 <----> W5100S MISO
    • RP2040 GPIO17 <----> W5100S CS
    • RP2040 GPIO18 <----> W5100S SCK
    • RP2040 GPIO19 <----> W5100S MOSI
    • RP2040 GPIO20 <----> W5100S RST
  • 通过PC和设备都通过网线连接路由器LAN口

4.4 主要代码概述

  我们使用的是WIZnet官方的ioLibrary_Driver库。该库支持的协议丰富,操作简单,芯片在硬件上集成了TCP/IP协议栈,该库又封装好了TCP/IP层之上的协议,我们只需简单调用相应函数即可完成协议的应用。

第一步:mqtt_onenet.c文件中引用对应的库。

第二步:宏定义相关内容

第三步:定义一个mqtt连接参数的结构体并进行定义,这里给结构体赋的值是连接OneNET对应的参数以及物模型的订阅发布主题。

第四步: 设置预设IP地址信息以及标志位。

第五步:编写几个函数,包括网络初始化函数,1秒定时器回调函数,1毫秒定时器回调函数,MQTT初始化函数,MQTT接收消息回调函数,DNS解析函数以及json解析函数。

第六步:编写定时器回调处理函数,用于DHCP和MQTT 滴答定时器处理函数。

第七步:主函数先是对串口和SPI的初始化,然后写入W5100S的网络配置参数,初始化DHCP后开始DHCP获取IP,获取到就打印获取到的IP,获取次数超过最大获取次数时就使用静态IP,DNS解析域名,之后初始化MQTT,然后主循环是一个状态机的轮询,会按照流程图进行连接、订阅、定时上报消息、保活以及接收消息处理。

主函数代码如下所示:

int main()
{/* Variable definition */int ret;struct repeating_timer timer_1s;struct repeating_timer timer_1ms;uint8_t pubmsg[128] = {0};/*mcu init*/stdio_init_all();     /*Initialize the serial port*/wizchip_initialize(); /*Initialize the SPI*//* LED init */gpio_init(LED_PIN);gpio_set_dir(LED_PIN, GPIO_OUT);/*timer init*/add_repeating_timer_ms(1000, repeating_timer_1s_callback, NULL, &timer_1s); // Add DHCP and DNS 1s Tick Timer handleradd_repeating_timer_ms(1, repeating_timer_1ms_callback, NULL, &timer_1ms);  // Add MQTT 1ms Tick Timer handler/*dhcp init*/DHCP_init(SOCK_DHCP, ethernet_buf); // DHCP initialization/*dns init*/DNS_init(SOCK_DNS, ethernet_buf);/* Set the network address information */printf("wiznet chip mqtt of onenet example.\r\n");network_init(&net_info);              // Configuring Network Informationprint_network_information(&get_info); // Read back the configuration information and print it/* Resolve mqtt broker domain names using dns */do_dns(mqtt_params.mqttHostUrl, mqtt_params.server_ip);/*mqtt init*/mqtt_init();while (true){switch (run_status){case CONN:{ret = MQTTConnect(&c, &data); /* Connect to the MQTT server */printf("Connect to the MQTT server: %d.%d.%d.%d:%d\r\n", mqtt_params.server_ip[0], mqtt_params.server_ip[1], mqtt_params.server_ip[2], mqtt_params.server_ip[3], mqtt_params.port);printf("Connected:%s\r\n\r\n", ret == SUCCESSS ? "success" : "failed");if (ret != SUCCESSS){run_status = ERROR;}else{run_status = SUB;}break;}case SUB:{ret = MQTTSubscribe(&c, mqtt_params.subtopic, mqtt_params.subQoS, messageArrived); /* Subscribe to Topics */printf("Subscribing to %s\r\n", mqtt_params.subtopic);printf("Subscribed:%s\r\n\r\n", ret == SUCCESSS ? "success" : "failed");if (ret != SUCCESSS){run_status = ERROR;}else{run_status = KEEPALIVE;}ret = MQTTSubscribe(&c, mqtt_params.pubtopic_reply, mqtt_params.subQoS, NULL); /* Subscribe to Topics */printf("Subscribing to %s\r\n", mqtt_params.pubtopic_reply);printf("Subscribed:%s\r\n\r\n", ret == SUCCESSS ? "success" : "failed");if (ret != SUCCESSS){run_status = ERROR;}else{run_status = KEEPALIVE;}break;}case PUB:{if (pub_time >= 5){pub_time = 0;sprintf(pubmsg, "{\"id\": \"123\",\"version\": \"1.0\",\"params\": {\"LEDSwitch\": {\"value\":%s}}}", gpio_get(LED_PIN) == ON ? "true" : "false");pubmessage.payload = pubmsg;pubmessage.payloadlen = strlen(pubmessage.payload);ret = MQTTPublish(&c, mqtt_params.pubtopic, &pubmessage); /* Publish message */if (ret != SUCCESSS){run_status = ERROR;}else{printf("publish:%s,%s\r\n\r\n", mqtt_params.pubtopic, pubmessage.payload);}}else{run_status = KEEPALIVE;}break;}case KEEPALIVE:{if (MQTTYield(&c, 30) != SUCCESSS) /* keepalive MQTT */{run_status = ERROR;}else{run_status = PUB;}sleep_ms(100);break;}case ERROR: /* Running error */printf("system ERROR!\r\n");sleep_ms(1000);break;default:break;}}
}

4.5 结果演示

1.打开WIZ UartTool,填入参数,获取到IP之后解析mqtt服务器域名,然后进行OneNET的连接,连接成功后会打印订阅的主题,并定时向服务器上报板载LED灯状态。

在这里插入图片描述

2.通过OneNET下发指令控制LED打开

在这里插入图片描述

在这里插入图片描述

在这里插入图片描述

3.平台物模型上也可以收到设备上的板载LED灯状态
在这里插入图片描述

5 注意事项

  • 订阅和发布的物模型主题不要弄错了,否则会导致无法正常运行。
  • 把OneNET的物模型主题复制过来时,需要把{device-name}替换成设备名
  • 如果想用WIZnet的W5500来实现本章的示例,我们只需修改两个地方即可:

​ (1)在library/ioLibrary_Driver/Ethernet/下找到wizchip_conf.h这个头文件,将_WIZCHIP_ 宏定义修改为W5500。

​ (2)在library下找到CMakeLists.txt文件,将COMPILE_SEL设置为ON即可,OFF为W5100S,ON为W5500。

6 相关链接

WIZnet官网

WIZnet官方库链接

本章例程链接

想了解更多,评论留言哦!

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

如若内容造成侵权/违法违规/事实不符,请联系编程知识网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

[算法学习笔记](超全)概率与期望

引子 先来讲个故事 话说在神奇的OI大陆上&#xff0c;有一只paper mouse 有一天&#xff0c;它去商场购物&#xff0c;正好是11.11&#xff0c;商店有活动 它很荣幸被选上给1832抽奖 在抽奖箱里&#xff0c;有3个篮蓝球&#xff0c;12个红球 paper mouse能抽3次 蒟蒻的p…

基于LeNet实现手写体数字识别实验

目录 1 数据 1.1 数据预处理 2 模型构建 2.1 自定义算子实现 2.2 Pytorch框架实现 2.3 测试两个网络的运算速度 2.4 两个网络加载同样的权重&#xff0c;两个网络的输出结果是否一致&#xff1f; 2.5 计算模型的参数量和计算量。 3 模型训练 4 模型评价 5 模型预测 总结…

网络工程师沦为IT行业里的“二等公民”了?

大家好&#xff0c;我是老杨。 都说网工难&#xff0c;都说网工苦&#xff0c;都说网工行业已经不行了、网工成为最底层、“二等公民”&#xff0c;已经彻底没落了…… 这些在互联网里持续不断散发出来的负能量&#xff0c;有没有让你在深夜耍手机的时候一次又一次的扎心过&a…

【C++】——阶段性测验(帮助巩固C++前半部分知识)

&#x1f383;个人专栏&#xff1a; &#x1f42c; 算法设计与分析&#xff1a;算法设计与分析_IT闫的博客-CSDN博客 &#x1f433;Java基础&#xff1a;Java基础_IT闫的博客-CSDN博客 &#x1f40b;c语言&#xff1a;c语言_IT闫的博客-CSDN博客 &#x1f41f;MySQL&#xff1a…

数据库学习 02-01 关系数据模型详细学习(数据库模式中的一种)

关系型数据模型的相关概念介绍&#xff1a; 01.关系&#xff08;Relation&#xff09; 一个关系对应通常说的一张表 02.元组&#xff08;Tuple&#xff09; 表中的一行即为一个元组&#xff0c;也就是一个对象 03.属性&#xff08;Attribute&#xff09; 表中的一列即为一个属性…

2023年AI生成音频研究报告

第一章 行业概况 1.1 定义 AI音频生成行业&#xff0c;作为人工智能生成内容&#xff08;AIGC&#xff09;技术渗透的关键领域&#xff0c;正迅速成为技术革新的前沿阵地。这一领域专注于运用先进的人工智能技术和复杂算法来创造音频内容&#xff0c;覆盖了语音合成、音乐制作…

Pytorch torch.dot、torch.mv、torch.mm、torch.norm的用法详解

torch.dot的用法&#xff1a; 使用numpy求点积&#xff0c;对于二维的且一个二维的维数为1 torch.mv的用法&#xff1a; torch.mm的用法 torch.norm 名词解释&#xff1a;L2范数也就是向量的模&#xff0c;L1范数就是各个元素的绝对值之和例如&#xff1a;

业务架构、技术架构、项目管理的有机结合

新入职的创业公司一年不行了。 这一年来没有上班&#xff0c;也因为大龄的问题找不到合适的工作。然后考了几个项目管理证书&#xff0c;又思考了一个技术兑现的问题。 技术本身是架构的执行层面&#xff0c;如果上面的公司战略、业务架构变小&#xff0c;缩水&#xff0c;或者…

11.5MyBatis(进阶)

一.${}和#{} 1.$是直接替换,#是预处理(使用占位符,替换成?).前者不安全(SQL注入), 后者安全. 2.$的使用场景: 如果传递的值是sql的关键字,只能使用$,不能使用#(asc,desc). 二.SQL注入 注意: 如果使用${}进行传参,一定要是可以穷举的,并且要进行安全性验证(例如排序,只能传a…

【无标题】函数参数列表

torch.nn.Conv2d 参数详解 torch.nn.Conv2d(in_channels, out_channels, kernel_size, stride1, padding0, dilation1, groups1, biasTrue) 来源博客 view函数&#xff0c;和reshape函数&#xff1f; reshape函数的本质我觉的就是view函数contiguous函数 反正reshape功能多…

数字音频工作站FL Studio21.1中文版本如何下载?

在现在这个数字音乐时代&#xff0c;各种音乐中都或多或少有些电子音乐的影子&#xff0c;或是合成器音色、或是通过数字效果器制作出的变幻莫测的变化效果。而小马丁、Brooks、Eliminate等众多电子音乐巨头便是使用FL Studio来制作音乐的。今天小编就以FL Studio五年的资深用户…

【数据结构(二)】队列(2)

文章目录 1. 队列的应用场景和介绍1.1. 队列的一个使用场景1.2. 队列介绍 2. 数组模拟队列2.1. 思路分析2.2. 代码实现 3. 数组模拟环形队列3.1. 思路分析3.2. 代码实现 1. 队列的应用场景和介绍 1.1. 队列的一个使用场景 银行排队的案例&#xff1a; 1.2. 队列介绍 队列是一…