返回发烧友论坛
发 帖  

[]基于HiSpark_WiFi_IoT智能家居项目实战1-灯光控制UDP版本

pschen083
2020-11-15 15:06:23
阅读量0
HiSpark智能家居
0
2
`        这是一个基于HiSpark_WiFi_IoT智能家居项目实战1-灯光控制例程, 之前有看下润和许老师以及连志安老师视频和开源码,HiSpark_WiFi_IoT Hi3861的底层驱动,和一些移植案例做都非常好,如MQTT,Oled 等,非常感谢他们的付出. 他们的案例很值得我们去学习参考 ,在此,我就不必重复造轮子. 下列是我一个智能家居项目实战1-灯光控制例程, 客户APP端的软件包含一个UDP 服务器, Hi3861只要请求连接成功就可以通讯了.如下图:

具体看源码:
  1. //------------------------------------------------------------------------
  2. //#include "MQTTPacket.h"
  3. #include "transport.h"
  4. #include <stdio.h>
  5. #include <string.h>
  6. #include <unistd.h>
  7. #include "wifi_device.h"
  8. #include "wifiiot_gpio.h"
  9. #include "wifiiot_gpio_ex.h"
  10. #include "lwip/netifapi.h"
  11. #include "lwip/api_shell.h"
  12. #include "net_common.h"
  13. #define PARAM_HOTSPOT_SSID "Honor"   // your AP SSID
  14. #define PARAM_HOTSPOT_PSK  "12345678"  // your AP PSK
  15. #define PARAM_SERVER_ADDR  "192.168.43.36"
  16. #define PARAM_SERVER_PORT   6201
  17. #define PARAM_HOTSPOT_TYPE WIFI_SEC_TYPE_PSK // defined in wifi_device_config.h
  18. #define R_LED WIFI_IOT_GPIO_IDX_10
  19. #define B_LED WIFI_IOT_GPIO_IDX_12
  20. #define G_LED WIFI_IOT_GPIO_IDX_11

  22. static char request[] = "light:0
  23. ";
  24. static char response[128] = "";
  25. static char light_status = 0;

  27. void UdpClient(const char* host, unsigned short port);
  28. static void PrintLinkedInfo(WifiLinkedInfo* info)
  29. {
  30.     if (!info) return;
  31.    static char macAddress[32] = {0};
  32.     unsigned char* mac = info->bssid;
  33.     snprintf(macAddress, sizeof(macAddress), "%02X:%02X:%02X:%02X:%02X:%02X",
  34.         mac[0], mac[1], mac[2], mac[3], mac[4], mac[5]);
  35.     printf("bssid: %s, rssi: %d, connState: %d, reason: %d, ssid: %s
  36. ",
  37.         macAddress, info->rssi, info->connState, info->disconnectedReason, info->ssid);
  38. }
  39. static volatile int g_connected = 0;
  40. static void OnWifiConnectionChanged(int state, WifiLinkedInfo* info)
  41. {
  42.     if (!info) return;
  43.     printf("%s %d, state = %d, info =
  44. ", __FUNCTION__, __LINE__, state);
  45.     PrintLinkedInfo(info);
  46.     if (state == WIFI_STATE_AVALIABLE) {
  47.         g_connected = 1;
  48.     } else {
  49.         g_connected = 0;
  50.     }
  51. }


  54. static void OnWifiScanStateChanged(int state, int size)
  55. {
  56.     printf("%s %d, state = %X, size = %d
  57. ", __FUNCTION__, __LINE__, state, size);
  58. }


  61. static WifiEvent g_defaultWifiEventListener = {
  62.     .OnWifiConnectionChanged = OnWifiConnectionChanged,
  63.     .OnWifiScanStateChanged = OnWifiScanStateChanged
  64. };
  65. static struct netif* g_iface = NULL;


  68. int ConnectToHotspot(WifiDeviceConfig* apConfig)
  69. {
  70.     WifiErrorCode errCode;
  71.     int netId = -1;
  72.     errCode = RegisterWifiEvent(&g_defaultWifiEventListener);
  73.     printf("RegisterWifiEvent: %d
  74. ", errCode);
  75.     errCode = EnableWifi();
  76.     printf("EnableWifi: %d
  77. ", errCode);
  78.    errCode = AddDeviceConfig(apConfig, &netId);
  79.     printf("AddDeviceConfig: %d
  80. ", errCode);
  81.     g_connected = 0;
  82.     errCode = ConnectTo(netId);
  83.     printf("ConnectTo(%d): %d
  84. ", netId, errCode);
  85.     while (!g_connected) { // wait until connect to AP
  86.         osDelay(10);
  87.     }
  88.     printf("g_connected: %d
  89. ", g_connected);
  90.     g_iface = netifapi_netif_find("wlan0");
  91.     if (g_iface) {
  92.         err_t ret = netifapi_dhcp_start(g_iface);
  93.         printf("netifapi_dhcp_start: %d
  94. ", ret);
  95.         osDelay(100); // wait DHCP server give me IP
  96.         ret = netifapi_netif_common(g_iface, dhcp_clients_info_show, NULL);
  97.         printf("netifapi_netif_common: %d
  98. ", ret);
  99.     }
  100.     return netId;
  101. }


  104. void DisconnectWithHotspot(int netId)
  105. {
  106.     if (g_iface) {
  107.         err_t ret = netifapi_dhcp_stop(g_iface);
  108.         printf("netifapi_dhcp_stop: %d
  109. ", ret);
  110.     }
  111.     WifiErrorCode errCode = Disconnect(); // disconnect with your AP
  112.     printf("Disconnect: %d
  113. ", errCode);
  114.     errCode = UnRegisterWifiEvent(&g_defaultWifiEventListener);
  115.     printf("UnRegisterWifiEvent: %d
  116. ", errCode);
  117.     RemoveDevice(netId); // remove AP config
  118.     printf("RemoveDevice: %d
  119. ", errCode);
  120.     errCode = DisableWifi();
  121.     printf("DisableWifi: %d
  122. ", errCode);
  123. }

  125. static void NetDemoTask(void *arg)
  126. {
  127.     (void)arg;
  128.     WifiDeviceConfig config = {0};
  129.     // 准备AP的配置参数
  130.     strcpy(config.ssid, PARAM_HOTSPOT_SSID);
  131.     strcpy(config.preSharedKey, PARAM_HOTSPOT_PSK);
  132.     config.securityType = PARAM_HOTSPOT_TYPE;
  133. for(;;){
  134.     osDelay(10);
  135.     int netId = ConnectToHotspot(&config);
  136.     int timeout = 2;
  137.     while (timeout--) {
  138.         printf("After %d seconds, I will start
  139. ", timeout);
  140.         osDelay(100);
  141.     }
  142.     UdpClient(PARAM_SERVER_ADDR, PARAM_SERVER_PORT);
  143.     // mqtt_connect();
  144.     printf("disconnect to AP ...
  145. ");
  146.     DisconnectWithHotspot(netId);
  147.     printf("disconnect to AP done!
  148. ");
  149.   }
  150. }

  152. static void NetDemoEntry(void)
  153. {
  154.         GpioInit();
  155.         //设置红色,蓝 色,绿色 LED IO为输出状态
  156.         IoSetFunc(WIFI_IOT_IO_NAME_GPIO_10,          WIFI_IOT_IO_FUNC_GPIO_10_GPIO);
  157.         GpioSetDir(WIFI_IOT_IO_NAME_GPIO_10, WIFI_IOT_GPIO_DIR_OUT);
  158.         IoSetFunc(WIFI_IOT_IO_NAME_GPIO_11, WIFI_IOT_IO_FUNC_GPIO_11_GPIO);
  159.         GpioSetDir(WIFI_IOT_IO_NAME_GPIO_11, WIFI_IOT_GPIO_DIR_OUT);
  160.         IoSetFunc(WIFI_IOT_IO_NAME_GPIO_12, WIFI_IOT_IO_FUNC_GPIO_12_GPIO);
  161.         GpioSetDir(WIFI_IOT_IO_NAME_GPIO_12, WIFI_IOT_GPIO_DIR_OUT);
  162.     osThreadAttr_t attr;
  163.     attr.name = "NetDemoTask";
  164.     attr.attr_bits = 0U;
  165.     attr.cb_mem = NULL;
  166.     attr.cb_size = 0U;
  167.     attr.stack_mem = NULL;
  168.     attr.stack_size = 40960;
  169.     attr.priority = osPriorityNormal;
  170.     if (osThreadNew(NetDemoTask, NULL, &attr) == NULL) {
  171.         printf("[NetDemoEntry] Falied to create NetDemoTask!
  172. ");
  173.     }
  174. }
  175. SYS_RUN(NetDemoEntry);
  176. //=================================================
  177. void UdpClient(const char* host, unsigned short port)
  178. {
  179.        ssize_t retval = 0;
  180.         GpioSetOutputVal(R_LED, 1);
  181.         GpioSetOutputVal(B_LED, 1);
  182.         GpioSetOutputVal(G_LED, 1);
  183.         light_status = 1;
  184.         while (g_connected){
  185.            int sockfd = socket(AF_INET, SOCK_DGRAM, 0); // UDP socket
  186.           printf("ip%s:%d
  187. ",host,port);
  188.           struct sockaddr_in toAddr = {0};
  189.           toAddr.sin_family = AF_INET;
  190.           toAddr.sin_port = htons(port);
  191.      if (inet_pton(AF_INET, host, &toAddr.sin_addr) <= 0) {
  192.            printf("inet_pton failed!
  193. ");
  194.            goto do_cleanup;
  195.     }


  198.     if(light_status == 1){
  199.             request[6] = '1';
  200.     }else{
  201.             request[6] = '0';
  202.     }
  203.     retval = sendto(sockfd, request, sizeof(request), 0, (struct sockaddr *)&toAddr, sizeof(toAddr));
  204.     if (retval < 0) {
  205.         printf("sendto failed!
  206. ");
  207.         goto do_cleanup;
  208.     }
  209.     printf("send UDP message {%s} %ld done!
  210. ", request, retval);
  211.     struct sockaddr_in fromAddr = {0};
  212.     socklen_t fromLen = sizeof(fromAddr);
  213.     retval = recvfrom(sockfd, &response, sizeof(response), 0, (struct sockaddr *)&fromAddr, &fromLen);
  214.     if (retval <= 0) {
  215.         printf("recvfrom failed or abort, %ld, %d!
  216. ", retval, errno);
  217.         goto do_cleanup;
  218.     }
  219.     response[retval] = '\0';
  220.     printf("recv UDP message {%s} %ld done!
  221. ", response, retval);
  222.     printf("peer info: ipaddr = %s, port = %d
  223. ", inet_ntoa(fromAddr.sin_addr), ntohs(fromAddr.sin_port));
  224.         if (strncmp((char *)response, (char *)"light", 5) == 0){
  225.             printf("response[6]= %c
  226. ",response[6]);
  227.             if(response[6]=='1'){
  228.                                   GpioSetOutputVal(R_LED, 1);
  229.                                   GpioSetOutputVal(B_LED, 1);
  230.                                   GpioSetOutputVal(G_LED, 1);
  231.                                   light_status = 1;
  232.             }
  233.             else{
  234.                                   GpioSetOutputVal(R_LED, 0);
  235.                                   GpioSetOutputVal(B_LED, 0);
  236.                                   GpioSetOutputVal(G_LED, 0);
  237.                                   light_status = 0;
  238.             }
  239.         }
  240. do_cleanup:
  241.     printf("do_cleanup...
  242. ");
  243.     close(sockfd);
  244.     }
  245. }
复制代码


--------------------------------------------------------------------
附上源码:
  

附上高清视频
  
模拟APP测试软件




`
2020-11-15_144933.png
[attach]976213[/attach]
举报

回帖

声明：本文内容及配图由入驻作者撰写或者入驻合作网站授权转载。文章观点仅代表作者本人，不代表电子发烧友网立场。文章及其配图仅供工程师学习之用，如有内容图片侵权或者其他问题，请联系本站作侵删。 侵权投诉
链接复制成功，分享给好友