自拍偷在线精品自拍偷,亚洲欧美中文日韩v在线观看不卡

使用鴻蒙Hi3861完成連接WiFi熱點并啟動TCPSocketServ

作者：LegendOfTiger
系統(tǒng)
這次使用Hi3861來完成Wifi熱點的連接，并啟動TCP SocketServer，接收消息并將消息反饋TcpCLient。

[[380071]]

 想了解更多內(nèi)容，請訪問：

51CTO和華為官方合作共建的鴻蒙技術(shù)社區(qū)

https://harmonyos.51cto.com/#zz

這次使用Hi3861來完成Wifi熱點的連接，并啟動TCP SocketServer，接收消息并將消息反饋TcpCLient。

一、連接Wifi熱點。主要做法是啟動開發(fā)板Wifi，然后設(shè)置熱點和密碼等配置信息，再連接熱點。

1、先定義兩個Wifi監(jiān)聽器，一個連接改變、一個狀態(tài)改變，并注冊監(jiān)聽器。其中重要的是OnWifiConnectionChanged連接狀態(tài)事件處理函數(shù)。該函數(shù)會在連接成功后設(shè)置全局變量g_connected=1，代表已經(jīng)連接成功。

  1. WifiEvent eventListener = { 
  2.   .OnWifiConnectionChanged = OnWifiConnectionChanged, 
  3.   .OnWifiScanStateChanged = OnWifiScanStateChanged 
  4. }; 
  5. WifiErrorCode errCode = RegisterWifiEvent(&eventListener); 
  6.  
  7. void OnWifiConnectionChanged(int state, WifiLinkedInfo* info) { 
  8.   if (!info) return; 
  9.  
  10.   if (state == WIFI_STATE_AVALIABLE) { 
  11.     g_connected = 1; 
  12.   } else { 
  13.     g_connected = 0; 
  14.   } 
  15. } 

 2、啟動Wifi

  1. EnableWifi(); 

3、設(shè)置Wifi熱點信息，并返回NetworkId

  1. WifiDeviceConfig apConfig = {}; 
  2. strcpy(apConfig.ssid, "MyWifi"); 
  3. strcpy(apConfig.preSharedKey, "12345678"); 
  4. apConfig.securityType = WIFI_SEC_TYPE_PSK; 
  5.  
  6. int netId = -1; 
  7. AddDeviceConfig(&apConfig, &netId); 

 4、連接熱點，注意此時的g_connected變量，true代表已連接，false代表未連接。這個狀態(tài)在事件處理函數(shù)中設(shè)置。未連接成功時，系統(tǒng)會循環(huán)等待，知道事件設(shè)置該值。

  1. ConnectTo(netId); 
  2. while (!g_connected) { 
  3.   osDelay(10); 
  4. } 

 二、進(jìn)行聯(lián)網(wǎng)，找到wlan0的network interface，然后啟動DHCP客戶端，獲取IP地址。

  1. struct netif* iface = netifapi_netif_find("wlan0"); 
  2. if (iface) { 
  3.   err_t ret = netifapi_dhcp_start(iface); 
  4.   osDelay(300); 
  5. } 

 三、啟動TcpSocketServer，并收發(fā)消息

1、創(chuàng)建SocketServer，設(shè)置服務(wù)端口，并啟動監(jiān)聽

  1. int sockfd = socket(AF_INET, SOCK_STREAM, 0); 
  2.  
  3. struct sockaddr_in serverAddr = {0}; 
  4. serverAddr.sin_family = AF_INET; 
  5. serverAddr.sin_port = htons(port); 
  6. serverAddr.sin_addr.s_addr = htonl(INADDR_ANY); 
  7. bind(sockfd, (struct sockaddr *)&serverAddr, sizeof(serverAddr)); 
  8.  
  9. int backlog = 1; 
  10. listen(sockfd, backlog) 

 2、客戶端連接。接收客戶端消息并發(fā)送回去。注意連接后，會創(chuàng)建一個新的Socket File Description。

  1. int connfd = -1; 
  2. connfd = accept(sockfd, (struct sockaddr *)&clientAddr, &clientAddrLen); 
  3.  
  4. recv(connfd, request, sizeof(request), 0); 
  5. send(connfd, request, strlen(request), 0); 

 3、關(guān)閉TcpSocketServer

  1. lwip_close(connfd); 
  2. lwip_close(socketfd); 

 四、聯(lián)網(wǎng)結(jié)束，關(guān)閉DHCP客戶端，斷開Wifi，移除熱點的配置信息，禁用Wifi。

  1. err_t ret = netifapi_dhcp_stop(iface); 
  2. Disconnect(); 
  3. RemoveDevice(netId); 
  4. DisableWifi(); 

 五、測試情況如下：

1、啟動開發(fā)板，連接Wifi熱點，啟動TcpServer

2、TcpClient(網(wǎng)絡(luò)調(diào)試助手)連接開發(fā)板的TcpServer(HiBurn)。

3、TcpClient輸入數(shù)據(jù)并發(fā)送，TcpServer接收后再發(fā)送回TcpClient。


六、全部源代碼，我都注釋了，希望大家能夠有所參考。

  1. #include <errno.h> 
  2. #include <stdio.h> 
  3. #include <string.h> 
  4. #include <stddef.h> 
  5. #include <unistd.h> 
  6.  
  7. #include "ohos_init.h" 
  8. #include "cmsis_os2.h" 
  9. #include "wifi_device.h" 
  10.  
  11. #include "lwip/netifapi.h" 
  12. #include "lwip/api_shell.h" 
  13. #include "lwip/sockets.h" 
  14.  
  15. // 接收、發(fā)送的數(shù)據(jù) 
  16. static char request[128] = ""; 
  17. // 未連接熱點=0，已連接熱點=1 
  18. static int g_connected = 0; 
  19.  
  20. // 輸出連接信息字符串 
  21. // 打印內(nèi)容樣例--> bssid: 38:47:BC:49:01:FA, rssi: 0, connState: 0, reason: 0, ssid: MyMobile 
  22. void PrintLinkedInfo(WifiLinkedInfo* info) { 
  23.   if (!info) return; 
  24.  
  25.   static char macAddress[32] = {0}; 
  26.   unsigned char* mac = info->bssid; 
  27.   snprintf(macAddress, sizeof(macAddress), "%02X:%02X:%02X:%02X:%02X:%02X", mac[0], mac[1], mac[2], mac[3], mac[4], mac[5]); 
  28.   printf("bssid: %s, rssi: %d, connState: %d, reason: %d, ssid: %srn", macAddress, info->rssi, info->connState, info->disconnectedReason, info->ssid); 
  29. } 
  30.  
  31. // 連接狀態(tài)改變事件處理 
  32. void OnWifiConnectionChanged(int state, WifiLinkedInfo* info) { 
  33.   if (!info) return; 
  34.  
  35.   // 輸出類似內(nèi)容：OnWifiConnectionChanged 31, state = 1, info =  
  36.   printf("%s %d, state = %d, info = rn", __FUNCTION__, __LINE__, state); 
  37.   PrintLinkedInfo(info); 
  38.  
  39.   // 根據(jù)連接狀態(tài)設(shè)置g_connected 
  40.   if (state == WIFI_STATE_AVALIABLE) { 
  41.     g_connected = 1; 
  42.   } else { 
  43.     g_connected = 0; 
  44.   } 
  45. } 
  46.  
  47. // 掃描狀態(tài)改變事件處理 
  48. void OnWifiScanStateChanged(int state, int size) { 
  49.   printf("%s %d, state = %X, size = %drn", __FUNCTION__, __LINE__, state, size); 
  50. } 
  51.  
  52. void DisconnectTcpSocket(int connfd) { 
  53.   sleep(1); 
  54.   printf("do_disconnect...rn"); 
  55.   lwip_close(connfd); 
  56.   sleep(1); // for debug 
  57. } 
  58.  
  59. void CloseTcpSocket(int socketfd) { 
  60.   printf("do_cleanup...rn"); 
  61.  
  62.   lwip_close(socketfd); 
  63. } 
  64.  
  65. static void TcpServerHandler(void) { 
  66.   ssize_t retval = 0; 
  67.   unsigned short port = 9118; 
  68.  
  69.   // 創(chuàng)建一個通信的Socket，并返回一個Socket文件描述符。第一個參數(shù)IpV4，第二個參數(shù)SOCK_STREAM類型，第三個指用到的協(xié)議 
  70.   int sockfd = socket(AF_INET, SOCK_STREAM, 0); 
  71.  
  72.   // 客戶端地址和地址長度 
  73.   struct sockaddr_in clientAddr = {0}; 
  74.   socklen_t clientAddrLen = sizeof(clientAddr); 
  75.  
  76.   // 服務(wù)端地址 
  77.   struct sockaddr_in serverAddr = {0}; 
  78.   serverAddr.sin_family = AF_INET; 
  79.   // htons是將整型變量從主機字節(jié)順序轉(zhuǎn)變成網(wǎng)絡(luò)字節(jié)順序，就是整數(shù)在地址空間存儲方式變?yōu)楦呶蛔止?jié)存放在內(nèi)存的低地址處 
  80.   serverAddr.sin_port = htons(port); 
  81.   // 監(jiān)聽本機的所有IP地址，INADDR_ANY=0x0 
  82.   // 將主機數(shù)轉(zhuǎn)換成無符號長整型的網(wǎng)絡(luò)字節(jié)順序 
  83.   serverAddr.sin_addr.s_addr = htonl(INADDR_ANY); 
  84.  
  85.   // 服務(wù)端綁定端口 
  86.   retval = bind(sockfd, (struct sockaddr *)&serverAddr, sizeof(serverAddr)); 
  87.   if (retval < 0) { 
  88.     printf("bind failed, %ld!rn", retval); 
  89.     CloseTcpSocket(sockfd); 
  90.     return; 
  91.   } 
  92.   printf("bind to port %d success!rn", port); 
  93.  
  94.   // 開始監(jiān)聽，backlog指Pending連接隊列增長到的最大長度。隊列滿了，再有新連接請求到達(dá)，則客戶端ECONNREFUSED錯誤。如果支持重傳，則請求忽略。 
  95.   int backlog = 1; 
  96.   retval = listen(sockfd, backlog); 
  97.   if (retval < 0) { 
  98.     printf("listen failed!rn"); 
  99.     CloseTcpSocket(sockfd); 
  100.     return; 
  101.   } 
  102.   printf("listen with %d backlog success!rn", backlog); 
  103.  
  104.   int outerFlag = 1; 
  105.   while (outerFlag) { 
  106.     // 接受客戶端連接，成功會返回一個表示連接的 socket。clientAddr參數(shù)將會攜帶客戶端主機和端口信息；失敗返回 -1 
  107.     // 從Pending連接隊列中獲取第一個連接，根據(jù)sockfd的socket協(xié)議、地址族等內(nèi)容創(chuàng)建一個新的socket文件描述，并返回。 
  108.     // 此后的 收、發(fā) 都在 表示連接的 socket 上進(jìn)行；之后 sockfd 依然可以繼續(xù)接受其他客戶端的連接， 
  109.     // UNIX系統(tǒng)上經(jīng)典的并發(fā)模型是“每個連接一個進(jìn)程”——創(chuàng)建子進(jìn)程處理連接，父進(jìn)程繼續(xù)接受其他客戶端的連接 
  110.     // 鴻蒙liteos-a內(nèi)核之上，可以使用UNIX的“每個連接一個進(jìn)程”的并發(fā)模型liteos-m內(nèi)核之上，可以使用“每個連接一個線程”的并發(fā)模型 
  111.     int connfd = -1; 
  112.     connfd = accept(sockfd, (struct sockaddr *)&clientAddr, &clientAddrLen); 
  113.     if (connfd < 0) { 
  114.       printf("accept failed, %d, %drn", connfd, errno); 
  115.       CloseTcpSocket(sockfd); 
  116.       outerFlag = 0; 
  117.     } 
  118.     printf("accept success, connfd = %d !rn", connfd); 
  119.     // inet_ntoa：網(wǎng)絡(luò)地址轉(zhuǎn)換成“.”點隔的字符串格式。ntohs：16位數(shù)由網(wǎng)絡(luò)字節(jié)順序轉(zhuǎn)換為主機字節(jié)順序。 
  120.     printf("client addr info: host = %s, port = %drn", inet_ntoa(clientAddr.sin_addr), ntohs(clientAddr.sin_port)); 
  121.  
  122.     int innerFlag = 1; 
  123.     // 接收消息，然后發(fā)送回去 
  124.     while (innerFlag) { 
  125.       // 后續(xù) 收、發(fā) 都在 表示連接的 socket 上進(jìn)行； 
  126.       // 在新的Socket文件描述上接收信息. 
  127.       retval = recv(connfd, request, sizeof(request), 0); 
  128.       if (retval < 0) { 
  129.         printf("recv request failed, %ld!rn", retval); 
  130.         innerFlag = 0; 
  131.       } else if (retval == 0) { 
  132.         // 對方主動斷開連接 
  133.         printf("client disconnected!rn"); 
  134.         innerFlag = 0; 
  135.       } else { 
  136.         printf("recv request{%s} from client done!rn", request); 
  137.  
  138.         // 發(fā)送數(shù)據(jù) 
  139.         retval = send(connfd, request, strlen(request), 0); 
  140.         if (retval <= 0) { 
  141.           printf("send response failed, %ld!rn", retval); 
  142.           innerFlag = 0; 
  143.         } 
  144.         printf("send response{%s} to client done!rn", request); 
  145.  
  146.         // 清空緩沖區(qū) 
  147.         memset(&request, 0, sizeof(request)); 
  148.     } 
  149.  
  150.     DisconnectTcpSocket(connfd); 
  151.  
  152.     outerFlag = 0; 
  153.   } 
  154.  
  155.   CloseTcpSocket(sockfd); 
  156. } 
  157.  
  158. static void TcpServerTask(void *arg) { 
  159.   (void)arg; 
  160.    
  161.   // 先定義兩個Wifi監(jiān)聽器，一個連接改變、一個狀態(tài)改變 
  162.   WifiEvent eventListener = { 
  163.     .OnWifiConnectionChanged = OnWifiConnectionChanged, 
  164.     .OnWifiScanStateChanged = OnWifiScanStateChanged 
  165.   }; 
  166.  
  167.   // 等待10個系統(tǒng)Ticks。每個ticks多少個us，計算方式= 1000 * 1000 / osKernelGetTickFreq() 
  168.   osDelay(10); 
  169.  
  170.   // 注冊監(jiān)聽器 
  171.   WifiErrorCode errCode = RegisterWifiEvent(&eventListener); 
  172.   printf("RegisterWifiEvent: %drn", errCode); 
  173.  
  174.   // 設(shè)置Wifi熱點信息 
  175.   WifiDeviceConfig apConfig = {}; 
  176.   strcpy(apConfig.ssid, "MyMobile"); 
  177.   strcpy(apConfig.preSharedKey, "12345678"); 
  178.   apConfig.securityType = WIFI_SEC_TYPE_PSK; 
  179.  
  180.   int netId = -1; 
  181.  
  182.   // 啟用Wifi 
  183.   errCode = EnableWifi(); 
  184.   printf("EnableWifi: %drn", errCode); 
  185.   osDelay(10); 
  186.  
  187.   // 設(shè)置Wifi熱點配置信息，返回生成的網(wǎng)絡(luò)Id-netId。 
  188.   errCode = AddDeviceConfig(&apConfig, &netId); 
  189.   printf("AddDeviceConfig: %drn", errCode); 
  190.  
  191.   // 根據(jù)網(wǎng)絡(luò)Id連接到Wifi熱點 
  192.   g_connected = 0; 
  193.   errCode = ConnectTo(netId); 
  194.   printf("ConnectTo(%d): %drn", netId, errCode); 
  195.   // 未連接完成，則一直等待。g_connected狀態(tài)會在事件中設(shè)置。 
  196.   while (!g_connected) { 
  197.     osDelay(10); 
  198.   } 
  199.   printf("g_connected: %drn", g_connected); 
  200.   osDelay(50); 
  201.  
  202.   // 聯(lián)網(wǎng)業(yè)務(wù)開始，找到netifname=wlan0的netif。 
  203.   struct netif* iface = netifapi_netif_find("wlan0"); 
  204.   if (iface) { 
  205.     // 啟動DHCP客戶端，獲取IP地址 
  206.     err_t ret = netifapi_dhcp_start(iface); 
  207.     printf("netifapi_dhcp_start: %drn", ret); 
  208.     // 等待DHCP服務(wù)器反饋給予地址 
  209.     osDelay(300); 
  210.     // 執(zhí)行線程安全的網(wǎng)絡(luò)方法，第二個參數(shù)是voidFunc，第三個參數(shù)是errFunc。如果沒有errFunc，那么就執(zhí)行voidFunc。 
  211.     // netifapi_dhcp_start/netifapi_dhcp_stop等都是調(diào)用的netifapi_netif_common方法。 
  212.     // dhcp_clients_info_show顯示信息 
  213.     /* 
  214.     server : 
  215.       server_id : 192.168.43.1 
  216.       mask : 255.255.255.0, 1 
  217.       gw : 192.168.43.1 
  218.       T0 : 3600 
  219.       T1 : 1800 
  220.       T2 : 3150 
  221.     clients <1> : 
  222.       mac_idx mac             addr            state   lease   tries   rto      
  223.       0       b4c9b9af69f8    192.168.43.56   10      0       1       2       
  224.     */ 
  225.     ret = netifapi_netif_common(iface, dhcp_clients_info_show, NULL); 
  226.     printf("netifapi_netif_common: %drn", ret); 
  227.   } 
  228.  
  229.   TcpServerHandler(); 
  230.  
  231.   // 聯(lián)網(wǎng)業(yè)務(wù)結(jié)束，斷開DHCP 
  232.   err_t ret = netifapi_dhcp_stop(iface); 
  233.   printf("netifapi_dhcp_stop: %drn", ret); 
  234.  
  235.   // 斷開Wifi熱點連接 
  236.   Disconnect(); 
  237.  
  238.   // 移除Wifi熱點的配置 
  239.   RemoveDevice(netId); 
  240.  
  241.   // 關(guān)閉Wifi 
  242.   errCode = DisableWifi(); 
  243.   printf("DisableWifi: %drn", errCode); 
  244.   osDelay(200); 
  245. } 
  246.  
  247. static void TcpServerEntry(void) { 
  248.   osThreadAttr_t attr; 
  249.  
  250.   attr.name = "TcpServerTask"; 
  251.   attr.attr_bits = 0U; 
  252.   attr.cb_mem = NULL; 
  253.   attr.cb_size = 0U; 
  254.   attr.stack_mem = NULL; 
  255.   attr.stack_size = 10240; 
  256.   attr.priority = osPriorityNormal; 
  257.  
  258.   if (osThreadNew((osThreadFunc_t)TcpServerTask, NULL, &attr) == NULL) { 
  259.     printf("SunLaoTest-Fail Create"); 
  260.   } 
  261. } 
  262.  
  263. APP_FEATURE_INIT(TcpServerEntry); 

想了解更多內(nèi)容，請訪問：

51CTO和華為官方合作共建的鴻蒙技術(shù)社區(qū)

https://harmonyos.51cto.com/#zz

 

責(zé)任編輯：jianghua 來源： 鴻蒙社區(qū)
鴻蒙HarmonyOS應(yīng)用開發(fā)
相關(guān)推薦

2020-10-16 09:50:37

Hi3861WiFi熱點

2020-11-02 11:56:57

鴻蒙 WiFi操作

2022-09-06 15:25:22

Wifi設(shè)備開發(fā)

2021-04-30 09:43:27

鴻蒙HarmonyOS應(yīng)用

2022-02-09 19:25:49

Hi3861WiFi操作鴻蒙

2022-02-09 19:31:41

Hi3861OpenHarmon鴻蒙

2020-11-03 11:39:22

wifi小車

2020-10-30 09:41:44

鴻蒙Hi3861WiFi小車

2022-09-07 15:35:49

設(shè)備開發(fā)鴻蒙

2020-11-06 10:15:16

HiBurn

2020-10-14 09:37:03

HiBurn鴻蒙.bin文件

2021-03-16 09:49:16

鴻蒙HarmonyOS應(yīng)用

2020-11-02 12:07:11

鴻蒙 GPIO

2021-09-30 10:11:05

鴻蒙HarmonyOS應(yīng)用

2020-10-12 09:36:04

鴻蒙

2022-03-15 15:00:59

Hi3861Pin接口鴻蒙

2023-05-26 16:07:14

Hi3861Wifi模塊

2021-04-29 09:52:25

鴻蒙HarmonyOS應(yīng)用

2022-08-19 10:54:47

操作系統(tǒng)鴻蒙

2021-04-26 15:19:02

鴻蒙HarmonyOS應(yīng)用
點贊
收藏

51CTO技術(shù)棧公眾號