[问答]

如何通过MQTT实现手机远程实现PWM控灯？

965 MQTT

问答对人有帮助，内容完整，我也想知道答案 0 如何通过MQTT实现手机远程实现PWM控灯？ 0
2021-12-29 06:24:48　　评论淘帖0 邀请回答您可以邀请以下用户，快速回答问题 × 文小二该类别下有 5 个回答。邀请回答 yqdedli 该类别下有 4 个回答。邀请回答 hfgdf 该类别下有 3 个回答。邀请回答倪love 该类别下有 3 个回答。邀请回答梅利号该类别下有 3 个回答。邀请回答 caosurround 该类别下有 3 个回答。邀请回答 heks 该类别下有 3 个回答。邀请回答 LL-LING宁该类别下有 3 个回答。邀请回答 yu1004402274 该类别下有 3 个回答。邀请回答笑过就走该类别下有 3 个回答。邀请回答 zym123456 该类别下有 3 个回答。邀请回答 fdvcxhtg 该类别下有 2 个回答。邀请回答 elecfans 该类别下有 2 个回答。邀请回答 kingnet6688 该类别下有 2 个回答。邀请回答 sjjs001 该类别下有 2 个回答。邀请回答大头该类别下有 2 个回答。邀请回答 bertvwang 该类别下有 2 个回答。邀请回答 fdjslkjd 该类别下有 2 个回答。邀请回答 tinlyxian 该类别下有 2 个回答。邀请回答 yuxiangxyz 该类别下有 2 个回答。邀请回答举报杨春林相关推荐 • 如何去实现手机远程给LED进行PWM调光呢 2175 • 请问esp8266如何通过mqtt协议建立连接实现小车的远程控制？ 2414 • 怎样使用Web页面去远程点亮led灯呢 1079 • 如何通过定时器产生PWM波控制LED实现呼吸灯的效果？ 1466 • 使用PWM控制LED实现呼吸灯的效果 2616 • 手机APP远程控制开关 17541 • 如何通过串口实现对灯亮度的控制？ 1746 • 如何通过XDRP实现Windows远程访问？ 1653 • 请问怎么用wifi ESP8266同时实现手机近距离直接连接和通过路由器远程连接？ 5179 • 如何实现手机控制小车的行进？ 1331 1个回答

答案对人有帮助，有参考价值 0 一、例程编译、烧录确认首先按照全志在线文档平台的点灯教程确保能正常编译、烧录和点灯：https://xr806.docs.aw-ol.com/... 确保例程没问题后，我们再改造例程，实现我们想要的功能二、代码编写我们将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 #include #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 (21024) 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 memoryn"); return -1; } recv_buf = malloc(MQTT_DEMO_BUF_SIZE); if (recv_buf == NULL) { free(send_buf); printf("no memoryn"); 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:%sn", ret, host_name, host_port); goto exit; } ret = MQTTConnect(&mqtt_demo_client, &mqtt_demo_connectData); if (ret != 0) { printf("mqtt connect faild, ret:%dn", ret); mqtt_demo_network.disconnect(&mqtt_demo_network); goto exit; } printf("mqtt connectedn"); exit: return ret; } static void mqtt_demo_msg_cb(MessageData data) { printf("get a message, topic: %.s, msg: %.sn", 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 errorn", __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:%dn", 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:%dn", 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:%dn", 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:%dn", 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:%dn", ret); reconnect: printf("mqtt reconnectn"); 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_UPn"); 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 startrn"); 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 errorn", __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 errorn", __func__, __LINE__); printf("max_duty_ratio=%dn", max_duty_ratio); status = HAL_PWM_ChSetDutyRatio(PWM_OUTPUT_CHL, 0); if (status != HAL_OK) printf("%s(): %d, PWM set duty ratio errorn", __func__, __LINE__); status = HAL_PWM_EnableCh(PWM_OUTPUT_CHL, PWM_OUTPUT_MODE, 1); if (status != HAL_OK) printf("%s(): %d, PWM ch enable errorn", __func__, __LINE__); if (WIFI_SUCCESS != EnableWifi()) { printf("Error: EnableWifi failn"); 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.ssid); printf("securityType: %dn", scan_results.securityType); if (0 == strcmp(scan_results.ssid, ssid_want_connect)) { memcpy(config.ssid, scan_results.ssid, WIFI_MAX_SSID_LEN); memcpy(config.bssid, scan_results.bssid, WIFI_MAC_LEN); strcpy(config.preSharedKey, psk); config.securityType = scan_results.securityType; config.wapiPskType = WIFI_PSK_TYPE_ASCII; config.freq = scan_results.frequency; break; } } if (i >= scan_num) { printf("Error: No found ssid in scan_resultsn"); return; } if (WIFI_SUCCESS != AddDeviceConfig(&config, &netId)) { printf("Error: AddDeviceConfig Failn"); return; } printf("Config Successn"); if (WIFI_SUCCESS != ConnectTo(netId)) { printf("Error: ConnectTo Failn"); 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 Failedn"); } } 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 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 [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 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验证点灯，其界面如下: 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 部分日志如下: 以上就是一个手机远程给LED进行PWM调光的应用实例 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 可以远程开电脑

2021-12-29 09:26:02 评论举报李洁