Navigation

    全志在线开发者论坛

    • Register
    • Login
    • Search
    • Categories
    • Tags
    • 在线文档
    • 社区主页

    【XR806开发板试用】通过MQTT实现手机远程实现PWM控灯

    Wireless & Analog Series
    2
    2
    1266
    Loading More Posts
    • Oldest to Newest
    • Newest to Oldest
    • Most Votes
    Reply
    • Reply as topic
    Log in to reply
    This topic has been deleted. Only users with topic management privileges can see it.
    • Z
      zwmasdf LV 3 last edited by

      一、例程编译、烧录确认
      首先按照全志在线文档平台的点灯教程确保能正常编译、烧录和点灯:https://xr806.docs.aw-ol.com/study/soft_led/
      确保例程没问题后,我们再改造例程,实现我们想要的功能
      二、代码编写
      我们将led工程复制一份改文件夹名为mydemo,目录结构如下

          mydemo
          ├── BUILD.gn
          └── src
          └── main.c
      

      然后BUILD.gn内容增加头文件引用,部分配置如下:

      static_library("app_mydemo") {
      ...
      include_dirs += [
            "//kernel/liteos_m/kernel/arch/include",
            "//base/iot_hardware/peripheral/interfaces/kits",
      
            ".",
            "//utils/native/lite/include",
            "//foundation/communication/wifi_lite/interfaces/wifiservice",
            "//device/xradio/xr806/xr_skylark/project"
         ]
      }
      

      接下来是main.c,内容如下:

      #include <stdio.h>
      #include <string.h>
      #include "ohos_init.h"
      #include "kernel/os/os.h"
      
      #include "iot_gpio.h"
      #include "wifi_device.h"
      #include "common/framework/net_ctrl.h"
      #include "net/mqtt/MQTTClient-C/MQTTClient.h"
      #include "driver/chip/hal_pwm.h"
      
      static OS_Thread_t g_main_thread;
      static OS_Thread_t g_mqtt_thread;
      
      #define PWM_OUTPUT_CHL        PWM_GROUP1_CH2
      #define PWM_OUTPUT_MODE       PWM_CYCLE_MODE
      
      #define WIFI_DEVICE_CONNECT_AP_SSID "ssid"//这里填你家路由器的SSID
      #define WIFI_DEVICE_CONNECT_AP_PSK "pwm"//这里填你家路由器的PWD
      
      
      #define MQTT_DEMO_CLIENT_ID "12345"
      #define MQTT_DEMO_HOST_NAME "broker-cn.emqx.io"//这个是免费调试用的MQTT服务器地址
      #define MQTT_DEMO_PORT      "1883"
      #define MQTT_DEMO_USERNAME  "12345678"
      #define MQTT_DEMO_PASSWORD  "12345678"
      #define MQTT_RESP_TOPIC "/to/master/light" //手机发出来的TOPIC
      #define MQTT_RECV_TOPIC  "/to/slave/light" //设备发出来的TOPIC
      #define MQTT_DEMO_BUF_SIZE (2*1024)
      
      static MQTTPacket_connectData mqtt_demo_connectData = MQTTPacket_connectData_initializer;
      static Client mqtt_demo_client;
      static Network mqtt_demo_network;
      static int max_duty_ratio = 0;
      
      static int mqtt_demo_publish(char *topic, char *msg) ;
      
      static int mqtt_demo_init(void) {
      	char *send_buf;
      	char *recv_buf;
      
      	mqtt_demo_connectData.clientID.cstring = MQTT_DEMO_CLIENT_ID;
      	mqtt_demo_connectData.keepAliveInterval = 30; // 30s
      	mqtt_demo_connectData.cleansession = 0;
      	mqtt_demo_connectData.MQTTVersion = 4; //Version of MQTT 3.1.1
      
      	send_buf = malloc(MQTT_DEMO_BUF_SIZE);
      	if (send_buf == NULL) {
      		printf("no memory\n");
      		return -1;
      	}
      	recv_buf = malloc(MQTT_DEMO_BUF_SIZE);
      	if (recv_buf == NULL) {
      		free(send_buf);
      		printf("no memory\n");
      		return -1;
      	}
      
      	/* init network */
      	NewNetwork(&mqtt_demo_network);
      	/* init mqtt client object */
      	MQTTClient(&mqtt_demo_client, &mqtt_demo_network, 6000,
      	           (unsigned char *)send_buf, MQTT_DEMO_BUF_SIZE,
      	           (unsigned char *)recv_buf, MQTT_DEMO_BUF_SIZE);
      
      	/* set username and password */
      	mqtt_demo_connectData.username.cstring = MQTT_DEMO_USERNAME;
      	mqtt_demo_connectData.password.cstring = MQTT_DEMO_PASSWORD;
      	return 0;
      }
      
      static int mqtt_demo_connect(char *host_name, char *host_port) {
      	int ret = -1;
      
      	ret = ConnectNetwork(&mqtt_demo_network, host_name, atoi(host_port));
      	if (ret != 0) {
      		printf("mqtt connect faild, ret:%d, host:%s, port:%s\n", ret, host_name, host_port);
      		goto exit;
      	}
      
      	ret = MQTTConnect(&mqtt_demo_client, &mqtt_demo_connectData);
      	if (ret != 0) {
      		printf("mqtt connect faild, ret:%d\n", ret);
      		mqtt_demo_network.disconnect(&mqtt_demo_network);
      		goto exit;
      	}
      	printf("mqtt connected\n");
      exit:
      	return ret;
      }
      
      static void mqtt_demo_msg_cb(MessageData *data) {
      	printf("get a message, topic: %.*s, msg: %.*s\n", data->topicName->lenstring.len,
      	       data->topicName->lenstring.data, data->message->payloadlen,
      	       (char *)data->message->payload);
      	if(!strncmp(data->topicName->lenstring.data, "/to/slave/light", 15) && data->message->payloadlen) {
      		char *payload = data->message->payload;
      		char str[8] = "";
      		int max_len = data->message->payloadlen > 3 ? 3 : data->message->payloadlen;
      		strncpy(str, payload, max_len);
      		int duty = atoi(str);
      		HAL_Status status = HAL_PWM_ChSetDutyRatio(PWM_OUTPUT_CHL, duty * max_duty_ratio / 100);
      		if (status != HAL_OK)
      			printf("%s(): %d, PWM set duty ratio error\n", __func__, __LINE__);
      		
      		if(duty) {
      			mqtt_demo_publish(MQTT_RESP_TOPIC, "light on");
      		} else {
      			mqtt_demo_publish(MQTT_RESP_TOPIC, "light off");
      		}
      	} 
      }
      
      static int mqtt_demo_subscribe(char *topic) {
      	int ret = -1;
      	if (mqtt_demo_client.isconnected) {
      		ret = MQTTSubscribe(&mqtt_demo_client, topic, 0, mqtt_demo_msg_cb);
      		if (ret != 0)
      			printf("mqtt subscribe faild ret:%d\n", ret);
      	}
      	return ret;
      }
      
      static int mqtt_demo_unsubscribe(char *topic) {
      	int ret = -1;
      	if (mqtt_demo_client.isconnected) {
      		ret = MQTTUnsubscribe(&mqtt_demo_client, topic);
      		if (ret != 0)
      			printf("mqtt unsubscribe faild, ret:%d\n", ret);
      	}
      	return ret;
      }
      
      static int mqtt_demo_publish(char *topic, char *msg) {
      	int ret = -1;
      
      	MQTTMessage message;
      	memset(&message, 0, sizeof(message));
      	message.qos = 0;
      	message.retained = 0; /* disable retain the message in server */
      	message.payload = msg;
      	message.payloadlen = strlen(msg);
      	ret = MQTTPublish(&mqtt_demo_client, topic, &message);
      	if (ret != 0)
      		printf("mqtt publish faild, ret:%d\n", ret);
      	return ret;
      }
      
      static int mqtt_demo_disconnect(void) {
      	int ret = -1;
      
      	if (mqtt_demo_client.isconnected) {
      		ret = MQTTDisconnect(&mqtt_demo_client);
      		if (ret != 0)
      			printf("mqtt disconnect fail, ret:%d\n", ret);
      		mqtt_demo_network.disconnect(&mqtt_demo_network);
      	}
      	return ret;
      }
      
      static void mqtt_demo_deinit(void) {
      	if (mqtt_demo_client.buf) {
      		free(mqtt_demo_client.buf);
      		mqtt_demo_client.buf = NULL;
      	}
      	if (mqtt_demo_client.readbuf) {
      		free(mqtt_demo_client.readbuf);
      		mqtt_demo_client.readbuf = NULL;
      	}
      }
      
      static void mqtt_task(void *arg)   {
      	int ret;
      	int reconnect_times = 0;
      
      	mqtt_demo_init();
      
      	ret = mqtt_demo_connect(MQTT_DEMO_HOST_NAME, MQTT_DEMO_PORT);
      	if (ret != 0)
      		goto exit;
      
      	ret = mqtt_demo_subscribe(MQTT_RECV_TOPIC);
      	if (ret != 0)
      		goto exit;
      
      	mqtt_demo_publish(MQTT_RESP_TOPIC, "light ready");
      
      	while (1) {
      		ret = MQTTYield(&mqtt_demo_client, 300);
      		if (ret != 0) {
      			printf("mqtt yield err, ret:%d\n", ret);
      reconnect:
      			printf("mqtt reconnect\n");
      			mqtt_demo_disconnect();
      			ret = mqtt_demo_connect(MQTT_DEMO_HOST_NAME, MQTT_DEMO_PORT);
      			if (ret != 0) {
      				reconnect_times++;
      				if (reconnect_times > 5)
      					goto exit;
      				OS_MSleep(5000); //5s
      				goto reconnect;
      			}
      		}
      	}
      
      exit:
      	mqtt_demo_unsubscribe(MQTT_RECV_TOPIC);
      	mqtt_demo_disconnect();
      	mqtt_demo_deinit();
      	OS_ThreadDelete(&g_mqtt_thread);
      }
      
      static void net_cb(uint32_t event, uint32_t data, void *arg) {
      	uint16_t type = EVENT_SUBTYPE(event);
      	switch (type) {
      	case NET_CTRL_MSG_NETWORK_UP:
      		printf("NET_CTRL_MSG_NETWORK_UP\n");
      		if (!OS_ThreadIsValid(&g_mqtt_thread)) {
      			OS_ThreadCreate(&g_mqtt_thread, "connect_to_server_task",
      			                    mqtt_task, (void *)NULL,  OS_THREAD_PRIO_APP, (8 * 1024));
      		}
      		break;
      	case NET_CTRL_MSG_NETWORK_DOWN:
      		break;
      	default:
      		break;
      	}
      }
      
      static void MainThread(void *arg)   {
      	printf("MainThread start\r\n");
      	HAL_Status status = HAL_ERROR;
      	PWM_ClkParam clk_param;
      	PWM_ChInitParam ch_param;
      
      	clk_param.clk = PWM_CLK_HOSC;
      	clk_param.div = PWM_SRC_CLK_DIV_1;
      
      	status = HAL_PWM_GroupClkCfg(PWM_OUTPUT_CHL, &clk_param);
      	if (status != HAL_OK)
      		printf("%s(): %d, PWM group clk config error\n", __func__, __LINE__);
      
      	ch_param.hz = 1000;
      	ch_param.mode = PWM_OUTPUT_MODE;
      	ch_param.polarity = PWM_HIGHLEVE;
      	max_duty_ratio = HAL_PWM_ChInit(PWM_OUTPUT_CHL, &ch_param);
      	if (max_duty_ratio == -1)
      		printf("%s(): %d, PWM ch init error\n", __func__, __LINE__);
      
      	printf("max_duty_ratio=%d\n", max_duty_ratio);
      	status = HAL_PWM_ChSetDutyRatio(PWM_OUTPUT_CHL, 0);
      	if (status != HAL_OK)
      		printf("%s(): %d, PWM set duty ratio error\n", __func__, __LINE__);
      
      	status = HAL_PWM_EnableCh(PWM_OUTPUT_CHL, PWM_OUTPUT_MODE, 1);
      	if (status != HAL_OK)
      		printf("%s(): %d, PWM ch enable error\n", __func__, __LINE__);
      
      	if (WIFI_SUCCESS != EnableWifi()) {
      		printf("Error: EnableWifi fail\n");
      		return;
      	}
      
      	OS_Sleep(1);
      
      	if (WIFI_SUCCESS != Scan()) {
      		printf("Error: Scan fail.\n");
      		return;
      	}
      
      	OS_Sleep(3);//这里为了方便用延时,实际用回调更好,否则3秒可能不够
      
      	const char ssid_want_connect[] = WIFI_DEVICE_CONNECT_AP_SSID;
      	const char psk[] = WIFI_DEVICE_CONNECT_AP_PSK;
      	WifiScanInfo scan_results[30];
      	unsigned int scan_num = 30;
      
      	if (WIFI_SUCCESS != GetScanInfoList(scan_results, &scan_num)) {
      		printf("Error: GetScanInfoList fail.\n");
      		return;
      	}
      
      	WifiDeviceConfig config = { 0 };
      	int netId = 0;
      
      	int i;
      	for (i = 0; i < scan_num; i++) {
      		printf("ssid: %s    ", scan_results[i].ssid);
      		printf("securityType: %d\n", scan_results[i].securityType);
      		if (0 == strcmp(scan_results[i].ssid, ssid_want_connect)) {
      			memcpy(config.ssid, scan_results[i].ssid,
      			       WIFI_MAX_SSID_LEN);
      			memcpy(config.bssid, scan_results[i].bssid,
      			       WIFI_MAC_LEN);
      			strcpy(config.preSharedKey, psk);
      			config.securityType = scan_results[i].securityType;
      			config.wapiPskType = WIFI_PSK_TYPE_ASCII;
      			config.freq = scan_results[i].frequency;
      			break;
      		}
      	}
      
      	if (i >= scan_num) {
      		printf("Error: No found ssid in scan_results\n");
      		return;
      	}
      
      	if (WIFI_SUCCESS != AddDeviceConfig(&config, &netId)) {
      		printf("Error: AddDeviceConfig Fail\n");
      		return;
      	}
      	printf("Config Success\n");
      
      	if (WIFI_SUCCESS != ConnectTo(netId)) {
      		printf("Error: ConnectTo Fail\n");
      		return;
      	}
      	
      	observer_base *net_ob;
      	net_ob = sys_callback_observer_create(CTRL_MSG_TYPE_NETWORK, NET_CTRL_MSG_ALL, net_cb, NULL);
      	if (net_ob == NULL)
      		return;
      
      	if (sys_ctrl_attach(net_ob) != 0)
      		return;
      
      	while (1) {
      		OS_MSleep(500);
      	}
      }
      
      void LEDMain(void) {
      	if (OS_ThreadCreate(&g_main_thread, "MainThread", MainThread, NULL, OS_THREAD_PRIO_APP, 4 * 1024) != OS_OK) {
      		printf("[ERR] Create MainThread Failed\n");
      	}
      }
      
      SYS_RUN(LEDMain);
      

      三、配置上层的BUILD.gn,并编译
      部分内容如下:

      group("ohosdemo") {
          deps = [
              #"hello_demo:app_hello",
              #"iot_peripheral:app_peripheral",
              #"wlan_demo:app_WlanTest",
              "mydemo:app_mydemo",
          ]
      }
      

      然后执行hb build -f,编译成功(若编译失败见论坛有解决方案)
      然后烧录到开发板上
      四、运行实例
      烧录完成后,开发板重新上电,输出如下日志

      ====================================================================
      	Hello! OpenHarmony!
      	System tag : OpenHarmony 1.1.2_LTS
      ====================================================================
      	
      use default flash chip mJedec 0x0
      [FD I]: mode: 0x10, freq: 96000000Hz, drv: 0
      [FD I]: jedec: 0x0, suspend_support: 1
      mode select:e
      
      wlan information ===================================================
      firmware:
          version : R0-XR_C07.08.52.65_02.84 May 27 2021 11:41:33-Y02.84 
          buffer  : 8
      driver:
          version : XR_V02.05
      mac address:
          in use        : 1c:98:c9:bc:50:01
          in use        : 1c:98:c9:bc:50:02
      ====================================================================
      
      wlan mode:a
      [VFS INF] LittleFS mount success.
      
      platform information ===============================================
      XR806 SDK v1.2.0  Dec 13 2021 13:06:05
      
      heap space [0x2238d0, 0x24bc00), size 164656
      
      cpu  clock 160000000 Hz
      HF   clock  40000000 Hz
      
      sdk option:
          XIP           : enable
          INT LF OSC    : enable
          SIP flash     : enable
      
      mac address:
          efuse         : 80:74:84:21:38:8e
          in use        : 1c:98:c9:bc:50:01
      ====================================================================
      
      hiview init success.MainThread start
      
      max_duty_ratio=40000
      
      
      console init success
      
      [net INF] no need to switch wlan mode 0
      [net INF] msg <wlan scan success>
      ssid: TP-LINK_A668    securityType: 2
      Config Success
      [net INF] no need to switch wlan mode 0
      en1: Trying to associate with a4:c7:4b:71:f9:84 (SSID='XXXXXX' freq=2462 MHz)
      en1: Associated with a4:c7:4b:71:f9:84
      en1: WPA: Key negotiation completed with a4:c7:4b:71:f9:84 [PTK=CCMP GTK=CCMP]
      en1: CTRL-EVENT-CONNECTED - Connection to a4:c7:4b:71:f9:84 completed [id=0 id_str=]
      [net INF] msg <wlan connected>
      [net INF] netif is link up
      [net INF] start DHCP...
      [net INF] IPv6 addr state change: 0x0 --> 0x1
      [net INF] msg <>
      [net INF] netif (IPv4) is up
      [net INF] address: 192.168.3.48
      [net INF] gateway: 192.168.3.1
      [net INF] netmask: 255.255.255.0
      [net INF] msg <network IPv6 state>
      NET_CTRL_MSG_NETWORK_UP
      WAR drop=1117, fctl=0x00d0.
      mqtt connected
      get a message, topic: /to/slave/light, msg: 0
      

      可以看到,开发板成功连接路由器,并接入了MQTT服务器
      五、手机测试
      本人的手机是Iphone,也不会手机APP开发,于是我们下载了一个叫MQTTTool的第三方APP验证点灯,其界面如下:
      1e9f62ad-9c5b-4255-b85b-b43db8f2de07-image.png
      Host和Port填对,由于是免费开放的MQTT服务器,其他参数任意,设置好以后点Connect即可连接上MQTT服务器。然后底部切换至Subscribe栏,订阅主题:
      0bca5012-7907-45fc-9d34-89fbc7c91c57-image.png
      若手机比设备先连接服务器并订阅相关主题,那么你会在订阅栏收到topic为/to/master/light的消息:light ready,这是因为设备连上服务器就会发布该topic。
      接下来是发布主题,我们往/to/slave/light主题发送一个0~100的数字,就会让设备以这个数字为占空比控制LED灯亮灭,如0表示灭灯,50表示50%的占空比驱动LED灯,100表示100%的占空比驱动LED灯。同时设备收到LED控制指令后,若占空比不为0,则发送消息light on,否则发送消息light off
      031393e7-f44b-4062-9258-7171bcad5402-image.png
      79781989-d3af-43bd-b320-82c8b78784b3-image.png
      1c54a800-83f4-4921-9d1a-055cc2b5b91b-image.png
      部分日志如下:

      WAR drop=1117, fctl=0x00d0.
      mqtt connected
      get a message, topic: /to/slave/light, msg: 0
      [net INF] IPv6 addr state change: 0x0 --> 0x1
      [net INF] msg <>
      get a message, topic: /to/slave/light, msg: 100
      get a message, topic: /to/slave/light, msg: 100
      get a message, topic: /to/slave/light, msg: 50
      

      以上就是一个手机远程给LED进行PWM调光的应用实例

      1 Reply Last reply Reply Quote Share 1
      • H
        HU_710774265 LV 4 last edited by

        可以远程开电脑😋

        1 Reply Last reply Reply Quote Share 0
        • 1 / 1
        • First post
          Last post

        Copyright © 2024 深圳全志在线有限公司 粤ICP备2021084185号 粤公网安备44030502007680号

        行为准则 | 用户协议 | 隐私权政策