小凌派鸿蒙社区
直播中

voidpbq

8年用户 131经验值
擅长:嵌入式技术,处理器/DSP
私信 关注

【小凌派RK2206开发板试用体验】4. mqtt发送消息到腾讯云

1 前言
本章介绍下使用mqtt示例发送消息。

2 代码
2.1 示例bug
官方示例：https://gitee.com/Lockzhiner-Ele ... iot_mqtt/iot_mqtt.c
1.png
这里有一个bug，不知道后续有没有改回来，注意一下。
2.2 main.c
  1. /*
  2. * Copyright (c) 2022 FuZhou Lockzhiner Electronic Co., Ltd. All rights reserved.
  3. * Licensed under the Apache License, Version 2.0 (the "License");
  4. * you may not use this file except in compliance with the License.
  5. * You may obtain a copy of the License at
  6. *
  7. *     http://www.apache.org/licenses/LICENSE-2.0
  8. *
  9. * Unless required by applicable law or agreed to in writing, software
  10. * distributed under the License is distributed on an "AS IS" BASIS,
  11. * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  12. * See the License for the specific language governing permissions and
  13. * limitations under the License.
  14. */

  16. #include "los_tick.h"
  17. #include "los_task.h"
  18. #include "los_config.h"
  19. #include "los_interrupt.h"
  20. #include "los_debug.h"
  21. #include "los_compiler.h"
  22. #include "lz_hardware.h"
  23. #include "config_network.h"

  25. #define  MAIN_TAG              "MAIN"
  26. int DeviceManagerStart();
  27. void IotInit(void);
  28. // void NFC_example2();
  29. // void uart_example();
  30. void iot_mqtt_example();
  31. /*****************************************************************************
  32. Function    : main
  33. Description : Main function entry
  34. Input       : None
  35. Output      : None
  36. Return      : None
  37. *****************************************************************************/
  38. LITE_OS_SEC_TEXT_INIT int Main(void)
  39. {
  40.     int ret;
  41.     LZ_HARDWARE_LOGD(MAIN_TAG, "%s: enter ...", __func__);
  42.    
  43.     HalInit();

  45.     ret = LOS_KernelInit();
  46.     if (ret == LOS_OK) {
  47.         IotInit();

  49.         printf("n");
  50.         
  51.         printf("----------- test start -----------n");
  52.         // task_example2();
  53.         // nfc_example2();
  54.         iot_mqtt_example();
  55.         // uart_example();
  56.         printf("----------- test end -----------n");

  58.         printf("n");

  60.         OHOS_SystemInit();
  61.         ClkDevInit();
  62.         /* 开启驱动管理服务 */
  63.         //DeviceManagerStart();
  64.         // ExternalTaskConfigNetwork();
  65.         LZ_HARDWARE_LOGD(MAIN_TAG, "%s: LOS_Start ...", __func__);
  66.         LOS_Start();
  67.     }

  69.     while (1) {
  70.         __asm volatile("wfi");
  71.     }
  72. }
PS：ExternalTaskConfigNetwork需要在main中先注释掉。

2.3 更改wifi账号和密码
lockzhiner-rk2206-openhARMony3.0ltsdevicerockchiprk2206sdk_liteosboardsrcconfig_network.c
2.png

2.4 MQTT账号与密码设置
初始化
  1. typedef struct
  2. {
  3.         /** The eyecatcher for this structure.  must be MQTC. */
  4.         char struct_id[4];
  5.         /** The version number of this structure.  Must be 0 */
  6.         int struct_version;
  7.         /** Version of MQTT to be used.  3 = 3.1 4 = 3.1.1
  8.           */
  9.         unsigned char MQTTVersion;
  10.         MQTTString clientID;
  11.         unsigned short keepAliveInterval;
  12.         unsigned char cleansession;
  13.         unsigned char willFlag;
  14.         MQTTPacket_willOptions will;
  15.         MQTTString username;
  16.         MQTTString password;
  17. } MQTTPacket_connectData;


  20. #define MQTTPacket_connectData_initializer { {'M', 'Q', 'T', 'C'}, 0, 4, {NULL, {0, NULL}}, 60, 1, 0,
  21.                 MQTTPacket_willOptions_initializer, {NULL, {0, NULL}}, {NULL, {0, NULL}} }
仿照着添加mqtt账号和密码

这里使用的是示例的代码。增加账号和密码即可
  1. begin:
  2.     printf("NetworkConnect...n");
  3.     rc = NetworkConnect(&network, MQTT_HOST, MQTT_PORT);

  5.     printf("MQTTClientInit...n");
  6.     MQTTClientInit(&client, &network, 2000, sendBuf, sizeof(sendBuf), readBuf, sizeof(readBuf));

  8.     clientId.cstring = "RK2206-youkai";

  10.     data.clientID          = clientId;
  11.     data.willFlag          = 0;
  12.     data.MQTTVersion       = 3;
  13.     data.keepAliveInterval = 0;
  14.     data.cleansession      = 1;

  16.     // youkai add
  17.     MQTTString username_t = MQTTString_initializer;
  18.     username_t.cstring = "mqtt_id";
  19.     MQTTString password_t = MQTTString_initializer;
  20.     password_t.cstring = "mqtt_pw";
  21.     data.password = password_t;
  22.     data.username = username_t;

2.5 发送接口
接口比较简单，MQTTPublish用于发送消息，其中IOT_MQTT也就是消息本身，可以注意服务器的接收内容。
  1.     while (1)
  2.     {
  3.         sprintf(payload, "publish test");
  4.         message.qos = 2;
  5.         message.retained = 0;
  6.         message.payload = payload;
  7.         message.payloadlen = strlen(payload);

  9.         if ((rc = MQTTPublish(&client, "IOT_MQTT", &message)) != 0){
  10.             printf("Return code from MQTT publish is %dn", rc);
  11.             NetworkDisconnect(&network);
  12.             MQTTDisconnect(&client);
  13.             goto begin;
  14.         }

  16.         LOS_Msleep(5000);
  17.     }

3 结果
小凌派log
3.png
服务器log
4.png

4 小结
本章测试了官方的mqtt实例，后续需要结合多台设备实现mqtt的收发功能。
腾讯云的mqtt服务器搭建可以参见：https://blog.csdn.net/qq_38091632/article/details/124990369

更多回帖

0 0 0

相关帖子

小凌派 RK2206 开发板
发帖
电子发烧友APP
|投诉反馈|电子发烧友网
© 2021 bbs.elecfans.com
湘ICP备2023018690号
×
20
完善资料，
赚取积分