ESP32 UDP 05

1.在上一文章基础上修改，文章网址

ESP32-Ethernet-04-CSDN博客
2.基本代码

1. /* Ethernet Basic Example
3.    This example code is in the Public Domain (or CC0 licensed, at your option.)
5.    Unless required by applicable law or agreed to in writing, this
6.    software is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR
7.    CONDITIONS OF ANY KIND, either express or implied.
8. */
9. #include <stdio.h>
10. #include <string.h>
11. #include "freertos/FreeRTOS.h"
12. #include "freertos/task.h"
13. #include "esp_netif.h"
14. #include "esp_eth.h"
15. #include "esp_event.h"
16. #include "esp_log.h"
17. #include "ethernet_init.h"
18. #include "sdkconfig.h"
19. #include "nvs_flash.h"
20. #include "lwip/err.h"
21. #include "lwip/sockets.h"
22. #include "lwip/sys.h"
23. #include <lwip/netdb.h>
25. static const char *TAG = "eth_example";
27. /** Event handler for Ethernet events */
28. static void eth_event_handler(void *arg, esp_event_base_t event_base,
29.                               int32_t event_id, void *event_data)
30. {
31.     uint8_t mac_addr[6] = {0};
32.     /* we can get the ethernet driver handle from event data */
33.     esp_eth_handle_t eth_handle = *(esp_eth_handle_t *)event_data;
34.         esp_netif_t *eth_netif=(esp_netif_t *)arg;
35.     switch (event_id) {
36.     case ETHERNET_EVENT_CONNECTED:
37.                 esp_netif_dhcpc_stop(eth_netif);
38.         esp_netif_ip_info_t eth;
39.                 esp_netif_set_ip4_addr(&eth.ip,192, 168, 1, 22);
40.                esp_netif_set_ip4_addr(&eth.gw,192, 168, 1, 1);
41.                esp_netif_set_ip4_addr(&eth.netmask, 255, 255, 255, 0);
42.             esp_netif_set_ip_info(eth_netif,&eth);
44.         esp_eth_ioctl(eth_handle, ETH_CMD_G_MAC_ADDR, mac_addr);
45.         ESP_LOGI(TAG, "Ethernet Link Up");
46.         ESP_LOGI(TAG, "Ethernet HW Addr %02x:%02x:%02x:%02x:%02x:%02x",
47.                  mac_addr[0], mac_addr[1], mac_addr[2], mac_addr[3], mac_addr[4], mac_addr[5]);
48.         break;
49.     case ETHERNET_EVENT_DISCONNECTED:
50.         ESP_LOGI(TAG, "Ethernet Link Down");
51.         break;
52.     case ETHERNET_EVENT_START:
53.         ESP_LOGI(TAG, "Ethernet Started");
54.         break;
55.     case ETHERNET_EVENT_STOP:
56.         ESP_LOGI(TAG, "Ethernet Stopped");
57.         break;
58.     default:
59.         break;
60.     }
61. }
63. //IP_EVENT_ETH_GOT_IP的事件处理程序
64. static void got_ip_event_handler(void *arg, esp_event_base_t event_base,
65.                                  int32_t event_id, void *event_data)
66. {
67.     ip_event_got_ip_t *event = (ip_event_got_ip_t *) event_data;
68.     const esp_netif_ip_info_t *ip_info = &event->ip_info;
69.     ESP_LOGI(TAG, "Ethernet Got IP Address");
70.     ESP_LOGI(TAG, "~~~~~~~~~~~");
71.     ESP_LOGI(TAG, "ETHIP:" IPSTR, IP2STR(&ip_info->ip));
72.     ESP_LOGI(TAG, "ETHMASK:" IPSTR, IP2STR(&ip_info->netmask));
73.     ESP_LOGI(TAG, "ETHGW:" IPSTR, IP2STR(&ip_info->gw));
74.     ESP_LOGI(TAG, "~~~~~~~~~~~");
75. }
78. //UDP 接受任务函数
79. static void udp_recv_task(void* arg)
80. {
81.     char rx_buffer[128];
82.         int sock = *(int *)arg;
83.     struct sockaddr_in source_addr; // Large enough for both IPv4 or IPv6
84.     socklen_t socklen = sizeof(source_addr);
85.     for (;;)
86.         {
87.                 //清空缓存
88.                 memset(rx_buffer, 0, sizeof(rx_buffer));
89.                 //接受数据
90.                 int len = recvfrom(sock, rx_buffer, sizeof(rx_buffer), 0, (struct sockaddr *)&source_addr, &socklen);
91.                 //发送数据
92.                 int err = sendto(sock, rx_buffer, len, 0, (struct sockaddr *)&source_addr, sizeof(source_addr));
93.                 if(err < 0)
94.                 {
95.                         printf("Error occurred during sending: errno %d", errno);
96.                 }
98.     }
99. }
101. void app_main(void)
102. {
103.         esp_err_t ret = nvs_flash_init();
104.     if (ret == ESP_ERR_NVS_NO_FREE_PAGES || ret == ESP_ERR_NVS_NEW_VERSION_FOUND) {
105.       ESP_ERROR_CHECK(nvs_flash_erase());
106.       ret = nvs_flash_init();
107.     }
108.         //初始化TCP/IP网络接口
109.     esp_netif_init();
110.     //创建一个在后台运行的默认事件循环
111.     esp_event_loop_create_default();
113.     //初始化MAC和PHY默认配置
114.         eth_mac_config_t mac_config = ETH_MAC_DEFAULT_CONFIG();
115.     eth_phy_config_t phy_config = ETH_PHY_DEFAULT_CONFIG();
116.    
117.         //PHY地址和复位引脚配置
118.         phy_config.phy_addr = CONFIG_EXAMPLE_ETH_PHY_ADDR;
119.     phy_config.reset_gpio_num = CONFIG_EXAMPLE_ETH_PHY_RST_GPIO;
121.         //初始化EMAC默认配置
122.         eth_esp32_emac_config_t esp32_emac_config = ETH_ESP32_EMAC_DEFAULT_CONFIG();
123.        
124.         //MDC的信号引脚
125.         esp32_emac_config.smi_mdc_gpio_num = CONFIG_EXAMPLE_ETH_MDC_GPIO;
126.         //MDIO的信号引脚
127.     esp32_emac_config.smi_mdio_gpio_num = CONFIG_EXAMPLE_ETH_MDIO_GPIO;
129.          //创建MAC实例
130.     esp_eth_mac_t *mac = esp_eth_mac_new_esp32(&esp32_emac_config, &mac_config);
132.         //创建PHY实例
133.         esp_eth_phy_t *phy = esp_eth_phy_new_lan87xx(&phy_config);
135.         //驱动程序安装完毕后，将得到驱动程序的句柄
136.         esp_eth_handle_t eth_handle = NULL;
137.         //应用默认驱动程序配置
138.     esp_eth_config_t config = ETH_DEFAULT_CONFIG(mac, phy);
139.         //安装驱动程序
140.         esp_eth_driver_install(&config, &eth_handle);
142.         //应用以太网默认的网络接口配置
143.         esp_netif_config_t cfg = ESP_NETIF_DEFAULT_ETH();
145.         //为以太网驱动程序创建网络接口
146.         esp_netif_t *eth_netif = esp_netif_new(&cfg);
148.         //将以太网驱动程序连接至TCP/IP协议栈
149.         esp_netif_attach(eth_netif, esp_eth_new_netif_glue(eth_handle));
151.     //注册以太网事件处理程序
152.     esp_event_handler_register(ETH_EVENT, ESP_EVENT_ANY_ID, &eth_event_handler, eth_netif);
153.        
154.         //注册用户定义的IP事件处理程序
155.     esp_event_handler_register(IP_EVENT, IP_EVENT_ETH_GOT_IP, &got_ip_event_handler, eth_netif);
157.         //启动以太网驱动程序状态机
158.     esp_eth_start(eth_handle);
160.         //新建socket
161.         int sock =  socket(AF_INET, SOCK_DGRAM, IPPROTO_IP);
163.         //绑定本机地址的IP和端口
164.         struct sockaddr_in dest_addr;
165.     dest_addr.sin_family = AF_INET;
166.     dest_addr.sin_addr.s_addr = htonl(INADDR_ANY);
167.     dest_addr.sin_port = htons(10000);
168.         //绑定本机IP
169.         int err = bind(sock, (struct sockaddr *)&dest_addr, sizeof(dest_addr));
170.         if(err < 0)
171.         {
172.                 printf("Socket unable to bind: errno %d", errno);
173.                 close(sock);
174.         }
175.         //创建任务
176.     xTaskCreate(udp_recv_task, "udp_recv_task", 2048, &sock, 10, NULL);
177. }

复制代码

3.运行和测试效果

免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！更多信息从访问主页：qidao123.com:ToB企服之家，中国第一个企服评测及商务社交产业平台。