128天创作纪念日 - wpsshop博客
devbox
小小林熬夜学编程
这个屌丝很懒，什么也没留下！
关注作者
热门标签
热门文章
当前位置:   article > 正文

128天创作纪念日

作者：小小林熬夜学编程 | 2024-06-08 19:27:46

赞

踩

128天创作纪念日

机缘

起初写博客，就是为了分享自己所学的东西，希望能帮助到别人，在几年前最初学一些技术类的东西时候，很艰难，没有教，又没人带，十分痛苦。后面在网上查阅的资料越来越多，特别是CSDN博客论坛上，有很多人分享的笔记文章影响到了我，所以开始学着他们的步伐，去分享自己的笔记文章，帮助更多的人在初学起步的时候，不会那么艰难。

收获

在创作的过程中，收获了490个粉丝，3万2千多个阅读量，476次点赞和457次收藏，24次评论。

日常

起初写博客文章，也是十分的艰难，没有什么idea，也不知道写什么东西，要怎么样去分享自己掌握的东西。后面因为学习的东西越来越多，发现经常会遗忘，就开始记笔记，一开始在有道云笔记上面写了大概8个月左右的内容，后面就直接到CSDN博客上开始记录笔记并且分享。写博客和学习工作方面的话，并不会冲突，这不仅可以帮助自己梳理知识体系，也可以更近一步的理解掌握这些内容。

成就

 分享一段写的还看得过去的代码

  1. #include "network.h"
  2.  
  3. //ESP-IDF v5.1
  4. static const char *TAG = "wifi_station";
  5.  
  6. int tcp_sock = -1;
  7. int udp_sock = -1;
  8.  
  9. esp_ping_handle_t ping;
  10. int ping_flag = -1;
  11. enum {
  12.     PING_IP_OK = 0,
  13.     PING_IP_ERR
  14. };
  15. struct sockaddr_in dest_addr;
  16.  
  17. /**
  18.   * @brief  连接WiFi事件处理器---处理WiFi和IP事件
  19.   * @param  arg:用户定义的参数
  20.   * @param  event_base:事件基类型
  21.   * @param  event_id:事件具体ID
  22.   * @param  event_data:指向事件数据的指针
  23.   * @retval void
  24.   */
  25. void connect_wifi_ap_event_handler(void* arg, esp_event_base_t event_base, int32_t event_id, void* event_data)
  26. {
  27.     if (event_base == WIFI_EVENT && event_id == WIFI_EVENT_STA_START) {
  28.         esp_wifi_connect();
  29.     } else if (event_base == WIFI_EVENT && event_id == WIFI_EVENT_STA_DISCONNECTED) {
  30.         esp_wifi_connect();
  31.     } else if (event_base == IP_EVENT && event_id == IP_EVENT_STA_GOT_IP) {
  32.         ip_event_got_ip_t* event = (ip_event_got_ip_t*) event_data;
  33.         char addr_str[IP4ADDR_STRLEN_MAX];
  34.         ESP_LOGI(TAG, "got ip:%s", esp_ip4addr_ntoa(&event->ip_info.ip, addr_str, IP4ADDR_STRLEN_MAX));
  35.     }
  36. }
  37.  
  38. /**
  39.   * @brief  设备连接WiFi AP热点
  40.   * @param  wifi_ssid:WiFi 热点ID
  41.   * @param  wifi_passwd:WiFi密码
  42.   * @retval void
  43.   */
  44. void device_connect_wifi_ap(uint8_t *wifi_ssid, uint8_t *wifi_passwd)
  45. {
  46.     esp_err_t ret = nvs_flash_init();
  47.     if (ret == ESP_ERR_NVS_NO_FREE_PAGES || ret == ESP_ERR_NVS_NEW_VERSION_FOUND) {
  48.         ESP_ERROR_CHECK(nvs_flash_erase());
  49.         ret = nvs_flash_init();
  50.     }
  51.     ESP_ERROR_CHECK(ret);
  52.  
  53.     ESP_ERROR_CHECK(esp_netif_init());
  54.     ESP_ERROR_CHECK(esp_event_loop_create_default());
  55.     esp_netif_create_default_wifi_sta();
  56.  
  57.     wifi_init_config_t cfg = WIFI_INIT_CONFIG_DEFAULT();
  58.     ESP_ERROR_CHECK(esp_wifi_init(&cfg));
  59.  
  60.     ESP_ERROR_CHECK(esp_event_handler_register(WIFI_EVENT, ESP_EVENT_ANY_ID, &connect_wifi_ap_event_handler, NULL));
  61.     ESP_ERROR_CHECK(esp_event_handler_register(IP_EVENT, IP_EVENT_STA_GOT_IP, &connect_wifi_ap_event_handler, NULL));
  62.  
  63.     wifi_config_t wifi_config;
  64.     memcpy(wifi_config.sta.ssid, wifi_ssid, strlen((char *)wifi_ssid)+1);
  65.     memcpy(wifi_config.sta.password, wifi_passwd, strlen((char *)wifi_passwd)+1);
  66.  
  67.     ESP_ERROR_CHECK(esp_wifi_set_mode(WIFI_MODE_STA));
  68.     ESP_ERROR_CHECK(esp_wifi_set_config(ESP_IF_WIFI_STA, &wifi_config));
  69.     ESP_ERROR_CHECK(esp_wifi_start());
  70. }
  71.  
  72. /**
  73.   * @brief  udp客户端初始化
  74.   * @param  None
  75.   * @retval 成功返回0，失败返回-1
  76.   */
  77. int udp_client_init(void)
  78. {
  79.     char host_ip[] = HOST_IP_ADDR;
  80.     int addr_family = 0;
  81.     int ip_protocol = 0;  
  82. #if defined(CONFIG_EXAMPLE_IPV4)
  83.     //struct sockaddr_in dest_addr;
  84.     dest_addr.sin_addr.s_addr = inet_addr(host_ip);
  85.     dest_addr.sin_family = AF_INET;
  86.     dest_addr.sin_port = htons(PORT);
  87.     addr_family = AF_INET;
  88.     ip_protocol = IPPROTO_IP;
  89. #elif defined(CONFIG_EXAMPLE_IPV6)
  90.     struct sockaddr_in6 dest_addr = {0};
  91.     inet6_aton(HOST_IP_ADDR, &dest_addr.sin6_addr);
  92.     dest_addr.sin6_family = AF_INET6;
  93.     dest_addr.sin6_port = htons(PORT);
  94.     dest_addr.sin6_scope_id = esp_netif_get_netif_impl_index(EXAMPLE_INTERFACE);
  95.     addr_family = AF_INET6;
  96.     ip_protocol = IPPROTO_IPV6;
  97. #elif defined(CONFIG_EXAMPLE_SOCKET_IP_INPUT_STDIN)
  98.     struct sockaddr_storage dest_addr = {0};
  99.     ESP_ERROR_CHECK(get_addr_from_stdin(PORT, SOCK_DGRAM, &ip_protocol, &addr_family, &dest_addr));
  100. #endif
  101.     extern int udp_sock;
  102.     udp_sock = socket(addr_family, SOCK_DGRAM, ip_protocol);
  103.     if (udp_sock < 0)
  104.     {
  105.         ESP_LOGE(TAG, "Unable to create socket: errno %d", errno);
  106.         return -1;
  107.     }
  108.     ESP_LOGI(TAG, "Socket created, sending to %s:%d", HOST_IP_ADDR, PORT);
  109.     return 0;
  110. }
  111.  
  112. /**
  113.   * @brief  tcp客户端初始化
  114.   * @param  None
  115.   * @retval 成功返回0，失败返回-1
  116.   */
  117. int tcp_client_init(char ip_addr[])
  118. {
  119.     //char host_ip[128] = HOST_IP_ADDR;
  120.     char host_ip[128] = {0};
  121.     memcpy(host_ip, ip_addr, strlen(ip_addr));
  122.     int addr_family = 0;
  123.     int ip_protocol = 0;
  124.     int err = 0;
  125. #if defined(CONFIG_EXAMPLE_IPV4)
  126.     struct sockaddr_in dest_addr;
  127.     dest_addr.sin_addr.s_addr = inet_addr(host_ip);
  128.     dest_addr.sin_family = AF_INET;
  129.     dest_addr.sin_port = htons(PORT);
  130.     addr_family = AF_INET;
  131.     ip_protocol = IPPROTO_IP;
  132. #elif defined(CONFIG_EXAMPLE_IPV6)
  133.     struct sockaddr_in6 dest_addr = { 0 };
  134.     inet6_aton(host_ip, &dest_addr.sin6_addr);
  135.     dest_addr.sin6_family = AF_INET6;
  136.     dest_addr.sin6_port = htons(PORT);
  137.     dest_addr.sin6_scope_id = esp_netif_get_netif_impl_index(EXAMPLE_INTERFACE);
  138.     addr_family = AF_INET6;
  139.     ip_protocol = IPPROTO_IPV6;
  140. #elif defined(CONFIG_EXAMPLE_SOCKET_IP_INPUT_STDIN)
  141.     struct sockaddr_storage dest_addr = { 0 };
  142.     ESP_ERROR_CHECK(get_addr_from_stdin(PORT, SOCK_STREAM, &ip_protocol, &addr_family, &dest_addr));
  143. #endif
  144.     extern int tcp_sock;
  145.     tcp_sock = socket(addr_family, SOCK_STREAM, ip_protocol);
  146.     if (tcp_sock < 0) {
  147.         ESP_LOGE(TAG, "Unable to create socket: errno %d", errno);
  148.         return -1;
  149.     }
  150.     ESP_LOGI(TAG, "Socket created, connecting to server");
  151.     DPRINTF("Socket created, connecting to %s:%d\n", host_ip, PORT);
  152.     err = connect(tcp_sock, (struct sockaddr *)&dest_addr, sizeof(struct sockaddr_in6));
  153.     if (err != 0) {
  154.         ESP_LOGE(TAG, "Socket unable to connect: errno %d", errno);
  155.         return -1;
  156.     }
  157.     ESP_LOGI(TAG, "Successfully connected");
  158.     return 0;
  159. }
  160.  
  161. /**
  162.   * @brief  设备连接服务器
  163.   * @param  target_ip:目标IP地址
  164.   * @retval 成功返回0，失败返回-1
  165.   */
  166. int device_connect_to_server(char *target_ip)
  167. {
  168.     int sock = 0;
  169.     struct sockaddr_in serv_addr;
  170.     //#define PORT 5005
  171.     DPRINTF("FUNCTION:%s\tLINE:%d\n", __FUNCTION__, __LINE__);
  172.     if ((sock = socket(AF_INET, SOCK_STREAM, 0)) < 0) {
  173.         DPRINTF("\n Socket creation error \n");
  174.         close(sock);
  175.         return -1;
  176.     }
  177.     DPRINTF("FUNCTION:%s\tLINE:%d\n", __FUNCTION__, __LINE__);
  178.     memset(&serv_addr, '0', sizeof(serv_addr));
  179.     serv_addr.sin_family = AF_INET;
  180.     serv_addr.sin_port = htons(PORT);
  181.  
  182.     if(inet_pton(AF_INET, target_ip, &serv_addr.sin_addr)<=0) {
  183.         DPRINTF("\nInvalid address/ Address not supported \n");
  184.         close(sock);
  185.         return -1;
  186.     }
  187.     DPRINTF("FUNCTION:%s\tLINE:%d\n", __FUNCTION__, __LINE__);
  188.     if (connect(sock, (struct sockaddr *)&serv_addr, sizeof(serv_addr)) < 0) {
  189.         //send(sock, "hello", strlen("hello"), 0);
  190.         DPRINTF("\nConnection Failed %s\t%d\n", target_ip, PORT);
  191.         close(sock);
  192.         return -1;
  193.     }
  194.     DPRINTF("Connected to %s:%d\n", target_ip, PORT);
  195.     //char str[] = "hello server!";
  196.     //send(sock, str, strlen(str)+1, 0);
  197.     close(sock);
  198.  
  199.     return 0;
  200. }
  201.  
  202. /**
  203.   * @brief  TCP扫描同一网段下的目标服务器设备
  204.   * @param  target_ip:目标IP地址
  205.   * @retval 成功返回0， 失败返回-1
  206.   */
  207. int device_scan_dest_server(char ip_addr[])
  208. {
  209.     char ip_local_addr[128]  = {0};
  210.     char ip_search_addr[256] = {0};
  211.     esp_netif_t *netif = esp_netif_get_handle_from_ifkey("WIFI_STA_DEF");
  212.     esp_netif_ip_info_t ip_info;
  213.     esp_netif_get_ip_info(netif, &ip_info); 
  214.     memcpy(ip_local_addr, ip4addr_ntoa((ip4_addr_t *)&ip_info.ip), strlen(ip4addr_ntoa((ip4_addr_t *)&ip_info.ip)));
  215.     
  216.     //char *ip4addr_ntoa(const ip4_addr_t *addr);
  217.     printf("device ip:%s\n", ip_local_addr);
  218.     //192.168.1.8
  219.     int i, self_ip_com = 0;
  220.     int tok_cnt = 1;
  221.     int ret = -1;
  222.     for(i = 0; i < 128; i++)
  223.     {
  224.         if(ip_local_addr[i] == '.')//获取所在网段
  225.         {
  226.             if(tok_cnt == 3)
  227.             {
  228.                 self_ip_com =  ip_local_addr[i+1] - '0';
  229.                 break;
  230.             }
  231.             tok_cnt++;
  232.         }
  233.         //DPRINTF("%c %d\n", ip_local_addr[i], i);
  234.     }
  235.     DPRINTF("self_ip_com:%d\n", self_ip_com);
  236.     DPRINTF("%s\t%d\n", __FUNCTION__,__LINE__);
  237.     char ip_addr_temp[128] = {0};
  238.     strncpy(ip_addr_temp, ip_local_addr, i+1);
  239.     DPRINTF("%s\n", ip_addr_temp);
  240.     int com;
  241.     for(com = 1; com < 255; com++)
  242.     {
  243.         if(com == self_ip_com)
  244.             continue;
  245.         sprintf(ip_search_addr, "%s%d", ip_addr_temp, com);
  246.         //DPRINTF("%s\n", ip_search_addr);
  247.         DPRINTF("%s\t%d\n", __FUNCTION__,__LINE__);
  248.         device_ping_ip_addr(ip_search_addr);//ping传入的ip地址
  249.         vTaskDelay(500 / portTICK_PERIOD_MS);
  250.         //ping通ip地址后，继续判断是否能够连接端口(5005)
  251.         if(ping_flag == PING_IP_OK)
  252.         {
  253.             esp_ping_stop(ping);
  254.             esp_ping_delete_session(ping);
  255.             DPRINTF("%s\t%d\n", __FUNCTION__,__LINE__);
  256.             ret = device_connect_to_server(ip_search_addr);
  257.             if (ret == 0)
  258.             {
  259.                 DPRINTF("Found the target server.\n");
  260.                 memcpy(ip_addr, ip_search_addr, strlen(ip_search_addr));
  261.                 break;
  262.             }
  263.         }else{
  264.             DPRINTF("%s\t%d\n", __FUNCTION__,__LINE__);
  265.             //vTaskDelay(300 / portTICK_PERIOD_MS);
  266.             esp_ping_stop(ping);
  267.             esp_ping_delete_session(ping);
  268.         }
  269.         DPRINTF("%s\t%d\n", __FUNCTION__,__LINE__);
  270.         //DPRINTF("try again.\n");
  271.         memset(ip_search_addr, 0, sizeof(ip_search_addr));
  272.     }
  273.     DPRINTF("%s\t%d\n", __FUNCTION__,__LINE__);
  274.     printf("com = %d\n", com);
  275.     if(com < 255)
  276.     {
  277.         DPRINTF("Device scan server success.\n");
  278.         
  279.         return 0;
  280.     }else{
  281.         DPRINTF("Device scan server failed.\n");
  282.         return -1;
  283.     }
  284. }
  285.  
  286. /**
  287.   * @brief  ping ip地址成功的回调函数
  288.   * @param  handle:ping ip句柄
  289.   * @param  args:传入给回调函数的参数
  290.   * @retval None
  291.   */
  292. void ping_ip_success(esp_ping_handle_t handle, void *args)
  293. {
  294.     // optionally, get callback arguments
  295.     // const char* str = (const char*) args;
  296.     // DPRINTF("%s\r\n", str); // "foo"
  297.     ping_flag = PING_IP_OK;
  298.     uint8_t ttl;
  299.     uint16_t seqno;
  300.     uint32_t elapsed_time, recv_len;
  301.     ip_addr_t target_addr;
  302.     esp_ping_get_profile(handle, ESP_PING_PROF_SEQNO, &seqno, sizeof(seqno));
  303.     esp_ping_get_profile(handle, ESP_PING_PROF_TTL, &ttl, sizeof(ttl));
  304.     esp_ping_get_profile(handle, ESP_PING_PROF_IPADDR, &target_addr, sizeof(target_addr));
  305.     esp_ping_get_profile(handle, ESP_PING_PROF_SIZE, &recv_len, sizeof(recv_len));
  306.     esp_ping_get_profile(handle, ESP_PING_PROF_TIMEGAP, &elapsed_time, sizeof(elapsed_time));
  307.     printf("%ld bytes from %s icmp_seq=%d ttl=%d time=%ld ms\n",
  308.            recv_len, inet_ntoa(target_addr.u_addr.ip4), seqno, ttl, elapsed_time);
  309. }
  310.  
  311. /**
  312.   * @brief  ping ip地址超时的回调函数
  313.   * @param  handle:ping ip句柄
  314.   * @param  args:传入给回调函数的参数
  315.   * @retval None
  316.   */
  317. void ping_ip_timeout(esp_ping_handle_t handle, void *args)
  318. {
  319.     ping_flag = PING_IP_ERR;
  320.     uint16_t seqno;
  321.     ip_addr_t target_addr;
  322.     esp_ping_get_profile(handle, ESP_PING_PROF_SEQNO, &seqno, sizeof(seqno));
  323.     esp_ping_get_profile(handle, ESP_PING_PROF_IPADDR, &target_addr, sizeof(target_addr));
  324.     printf("From %s icmp_seq=%d timeout\n", inet_ntoa(target_addr.u_addr.ip4), seqno);
  325. }
  326.  
  327. /**
  328.   * @brief  ping ip地址结束的回调函数
  329.   * @param  handle:ping ip句柄
  330.   * @param  args:传入给回调函数的参数
  331.   * @retval None
  332.   */
  333. void ping_ip_end(esp_ping_handle_t handle, void *args)
  334. {
  335.     uint32_t transmitted;
  336.     uint32_t received;
  337.     uint32_t total_time_ms;
  338.     ping_flag = -1;
  339.     esp_ping_get_profile(handle, ESP_PING_PROF_REQUEST, &transmitted, sizeof(transmitted));
  340.     esp_ping_get_profile(handle, ESP_PING_PROF_REPLY, &received, sizeof(received));
  341.     esp_ping_get_profile(handle, ESP_PING_PROF_DURATION, &total_time_ms, sizeof(total_time_ms));
  342.     DPRINTF("%ld packets transmitted, %ld received, time %ldms\n", transmitted, received, total_time_ms);
  343. }
  344.  
  345. /**
  346.   * @brief  ping ip地址
  347.   * @param  ip_str:字符串格式的IP地址   "192.168.1.8"
  348.   * @retval None
  349.   */
  350. void device_ping_ip_addr(char *ip_str)
  351. {
  352.     DPRINTF("%s\t%d\n", __FUNCTION__,__LINE__);
  353.     ip_addr_t target_addr;
  354.     esp_ping_config_t ping_config = ESP_PING_DEFAULT_CONFIG();
  355.     ping_config.interval_ms = 400;
  356.     ping_config.timeout_ms  = 400;
  357.     memset(&target_addr, 0, sizeof(ip_addr_t));
  358.     //字符串IP地址转换为ping_addr
  359.     if (ipaddr_aton(ip_str, &target_addr)) {
  360.         //DPRINTF("转换成功.\n");
  361.         ping_config.target_addr = target_addr;
  362.     } else {
  363.         DPRINTF("Invalid IP address\n");
  364.         return ;
  365.     }
  366.     DPRINTF("%s\t%d\n", __FUNCTION__,__LINE__);
  367.     //ping_config.target_addr = target_addr;          // target IP address
  368.     ping_config.count = ESP_PING_COUNT_INFINITE;    // ping in infinite mode, esp_ping_stop can stop it
  369.     
  370.     //设置回调函数
  371.     esp_ping_callbacks_t cbs;
  372.     cbs.on_ping_success = ping_ip_success;
  373.     cbs.on_ping_timeout = ping_ip_timeout;
  374.     cbs.on_ping_end = ping_ip_end;
  375.     cbs.cb_args = "ping ip";  // arguments that will feed to all callback functions, can be NULL
  376.     DPRINTF("%s\t%d\n", __FUNCTION__,__LINE__);
  377.     esp_ping_new_session(&ping_config, &cbs, &ping);
  378.     DPRINTF("%s\t%d\n", __FUNCTION__,__LINE__);
  379.     esp_ping_start(ping);
  380.     DPRINTF("%s\t%d\n", __FUNCTION__,__LINE__);
  381. }

憧憬

希望能保持分享，保持创作，让更多人喜欢我写的博客文章，帮助更多人学习或解决遇到的问题。

之后在创作方面，还会继续输出一些比较基础的内容，循序渐进输出一些更高难度的知识点，一是可以帮助自己巩固此前已经掌握的技术栈，二也是让关注我文章的读者，阅读起来不会突然感到吃力，更加的流畅。

Tips

  1. 您发布的文章将会展示至 里程碑专区 ，您也可以在 专区 内查看其他创作者的纪念日文章
  2. 优质的纪念文章将会获得神秘打赏哦
声明：本文内容由网友自发贡献，不代表【wpsshop博客】立场，版权归原作者所有，本站不承担相应法律责任。如您发现有侵权的内容，请联系我们。转载请注明出处：https://www.wpsshop.cn/w/小小林熬夜学编程/article/detail/690866
推荐阅读
相关标签

Copyright © 2003-2013 www.wpsshop.cn 版权所有，并保留所有权利。

  

闽ICP备14008679号