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

本文参与极术社区的《基于安谋科技STAR-MC1的XR806开发板试用》活动。

一、例程编译、烧录确认
首先按照全志在线文档平台的点灯教程确保能正常编译、烧录和点灯：https://xr806.docs.aw-ol.com/study/soft_led/
确保例程没问题后，我们再改造例程，实现我们想要的功能

二、代码编写
我们将led工程复制一份改文件夹名为mydemo，目录结构如下

    mydemo
    ├── BUILD.gn
    └── src
    └── main.c
1
2
3
4

然后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"
   ]
}
1
2
3
4
5
6
7
8
9
10
11
12

接下来是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);
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
230
231
232
233
234
235
236
237
238
239
240
241
242
243
244
245
246
247
248
249
250
251
252
253
254
255
256
257
258
259
260
261
262
263
264
265
266
267
268
269
270
271
272
273
274
275
276
277
278
279
280
281
282
283
284
285
286
287
288
289
290
291
292
293
294
295
296
297
298
299
300
301
302
303
304
305
306
307
308
309
310
311
312
313
314
315
316
317
318
319
320
321
322
323
324
325
326
327
328
329
330
331
332
333
334
335
336
337
338

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

group("ohosdemo") {
    deps = [
        #"hello_demo:app_hello",
        #"iot_peripheral:app_peripheral",
        #"wlan_demo:app_WlanTest",
        "mydemo:app_mydemo",
    ]
}
1
2
3
4
5
6
7
8

然后执行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
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72

可以看到，开发板成功连接路由器，并接入了MQTT服务器

五、手机测试
本人的手机是Iphone，也不会手机APP开发，于是我们下载了一个叫MQTTTool的第三方APP验证点灯，其界面如下:

Host和Port填对，由于是免费开放的MQTT服务器，其他参数任意，设置好以后点Connect即可连接上MQTT服务器。然后底部切换至Subscribe栏，订阅主题：

若手机比设备先连接服务器并订阅相关主题，那么你会在订阅栏收到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

部分日志如下:

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
1
2
3
4
5
6
7
8

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