基于ESP32的TCP/IP传输实现

熊熊出没  金牌会员 | 2023-6-3 23:14:15 | 显示全部楼层 | 阅读模式
打印 上一主题 下一主题
楼主

主题 924|帖子 924|积分 2772

TCP/IP协议原理

TCP/IP协议是Internet互联网最基本的协议，TCP/IP协议的应用层的主要协议有HTTP、Telnet、FTP、SMTP等，是用来读取来自传输层的数据或者将数据传输写入传输层；传输层的主要协议有UDP、TCP，实现端对端的数据传输；网络层的主要协议有ICMP、IP、IGMP，主要负责网络中数据包的传送等；链路层有时也称作数据链路层或网络接口层，主要协议有ARP、RARP，通常包括操作系统中的设备驱动程序和计算机中对应的网络接口卡，它们一起处理与传输媒介（如电缆或其他物理设备）的物理接口细节。
TCP协议是一个面向连接的、可靠的传输协议，它提供一种可靠的字节流，能保证数据完整、无损并且按顺序到达。TCP尽量连续不断地测试网络的负载并且控制发送数据的速度以避免网络过载。另外，TCP试图将数据按照规定的顺序发送。
ESP32作为热点+TCP服务端

参考乐鑫开源程序，设置wifi模式为AP,运行TCP服务端程序。
ESP32作为站点+TCP客户端

参考乐鑫开源程序，设置wifi模式为STA,运行TCP客户端程序。
AP+TCP服务端程序

主函数
  1. #include <string.h>
  2. #include "freertos/FreeRTOS.h"
  3. #include "freertos/task.h"
  4. #include "esp_mac.h"
  5. #include "esp_wifi.h"
  6. #include "esp_event.h"
  7. #include "esp_log.h"
  8. #include "nvs_flash.h"
  10. #include "lwip/err.h"
  11. #include "lwip/sys.h"
  13. #include "tcp_server.h"
  14. /* The examples use WiFi configuration that you can set via project configuration menu.
  16.    If you'd rather not, just change the below entries to strings with
  17.    the config you want - ie #define EXAMPLE_WIFI_SSID "mywifissid"
  18. */
  19. //#define EXAMPLE_ESP_WIFI_SSID      CONFIG_ESP_WIFI_SSID
  20. //#define EXAMPLE_ESP_WIFI_PASS      CONFIG_ESP_WIFI_PASSWORD
  21. #define EXAMPLE_ESP_WIFI_SSID      "myesp32AP"
  22. #define EXAMPLE_ESP_WIFI_PASS      "esp45678"
  23. #define EXAMPLE_ESP_WIFI_CHANNEL   CONFIG_ESP_WIFI_CHANNEL
  24. #define EXAMPLE_MAX_STA_CONN       CONFIG_ESP_MAX_STA_CONN
  26. #define WIFI_TAG "wifi softAP"
  27. //static const char *WIFI_TAG = "wifi softAP";
  29. static void wifi_event_handler(void* arg, esp_event_base_t event_base,
  30.                                     int32_t event_id, void* event_data)
  31. {
  32.     if (event_id == WIFI_EVENT_AP_STACONNECTED) {
  33.         wifi_event_ap_staconnected_t* event = (wifi_event_ap_staconnected_t*) event_data;
  34.         ESP_LOGI(WIFI_TAG, "station "MACSTR" join, AID=%d",
  35.                  MAC2STR(event->mac), event->aid);
  36.     } else if (event_id == WIFI_EVENT_AP_STADISCONNECTED) {
  37.         wifi_event_ap_stadisconnected_t* event = (wifi_event_ap_stadisconnected_t*) event_data;
  38.         ESP_LOGI(WIFI_TAG, "station "MACSTR" leave, AID=%d",
  39.                  MAC2STR(event->mac), event->aid);
  40.     }
  41. }
  43. void wifi_init_softap(void)
  44. {
  45.     ESP_ERROR_CHECK(esp_netif_init());
  46.     ESP_ERROR_CHECK(esp_event_loop_create_default());
  47.     esp_netif_create_default_wifi_ap();
  49.     wifi_init_config_t cfg = WIFI_INIT_CONFIG_DEFAULT();
  50.     ESP_ERROR_CHECK(esp_wifi_init(&cfg));
  52.     ESP_ERROR_CHECK(esp_event_handler_instance_register(WIFI_EVENT,
  53.                                                         ESP_EVENT_ANY_ID,
  54.                                                         &wifi_event_handler,
  55.                                                         NULL,
  56.                                                         NULL));
  58.     wifi_config_t wifi_config = {
  59.         .ap = {
  60.             .ssid = EXAMPLE_ESP_WIFI_SSID,
  61.             .ssid_len = strlen(EXAMPLE_ESP_WIFI_SSID),
  62.             .channel = EXAMPLE_ESP_WIFI_CHANNEL,
  63.             .password = EXAMPLE_ESP_WIFI_PASS,
  64.             .max_connection = EXAMPLE_MAX_STA_CONN,
  65.             .authmode = WIFI_AUTH_WPA_WPA2_PSK,
  66.             .pmf_cfg = {
  67.                     .required = false,
  68.             },
  69.         },
  70.     };
  71.     if (strlen(EXAMPLE_ESP_WIFI_PASS) == 0) {
  72.         wifi_config.ap.authmode = WIFI_AUTH_OPEN;
  73.     }
  75.     ESP_ERROR_CHECK(esp_wifi_set_mode(WIFI_MODE_AP));
  76.     ESP_ERROR_CHECK(esp_wifi_set_config(WIFI_IF_AP, &wifi_config));
  77.     ESP_ERROR_CHECK(esp_wifi_start());
  79.     ESP_LOGI(WIFI_TAG, "wifi_init_softap finished. SSID:%s password:%s channel:%d",
  80.              EXAMPLE_ESP_WIFI_SSID, EXAMPLE_ESP_WIFI_PASS, EXAMPLE_ESP_WIFI_CHANNEL);
  81. }
  83. void app_main(void)
  84. {
  85.     //Initialize NVS
  86.     esp_err_t ret = nvs_flash_init();
  87.     if (ret == ESP_ERR_NVS_NO_FREE_PAGES || ret == ESP_ERR_NVS_NEW_VERSION_FOUND) {
  88.       ESP_ERROR_CHECK(nvs_flash_erase());
  89.       ret = nvs_flash_init();
  90.     }
  91.     ESP_ERROR_CHECK(ret);
  93.     ESP_LOGI(WIFI_TAG, "ESP_WIFI_MODE_AP");
  94.     wifi_init_softap();
  95.     vTaskDelay(1000 / portTICK_PERIOD_MS);
  96.    
  97.     tcpServerStart();
  98. }
复制代码
tcp_server.c
  1. /*
  2. #include <string.h>
  3. #include <sys/param.h>
  4. #include "freertos/FreeRTOS.h"
  5. #include "freertos/task.h"
  6. #include "esp_system.h"
  7. #include "esp_wifi.h"
  8. #include "esp_event.h"
  9. #include "esp_log.h"
  10. #include "nvs_flash.h"
  11. #include "esp_netif.h"
  12. #include "protocol_examples_common.h"
  14. #include "lwip/err.h"
  15. #include "lwip/sockets.h"
  16. #include "lwip/sys.h"
  17. #include <lwip/netdb.h>
  18. */
  20. #include "tcp_server.h"
  22. #define PORT                        CONFIG_EXAMPLE_PORT
  23. #define KEEPALIVE_IDLE              CONFIG_EXAMPLE_KEEPALIVE_IDLE
  24. #define KEEPALIVE_INTERVAL          CONFIG_EXAMPLE_KEEPALIVE_INTERVAL
  25. #define KEEPALIVE_COUNT             CONFIG_EXAMPLE_KEEPALIVE_COUNT
  27. #define TCP_TAG "TCP"
  28. //static const char *TCP_TAG= "example";
  30. static void do_retransmit(const int sock)
  31. {
  32.     int len;
  33.     char rx_buffer[128];
  34.     char tx_buffer[128];
  36.     do {
  37.         len = recv(sock, rx_buffer, sizeof(rx_buffer) - 1, 0);
  38.         if (len < 0) {
  39.             ESP_LOGE(TCP_TAG, "Error occurred during receiving: errno %d", errno);
  40.         } else if (len == 0) {
  41.             ESP_LOGW(TCP_TAG, "Connection closed");
  42.         } else {
  43.             rx_buffer[len] = 0; // Null-terminate whatever is received and treat it like a string
  44.             ESP_LOGI(TCP_TAG, "Received %d bytes: %s", len, rx_buffer);
  46.             // send() can return less bytes than supplied length.
  47.             // Walk-around for robust implementation.
  48.             int to_write = len;
  49.             while (to_write > 0) {
  50.                 int written = send(sock, rx_buffer + (len - to_write), to_write, 0);
  51.                 if (written < 0) {
  52.                     ESP_LOGE(TCP_TAG, "Error occurred during sending: errno %d", errno);
  53.                 }
  54.                 to_write -= written;
  55.             }
  58.         }
  59.     } while (len > 0);
  60. }
  61. static void tcp_server_task(void *pvParameters)
  62. {
  63.     char addr_str[128];
  64.     int addr_family = (int)pvParameters;
  65.     int ip_protocol = 0;
  66.     int keepAlive = 1;
  67.     int keepIdle = KEEPALIVE_IDLE;
  68.     int keepInterval = KEEPALIVE_INTERVAL;
  69.     int keepCount = KEEPALIVE_COUNT;
  70.     struct sockaddr_storage dest_addr;
  72.     if (addr_family == AF_INET) {
  73.         struct sockaddr_in *dest_addr_ip4 = (struct sockaddr_in *)&dest_addr;
  74.         dest_addr_ip4->sin_addr.s_addr = htonl(INADDR_ANY);
  75.         dest_addr_ip4->sin_family = AF_INET;
  76.         dest_addr_ip4->sin_port = htons(PORT);
  77.         ip_protocol = IPPROTO_IP;
  78.     }
  79. #ifdef CONFIG_EXAMPLE_IPV6
  80.     else if (addr_family == AF_INET6) {
  81.         struct sockaddr_in6 *dest_addr_ip6 = (struct sockaddr_in6 *)&dest_addr;
  82.         bzero(&dest_addr_ip6->sin6_addr.un, sizeof(dest_addr_ip6->sin6_addr.un));
  83.         dest_addr_ip6->sin6_family = AF_INET6;
  84.         dest_addr_ip6->sin6_port = htons(PORT);
  85.         ip_protocol = IPPROTO_IPV6;
  86.     }
  87. #endif
  89.     int listen_sock = socket(addr_family, SOCK_STREAM, ip_protocol);
  90.     if (listen_sock < 0) {
  91.         ESP_LOGE(TCP_TAG, "Unable to create socket: errno %d", errno);
  92.         vTaskDelete(NULL);
  93.         return;
  94.     }
  95.     int opt = 1;
  96.     setsockopt(listen_sock, SOL_SOCKET, SO_REUSEADDR, &opt, sizeof(opt));
  97. #if defined(CONFIG_EXAMPLE_IPV4) && defined(CONFIG_EXAMPLE_IPV6)
  98.     // Note that by default IPV6 binds to both protocols, it is must be disabled
  99.     // if both protocols used at the same time (used in CI)
  100.     setsockopt(listen_sock, IPPROTO_IPV6, IPV6_V6ONLY, &opt, sizeof(opt));
  101. #endif
  103.     ESP_LOGI(TCP_TAG, "Socket created");
  105.     int err = bind(listen_sock, (struct sockaddr *)&dest_addr, sizeof(dest_addr));
  106.     if (err != 0) {
  107.         ESP_LOGE(TCP_TAG, "Socket unable to bind: errno %d", errno);
  108.         ESP_LOGE(TCP_TAG, "IPPROTO: %d", addr_family);
  109.         goto CLEAN_UP;
  110.     }
  111.     ESP_LOGI(TCP_TAG, "Socket bound, port %d", PORT);
  113.     err = listen(listen_sock, 1);
  114.     if (err != 0) {
  115.         ESP_LOGE(TCP_TAG, "Error occurred during listen: errno %d", errno);
  116.         goto CLEAN_UP;
  117.     }
  119.     while (1) {
  121.         ESP_LOGI(TCP_TAG, "Socket listening");
  123.         struct sockaddr_storage source_addr; // Large enough for both IPv4 or IPv6
  124.         socklen_t addr_len = sizeof(source_addr);
  125.         int sock = accept(listen_sock, (struct sockaddr *)&source_addr, &addr_len);
  126.         if (sock < 0) {
  127.             ESP_LOGE(TCP_TAG, "Unable to accept connection: errno %d", errno);
  128.             break;
  129.         }
  131.         // Set tcp keepalive option
  132.         setsockopt(sock, SOL_SOCKET, SO_KEEPALIVE, &keepAlive, sizeof(int));
  133.         setsockopt(sock, IPPROTO_TCP, TCP_KEEPIDLE, &keepIdle, sizeof(int));
  134.         setsockopt(sock, IPPROTO_TCP, TCP_KEEPINTVL, &keepInterval, sizeof(int));
  135.         setsockopt(sock, IPPROTO_TCP, TCP_KEEPCNT, &keepCount, sizeof(int));
  136.         // Convert ip address to string
  137.         if (source_addr.ss_family == PF_INET) {
  138.             inet_ntoa_r(((struct sockaddr_in *)&source_addr)->sin_addr, addr_str, sizeof(addr_str) - 1);
  139.         }
  140. #ifdef CONFIG_EXAMPLE_IPV6
  141.         else if (source_addr.ss_family == PF_INET6) {
  142.             inet6_ntoa_r(((struct sockaddr_in6 *)&source_addr)->sin6_addr, addr_str, sizeof(addr_str) - 1);
  143.         }
  144. #endif
  145.         ESP_LOGI(TCP_TAG, "Socket accepted ip address: %s", addr_str);
  147.         do_retransmit(sock);
  149.         shutdown(sock, 0);
  150.         close(sock);
  151.     }
  153. CLEAN_UP:
  154.     close(listen_sock);
  155.     vTaskDelete(NULL);
  156. }
  158. void tcpServerStart(void)
  159. {
  160.     //ESP_ERROR_CHECK(nvs_flash_init());
  161.     //ESP_ERROR_CHECK(esp_netif_init());
  162.     //ESP_ERROR_CHECK(esp_event_loop_create_default());
  164.     /* This helper function configures Wi-Fi or Ethernet, as selected in menuconfig.
  165.      * Read "Establishing Wi-Fi or Ethernet Connection" section in
  166.      * examples/protocols/README.md for more information about this function.
  167.      */
  168.     //ESP_ERROR_CHECK(example_connect());
  170. #ifdef CONFIG_EXAMPLE_IPV4
  171.     xTaskCreate(tcp_server_task, "tcp_server", 4096, (void*)AF_INET, 5, NULL);
  172. #endif
  173. #ifdef CONFIG_EXAMPLE_IPV6
  174.     xTaskCreate(tcp_server_task, "tcp_server", 4096, (void*)AF_INET6, 5, NULL);
  175. #endif
  176. }
复制代码
ATP+TCP客户端程序

主函数
  1. #include <string.h>
  2. #include <sys/param.h>
  3. #include "freertos/FreeRTOS.h"
  4. #include "freertos/task.h"
  5. #include "freertos/event_groups.h"
  6. #include "esp_system.h"
  7. #include "esp_wifi.h"
  8. #include "esp_event.h"
  9. #include "esp_log.h"
  10. #include "nvs_flash.h"
  11. #include "esp_netif.h"
  13. #include "addr_from_stdin.h"
  14. #include "lwip/err.h"
  15. #include "lwip/sockets.h"
  17. #include "my_wifi.h"
  18. #include "tcp_client.h"
  20. void app_main(void)
  21. {
  22.     //wifi conect
  24.     wifiStaStart();
  26.     //tcp client
  27.     tcpClientStart();
  28. }
复制代码
my_wifi.c
  1. #include "my_wifi.h"
  2. /* The examples use WiFi configuration that you can set via project configuration menu
  4.    If you'd rather not, just change the below entries to strings with
  5.    the config you want - ie #define EXAMPLE_WIFI_SSID "mywifissid"
  6. */
  7. #define EXAMPLE_ESP_WIFI_SSID      "myesp32AP"
  8. #define EXAMPLE_ESP_WIFI_PASS      "esp45678"
  9. #define EXAMPLE_ESP_MAXIMUM_RETRY  CONFIG_ESP_MAXIMUM_RETRY
  11. #if CONFIG_ESP_WIFI_AUTH_OPEN
  12. #define ESP_WIFI_SCAN_AUTH_MODE_THRESHOLD WIFI_AUTH_OPEN
  13. #elif CONFIG_ESP_WIFI_AUTH_WEP
  14. #define ESP_WIFI_SCAN_AUTH_MODE_THRESHOLD WIFI_AUTH_WEP
  15. #elif CONFIG_ESP_WIFI_AUTH_WPA_PSK
  16. #define ESP_WIFI_SCAN_AUTH_MODE_THRESHOLD WIFI_AUTH_WPA_PSK
  17. #elif CONFIG_ESP_WIFI_AUTH_WPA2_PSK
  18. #define ESP_WIFI_SCAN_AUTH_MODE_THRESHOLD WIFI_AUTH_WPA2_PSK
  19. #elif CONFIG_ESP_WIFI_AUTH_WPA_WPA2_PSK
  20. #define ESP_WIFI_SCAN_AUTH_MODE_THRESHOLD WIFI_AUTH_WPA_WPA2_PSK
  21. #elif CONFIG_ESP_WIFI_AUTH_WPA3_PSK
  22. #define ESP_WIFI_SCAN_AUTH_MODE_THRESHOLD WIFI_AUTH_WPA3_PSK
  23. #elif CONFIG_ESP_WIFI_AUTH_WPA2_WPA3_PSK
  24. #define ESP_WIFI_SCAN_AUTH_MODE_THRESHOLD WIFI_AUTH_WPA2_WPA3_PSK
  25. #elif CONFIG_ESP_WIFI_AUTH_WAPI_PSK
  26. #define ESP_WIFI_SCAN_AUTH_MODE_THRESHOLD WIFI_AUTH_WAPI_PSK
  27. #endif
  29. /* FreeRTOS event group to signal when we are connected*/
  30. static EventGroupHandle_t s_wifi_event_group;
  32. /* The event group allows multiple bits for each event, but we only care about two events:
  33. * - we are connected to the AP with an IP
  34. * - we failed to connect after the maximum amount of retries */
  35. #define WIFI_CONNECTED_BIT BIT0
  36. #define WIFI_FAIL_BIT      BIT1
  38. static const char *TAG = "wifi station";
  40. static int s_retry_num = 0;
  42. static void event_handler(void* arg, esp_event_base_t event_base,
  43.                                 int32_t event_id, void* event_data)
  44. {
  45.     if (event_base == WIFI_EVENT && event_id == WIFI_EVENT_STA_START) {
  46.         esp_wifi_connect();
  47.     } else if (event_base == WIFI_EVENT && event_id == WIFI_EVENT_STA_DISCONNECTED) {
  48.         if (s_retry_num < EXAMPLE_ESP_MAXIMUM_RETRY) {
  49.             esp_wifi_connect();
  50.             s_retry_num++;
  51.             ESP_LOGI(TAG, "retry to connect to the AP");
  52.         } else {
  53.             xEventGroupSetBits(s_wifi_event_group, WIFI_FAIL_BIT);
  54.         }
  55.         ESP_LOGI(TAG,"connect to the AP fail");
  56.     } else if (event_base == IP_EVENT && event_id == IP_EVENT_STA_GOT_IP) {
  57.         ip_event_got_ip_t* event = (ip_event_got_ip_t*) event_data;
  58.         ESP_LOGI(TAG, "got ip:" IPSTR, IP2STR(&event->ip_info.ip));
  59.         s_retry_num = 0;
  60.         xEventGroupSetBits(s_wifi_event_group, WIFI_CONNECTED_BIT);
  61.     }
  62. }
  64. void wifi_init_sta(void)
  65. {
  66.     s_wifi_event_group = xEventGroupCreate();
  68.     ESP_ERROR_CHECK(esp_netif_init());
  70.     ESP_ERROR_CHECK(esp_event_loop_create_default());
  71.     esp_netif_create_default_wifi_sta();
  73.     wifi_init_config_t cfg = WIFI_INIT_CONFIG_DEFAULT();
  74.     ESP_ERROR_CHECK(esp_wifi_init(&cfg));
  76.     esp_event_handler_instance_t instance_any_id;
  77.     esp_event_handler_instance_t instance_got_ip;
  78.     ESP_ERROR_CHECK(esp_event_handler_instance_register(WIFI_EVENT,
  79.                                                         ESP_EVENT_ANY_ID,
  80.                                                         &event_handler,
  81.                                                         NULL,
  82.                                                         &instance_any_id));
  83.     ESP_ERROR_CHECK(esp_event_handler_instance_register(IP_EVENT,
  84.                                                         IP_EVENT_STA_GOT_IP,
  85.                                                         &event_handler,
  86.                                                         NULL,
  87.                                                         &instance_got_ip));
  89.     wifi_config_t wifi_config = {
  90.         .sta = {
  91.             .ssid = EXAMPLE_ESP_WIFI_SSID,
  92.             .password = EXAMPLE_ESP_WIFI_PASS,
  93.             /* Authmode threshold resets to WPA2 as default if password matches WPA2 standards (pasword len => 8).
  94.              * If you want to connect the device to deprecated WEP/WPA networks, Please set the threshold value
  95.              * to WIFI_AUTH_WEP/WIFI_AUTH_WPA_PSK and set the password with length and format matching to
  96.              * WIFI_AUTH_WEP/WIFI_AUTH_WPA_PSK standards.
  97.              */
  98.             .threshold.authmode = ESP_WIFI_SCAN_AUTH_MODE_THRESHOLD,
  99.             .sae_pwe_h2e = WPA3_SAE_PWE_BOTH,
  100.         },
  101.     };
  102.     ESP_ERROR_CHECK(esp_wifi_set_mode(WIFI_MODE_STA) );
  103.     ESP_ERROR_CHECK(esp_wifi_set_config(WIFI_IF_STA, &wifi_config) );
  104.     ESP_ERROR_CHECK(esp_wifi_start() );
  106.     ESP_LOGI(TAG, "wifi_init_sta finished.");
  108.     /* Waiting until either the connection is established (WIFI_CONNECTED_BIT) or connection failed for the maximum
  109.      * number of re-tries (WIFI_FAIL_BIT). The bits are set by event_handler() (see above) */
  110.     EventBits_t bits = xEventGroupWaitBits(s_wifi_event_group,
  111.             WIFI_CONNECTED_BIT | WIFI_FAIL_BIT,
  112.             pdFALSE,
  113.             pdFALSE,
  114.             portMAX_DELAY);
  116.     /* xEventGroupWaitBits() returns the bits before the call returned, hence we can test which event actually
  117.      * happened. */
  118.     if (bits & WIFI_CONNECTED_BIT) {
  119.         ESP_LOGI(TAG, "connected to ap SSID:%s password:%s",
  120.                  EXAMPLE_ESP_WIFI_SSID, EXAMPLE_ESP_WIFI_PASS);
  121.     } else if (bits & WIFI_FAIL_BIT) {
  122.         ESP_LOGI(TAG, "Failed to connect to SSID:%s, password:%s",
  123.                  EXAMPLE_ESP_WIFI_SSID, EXAMPLE_ESP_WIFI_PASS);
  124.     } else {
  125.         ESP_LOGE(TAG, "UNEXPECTED EVENT");
  126.     }
  127. }
  129. void wifiStaStart(void)
  130. {
  131.     //Initialize NVS
  132.     esp_err_t ret = nvs_flash_init();
  133.     if (ret == ESP_ERR_NVS_NO_FREE_PAGES || ret == ESP_ERR_NVS_NEW_VERSION_FOUND) {
  134.       ESP_ERROR_CHECK(nvs_flash_erase());
  135.       ret = nvs_flash_init();
  136.     }
  137.     ESP_ERROR_CHECK(ret);
  139.     ESP_LOGI(TAG, "ESP_WIFI_MODE_STA");
  140.     wifi_init_sta();
  141.     //tcpStart();
  143. }
复制代码
tcp_client.c
  1. #include "tcp_client.h"
  3. #if defined(CONFIG_EXAMPLE_IPV4)
  4. #define HOST_IP_ADDR CONFIG_EXAMPLE_IPV4_ADDR
  5. #elif defined(CONFIG_EXAMPLE_IPV6)
  6. #define HOST_IP_ADDR CONFIG_EXAMPLE_IPV6_ADDR
  7. #else
  8. #define HOST_IP_ADDR ""
  9. #endif
  11. #define PORT CONFIG_EXAMPLE_PORT
  13. static const char *TAGC = "example";
  14. static const char *payload = "Message from Client1:tem,hum,c2h4 ";
  16. static void tcp_client_task(void *pvParameters)
  17. {
  18.     char rx_buffer[128];
  19.     char host_ip[] = HOST_IP_ADDR;
  20.     int addr_family = 0;
  21.     int ip_protocol = 0;
  23.     while (1) {
  24. #if defined(CONFIG_EXAMPLE_IPV4)
  25.         struct sockaddr_in dest_addr;
  26.         dest_addr.sin_addr.s_addr = inet_addr(host_ip);
  27.         dest_addr.sin_family = AF_INET;
  28.         dest_addr.sin_port = htons(PORT);
  29.         addr_family = AF_INET;
  30.         ip_protocol = IPPROTO_IP;
  31. #elif defined(CONFIG_EXAMPLE_IPV6)
  32.         struct sockaddr_in6 dest_addr = { 0 };
  33.         inet6_aton(host_ip, &dest_addr.sin6_addr);
  34.         dest_addr.sin6_family = AF_INET6;
  35.         dest_addr.sin6_port = htons(PORT);
  36.         dest_addr.sin6_scope_id = esp_netif_get_netif_impl_index(EXAMPLE_INTERFACE);
  37.         addr_family = AF_INET6;
  38.         ip_protocol = IPPROTO_IPV6;
  39. #elif defined(CONFIG_EXAMPLE_SOCKET_IP_INPUT_STDIN)
  40.         struct sockaddr_storage dest_addr = { 0 };
  41.         ESP_ERROR_CHECK(get_addr_from_stdin(PORT, SOCK_STREAM, &ip_protocol, &addr_family, &dest_addr));
  42. #endif
  43.         int sock =  socket(addr_family, SOCK_STREAM, ip_protocol);
  44.         if (sock < 0) {
  45.             ESP_LOGE(TAGC, "Unable to create socket: errno %d", errno);
  46.             break;
  47.         }
  48.         ESP_LOGI(TAGC, "Socket created, connecting to %s:%d", host_ip, PORT);
  50.         int err = connect(sock, (struct sockaddr *)&dest_addr, sizeof(struct sockaddr_in6));
  51.         if (err != 0) {
  52.             ESP_LOGE(TAGC, "Socket unable to connect: errno %d", errno);
  53.             break;
  54.         }
  55.         ESP_LOGI(TAGC, "Successfully connected");
  57.         while (1) {
  58.             int err = send(sock, payload, strlen(payload), 0);
  59.             if (err < 0) {
  60.                 ESP_LOGE(TAGC, "Error occurred during sending: errno %d", errno);
  61.                 break;
  62.             }
  64.             int len = recv(sock, rx_buffer, sizeof(rx_buffer) - 1, 0);
  65.             // Error occurred during receiving
  66.             if (len < 0) {
  67.                 ESP_LOGE(TAGC, "recv failed: errno %d", errno);
  68.                 break;
  69.             }
  70.             // Data received
  71.             else {
  72.                 rx_buffer[len] = 0; // Null-terminate whatever we received and treat like a string
  73.                 ESP_LOGI(TAGC, "Received %d bytes from %s:", len, host_ip);
  74.                 ESP_LOGI(TAGC, "%s", rx_buffer);
  75.             }
  77.             vTaskDelay(2000 / portTICK_PERIOD_MS);
  78.         }
  80.         if (sock != -1) {
  81.             ESP_LOGE(TAGC, "Shutting down socket and restarting...");
  82.             shutdown(sock, 0);
  83.             close(sock);
  84.         }
  85.     }
  86.     vTaskDelete(NULL);
  87. }
  89. void tcpClientStart(void)
  90. {
  91.    // ESP_ERROR_CHECK(nvs_flash_init());
  92.    // ESP_ERROR_CHECK(esp_netif_init());
  93.    // ESP_ERROR_CHECK(esp_event_loop_create_default());
  95.     /* This helper function configures Wi-Fi or Ethernet, as selected in menuconfig.
  96.      * Read "Establishing Wi-Fi or Ethernet Connection" section in
  97.      * examples/protocols/README.md for more information about this function.
  98.      */
  99.    // ESP_ERROR_CHECK(example_connect());
  101.     xTaskCreate(tcp_client_task, "tcp_client", 4096, NULL, 5, NULL);
  102. }
复制代码
注意

需要在Kconfig.projbuild文件中预先进行一些配置如IP,端口号等。CMakeLists.txt需要包含主函数调用的所有c文件。
结果

成功通信运行的结果如下图所示
服务端运行

客户端运行


免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！

本帖子中包含更多资源

您需要 登录 才可以下载或查看，没有账号？立即注册

x
回复

使用道具 举报

0 个回复

倒序浏览
返回列表

快速回复

高级模式
B Color Image Link Quote Code Smilies
您需要登录后才可以回帖 登录 or 立即注册

本版积分规则

熊熊出没

金牌会员
这个人很懒什么都没写!

楼主热帖

标签云

存储 服务器
微信订阅号
微信服务号
微信客服
小程序
H5
关于我们 商务合作 网站地图
©Copyright 2022-2024 杭州祥升科技有限公司 版权所有 浙ICP备20004199号
快速回复 返回顶部 返回列表