二十八、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.mzph.cn/news/146638.shtml

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

相关文章

gorm的简单操作

1. 什么是orm ORM全称是&#xff1a;Object Relational Mapping(对象关系映射)&#xff0c;其主要作用是在编程中&#xff0c;把面向对象的概念跟数据库中表的概念对应起来。举例来说就是&#xff0c;我定义一个对象&#xff0c;那就对应着一张表&#xff0c;这个对象的实例&a…

无需添加udid,ios企业证书的自助生成方法

我们开发uniapp的app的时候&#xff0c;需要苹果证书去打包。 假如申请的是个人或company类型的苹果开发者账号&#xff0c;必须上架才能安装&#xff0c;异常的麻烦&#xff0c;但是有一些app&#xff0c;比如企业内部使用的app&#xff0c;是不需要上架苹果应用市场的。 假…

Redis篇---第六篇

系列文章目录 文章目录 系列文章目录前言一、Redis 为什么设计成单线程的?二、什么是 bigkey?会存在什么影响?三、熟悉哪些 Redis 集群模式?前言 前些天发现了一个巨牛的人工智能学习网站,通俗易懂,风趣幽默,忍不住分享一下给大家。点击跳转到网站,这篇文章男女通用,…

MySQL存储架构

连接管理与安全性 每个客户端连接都会在服务器进程中拥有一个线程&#xff0c;这个连接的查询只会在这个线程中执行。MySQL5.5以后支持了一个API叫线程池插件&#xff0c;可以用少量线程服务大量连接&#xff0c;因此不用每次都新建连接然后销毁。 客户端连接MySQL服务器时候&…

酷柚易汛ERP - 系统初始化操作指南

1、应用场景 重新初始化将会清空系统数据&#xff0c;恢复至新系统初始创建的状态&#xff0c;且不可逆转&#xff0c;请谨慎操作&#xff01; 初始化系统需要验证管理员密码&#xff0c;密码输入正确后即可开始初始化系统

使用maven命令打包依赖

1、maven仓库地址 阿里云地址&#xff1a;https://developer.aliyun.com/mvn/search 中央仓库地址&#xff1a;https://mvnrepository.com/ 2、下载方式 在地址栏中输入要搜索的依赖 选择需要的版本 &#xff08;1&#xff09;直接复制 &#xff08;2&#xff09;pom下载 …

4.5 Windows驱动开发:实现进程数据转储

多数ARK反内核工具中都存在驱动级别的内存转存功能&#xff0c;该功能可以将应用层中运行进程的内存镜像转存到特定目录下&#xff0c;内存转存功能在应对加壳程序的分析尤为重要&#xff0c;当进程在内存中解码后&#xff0c;我们可以很容易的将内存镜像导出&#xff0c;从而更…

汽车 CAN\CANFD数据记录仪

CAN FD数据记录仪解决汽车电子数据记录与偶发性故障查找问题。 1、脱机离线记录两路CAN/CANFD通道数据 脱机离线记录两路CAN/CANFD通道数据&#xff0c;可记录6个月数据。每个通 道单独设置触发记录模式、触发前预记录报文个数&#xff08;默认1000帧&#xff09;及 过滤规则&a…

JavaScript 浮点数运算的精度问题及解决

JavaScript 浮点数运算的精度问题及解决 在 JavaScript 中整数和浮点数都属于 Number 数据类型&#xff0c;当浮点数做数学运算的时候&#xff0c;你经常会发现一些问题&#xff0c;举几个例子&#xff1a; 0.1 0.2 0.30000000000000004 console.log(0.1 0.2) 0.3000000…

C# Socket通信从入门到精通(9)——如何设置本机Ip地址

前言&#xff1a; 我们开发好Socket通信程序以后&#xff0c;上机调试的时候&#xff0c;首先要做的就是先设置好电脑的IP&#xff0c;这样才能实现不同的电脑之间的通信&#xff0c;并且电脑1的ip地址和电脑2的Ip地址要同处于一个网段&#xff0c;比如电脑1的Ip地址为192.168…

《少儿编程启蒙指南》

《少儿编程启蒙指南》大纲 本文详细阐述少儿编程启蒙&#xff0c;如果有人喜欢&#xff0c;往后我会继续更新迭代此文。 “Everyone should know how to program a computer, because it teaches you how to think.”—Steve Jobs 每个人都应该知道如何编程&#xff0c;因为它…

VS 将 localhost访问改为ip访问

项目场景&#xff1a; 使用vs进行本地调试时需要多人访问界面,使用ip访问报错 问题描述 vs通过ip访问报错 虚拟机或其它电脑不能正常打开 原因分析&#xff1a; 原因是vs访问规则默认是iis,固定默认启动地址是localhost 解决方案&#xff1a; 1.vs项目启动之后会出现这个 右…

flutter开发web应用支持浏览器跨域设置

开发web应用难免会遇到跨域问题&#xff0c;所以flutter设置允许web跨域的设置是要在你的flutter安装路径下面 flutter\bin\cache 找到flutter_tools.stamp文件&#xff0c;然后删除掉&#xff1a;这个文件是临时缓存文件 然后找到 flutter\packages\flutter_tools\lib\src\web…

Linux脚本shell中将Windos格式字符转换为unix

众所周知&#xff0c;windos的文档直接复制到linux服务器上去&#xff0c;是需要进行格式转换的&#xff0c;否则可能出现以下报错&#xff1a; 解决方法&#xff1a; vim 脚本 输入 :set ff ##会显示字符格式 :set ffunix ##转换为unix格式 :wq ##保存退出

【Linux】第十八站:进程等待

文章目录 一、进程等待的必要性1.进程等待是什么2.进程等待的必要性3.为什么要进程等待呢&#xff1f; 二、进程等待的方法1.问题2.wait3.waitpid4.status的原理5.等待失败6.与status有关的两个宏7.options 一、进程等待的必要性 1.进程等待是什么 通过系统调用wait/waitpid&a…

微服务基础,分布式核心,常见微服务框架,SpringCloud概述,搭建SpringCloud微服务项目详细步骤,含源代码

微服务基础 系统架构的演变 随着会联网的发展&#xff0c;网站应用的规模不断扩大&#xff0c;常规的应用架构已经无法应对&#xff0c;分布式服务架构以及微服务架构势在必行&#xff0c;必须一个治理系统确保架构有条不紊的演进 单体应用框架 Web应用程序发展的早期&…

PyCharm 远程连接服务器并使用服务器的 Jupyter 环境

❤️觉得内容不错的话&#xff0c;欢迎点赞收藏加关注&#x1f60a;&#x1f60a;&#x1f60a;&#xff0c;后续会继续输入更多优质内容❤️ &#x1f449;有问题欢迎大家加关注私戳或者评论&#xff08;包括但不限于NLP算法相关&#xff0c;linux学习相关&#xff0c;读研读博…

我所理解的 UI Toolkit 启蒙阶段(一)

我所理解的 UI Toolkit 启蒙阶段&#xff08;一&#xff09; 对于自己不会的新东西的学习&#xff0c;我认为最合适的路径就是&#xff1a; 实例教学视频 —> 实操熟悉 —> 官方文档查漏补缺 —> 拟定思路实现功能 但这 4 步并非每一步都需要下 100% 的功夫&#x…

虚拟机上安装docker,并安装flink镜像

1. 安装docker 官网步骤&#xff1a;https://docs.docker.com/engine/install/centos/ sudo yum install -y yum-utils sudo yum-config-manager --add-repo https://download.docker.com/linux/centos/docker-ce.repo sudo yum install docker-ce docker-ce-cli containerd.…

2024年山东省职业院校技能大赛中职组“网络安全”赛项竞赛试题-A

2024年山东省职业院校技能大赛中职组 “网络安全”赛项竞赛试题-A 一、竞赛时间 总计&#xff1a;360分钟 二、竞赛阶段 竞赛阶段 任务阶段 竞赛任务 竞赛时间 分值 A、B模块 A-1 登录安全加固 180分钟 200分 A-2 本地安全策略设置 A-3 流量完整性保护 A-4 …