这次用的是CubeIDE + CubeMX
要把NX_APP的mem分配的大一些，在app_azure_rtos.c中，我给的是40*1024，如果给的不够，会导致后面无法分配pool和thread等等
需要用到filex 要在CubeMX里面勾选上，还要用到http_server和dhcp
netxduo/addons/auto_ip at v6.1.11_rel · eclipse-threadx/netxduo · GitHub
选择自己对应版本的即可
在nx_stm32_eth_config.h里添加
#define NX_ETH_CABLE_CONNECTION_CHECK_PERIOD 600
在app_filex.c里删除多余的东西，就保留这样
app_netxduo.c
/* USER CODE BEGIN Header */
/**
******************************************************************************
* @file app_netxduo.c
* @author MCD Application Team
* @brief NetXDuo applicative file
******************************************************************************
* @attention
*
* Copyright (c) 2021 STMicroelectronics.
* All rights reserved.
*
* This software is licensed under terms that can be found in the LICENSE file
* in the root directory of this software component.
* If no LICENSE file comes with this software, it is provided AS-IS.
*
******************************************************************************
*/
/* USER CODE END Header */
/* Includes ------------------------------------------------------------------*/
#include "app_netxduo.h"
#include "nx_stm32_eth_config.h"
#include "usart.h"
/* Private includes ----------------------------------------------------------*/
/* USER CODE BEGIN Includes */
#include "tx_api.h"
/* USER CODE END Includes */
/* Private typedef -----------------------------------------------------------*/
/* USER CODE BEGIN PTD */
extern void fx_stm32_sram_driver(FX_MEDIA *media_ptr);
VOID nx_stm32_eth_driver(NX_IP_DRIVER *driver_req_ptr);
static VOID App_Main_Thread_Entry(ULONG thread_input);
TX_SEMAPHORE Semaphore;
FX_MEDIA ram_disk;
UCHAR ram_disk_memory[32000];
NX_HTTP_SERVER my_server;
NX_PACKET_POOL server_pool;
NX_PACKET_POOL tx_pool;
TX_THREAD AppWebServerThread;
TX_THREAD AppMainThread;
TX_THREAD AppLinkThread;
NX_IP ip_0;
NX_DHCP DHCPClient;
ULONG IpAddress;
ULONG NetMask;
static uint8_t nx_server_pool[SERVER_POOL_SIZE];
uint32_t DataBuffer[512];
void nx_server_thread_entry(ULONG thread_input);
static VOID ip_address_change_notify_callback(NX_IP *ip_instance, VOID *ptr);
UINT webserver_request_notify_callback(NX_HTTP_SERVER *server_ptr, UINT request_type, CHAR *resource, NX_PACKET *packet_ptr);
static VOID ip_address_change_notify_callback(NX_IP *ip_instance, VOID *ptr);
static VOID App_Link_Thread_Entry(ULONG thread_input);
/* USER CODE END PTD */
/* Private define ------------------------------------------------------------*/
/* USER CODE BEGIN PD */
/* USER CODE END PD */
/* Private macro -------------------------------------------------------------*/
/* USER CODE BEGIN PM */
/* App memory pointer. */
/* USER CODE END PM */
/* Private variables ---------------------------------------------------------*/
/* USER CODE BEGIN PV */
/* USER CODE END PV */
/* Private function prototypes -----------------------------------------------*/
/* USER CODE BEGIN PFP */
/* USER CODE END PFP */
/**
* @brief Application NetXDuo Initialization.
* @param memory_ptr: memory pointer
* @retval int
*/
UINT MX_NetXDuo_Init(VOID *memory_ptr)
{
UCHAR *pointer ;
UINT ret = NX_SUCCESS;
TX_BYTE_POOL *byte_pool = (TX_BYTE_POOL*)memory_ptr;
/* USER CODE BEGIN MX_NetXDuo_MEM_POOL */
/* Initialize the NetX system. */
nx_system_initialize();
ret = tx_byte_allocate(byte_pool, (VOID **) &pointer, NX_PACKET_POOL_SIZE, TX_NO_WAIT);
if (ret != NX_SUCCESS)
{
printf("Packed pool memory allocation failed : 0x%02x\n", ret);
Error_Handler();
}
/* Create a packet pool. */
ret = nx_packet_pool_create(&tx_pool,"NetX Main txPacket Pool",1536,pointer ,NX_PACKET_POOL_SIZE);
if (ret != NX_SUCCESS)
{
printf("Packed creation failed : 0x%02x\n", ret);
Error_Handler();
}
ret = tx_byte_allocate(byte_pool, (VOID **) &pointer, SERVER_POOL_SIZE, TX_NO_WAIT);
if (ret != NX_SUCCESS)
{
printf("Packed pool memory allocation failed : 0x%02x\n", ret);
Error_Handler();
}
ret = nx_packet_pool_create(&server_pool, "HTTP Server Packet Pool", SERVER_PACKET_SIZE,nx_server_pool, SERVER_POOL_SIZE);
if (ret != NX_SUCCESS)
{
printf("Server pool creation failed : 0x%02x\n", ret);
Error_Handler();
}
// ip instance
ret = tx_byte_allocate(byte_pool, (VOID **) &pointer, 2 * DEFAULT_MEMORY_SIZE, TX_NO_WAIT);
if (ret != NX_SUCCESS)
{
printf("NetX IP Instance memory allocation failed : 0x%02x\n", ret);
Error_Handler();
}
/* Create an IP instance. */
ret = nx_ip_create(&ip_0, "NetX IP Instance 0", IP_ADDRESS(192, 168,3, 36), 0xFFFFFF00UL, &tx_pool, nx_stm32_eth_driver,
pointer, 2 * DEFAULT_MEMORY_SIZE, DEFAULT_PRIORITY);
if (ret != NX_SUCCESS)
{
printf("IP Instance creation failed : 0x%02x\n",ret);
Error_Handler();
}
// arp
ret = tx_byte_allocate(byte_pool, (VOID **) &pointer, ARP_CACHE_SIZE, TX_NO_WAIT);
if (ret != NX_SUCCESS)
{
printf("ARP cache memory allocation failed : 0x%02x\n", ret);
Error_Handler();
}
ret = nx_arp_enable(&ip_0, (void *) pointer, ARP_CACHE_SIZE);
if (ret != NX_SUCCESS)
{
printf("ARP Enable for IP error : 0x%02x\n", ret);
Error_Handler();
}
ret = nx_icmp_enable(&ip_0);
if (ret != NX_SUCCESS)
{
printf("ICMP enable for IP error : 0x%02x\n", ret);
Error_Handler();
}
ret = nx_udp_enable(&ip_0);
if (ret != NX_SUCCESS)
{
printf("UDP enable for IP error : 0x%02x\n", ret);
Error_Handler();
}
ret = nx_tcp_enable(&ip_0);
if (ret!=NX_SUCCESS)
{
printf("TCP enable for IP error : 0x%02x\n", ret);
Error_Handler();
}
ret = tx_byte_allocate(byte_pool, (VOID **) &pointer, SERVER_STACK, TX_NO_WAIT);
if (ret != NX_SUCCESS)
{
printf("Server stack memory allocation failed : 0x%02x\n", ret);
Error_Handler();
}
ret = nx_http_server_create(&my_server, "My HTTP Server", &ip_0, &ram_disk,
pointer, SERVER_STACK, &server_pool, NX_NULL, webserver_request_notify_callback);
if (ret != NX_SUCCESS)
{
printf("HTTP WEB Server creation failed: 0x%02x\n", ret);
Error_Handler();
}
// web thread
ret = tx_byte_allocate(byte_pool, (VOID **) &pointer, 2 * DEFAULT_MEMORY_SIZE, TX_NO_WAIT);
if (ret != TX_SUCCESS)
{
printf("Main thread memory allocation failed : 0x%02x\n", ret);
Error_Handler();
}
ret = tx_thread_create(&AppMainThread, "App Main thread", App_Main_Thread_Entry, 0, pointer, 2 * DEFAULT_MEMORY_SIZE,
DEFAULT_MAIN_PRIORITY, DEFAULT_MAIN_PRIORITY, TX_NO_TIME_SLICE, TX_AUTO_START);
if (ret != TX_SUCCESS)
{
return NX_NOT_ENABLED;
}
/* Allocate the TCP server thread stack. */
ret = tx_byte_allocate(byte_pool, (VOID **) &pointer, 2 * DEFAULT_MEMORY_SIZE, TX_NO_WAIT);
/* Check server thread memory allocation. */
if (ret != TX_SUCCESS)
{
printf("Server thread memory allocation failed : 0x%02x\n", ret);
Error_Handler();
}
ret = tx_thread_create(&AppWebServerThread, "App Web Server Thread", nx_server_thread_entry, 0, pointer, 2 * DEFAULT_MEMORY_SIZE,
DEFAULT_PRIORITY, DEFAULT_PRIORITY, TX_NO_TIME_SLICE, TX_DONT_START);
if (ret != TX_SUCCESS)
{
return NX_NOT_ENABLED;
}
/* Allocate the memory for Link thread */
if (tx_byte_allocate(byte_pool, (VOID **) &pointer,2 * DEFAULT_MEMORY_SIZE, TX_NO_WAIT) != TX_SUCCESS)
{
return TX_POOL_ERROR;
}
/* create the Link thread */
ret = tx_thread_create(&AppLinkThread, "App Link Thread", App_Link_Thread_Entry, 0, pointer, 2 * DEFAULT_MEMORY_SIZE,
LINK_PRIORITY, LINK_PRIORITY, TX_NO_TIME_SLICE, TX_AUTO_START);
if (ret != TX_SUCCESS)
{
return NX_NOT_ENABLED;
}
/* Create the DHCP instance. */
ret = nx_dhcp_create(&DHCPClient, &ip_0, "dhcp_client");
if (ret != NX_SUCCESS)
{
printf("DHCP Instance creation failed : 0x%02x\n", ret);
}
ret = nx_ip_address_change_notify(&ip_0, ip_address_change_notify_callback, NULL);
if (ret != NX_SUCCESS)
{
Error_Handler();
}
ret = tx_semaphore_create(&Semaphore, "App Semaphore", 0);
if (ret != TX_SUCCESS)
{
printf("Semaphore creation failed : 0x%02x\n", ret);
Error_Handler();
}
/* USER CODE END MX_NetXDuo_MEM_POOL */
/* USER CODE BEGIN MX_NetXDuo_Init */
/* USER CODE END MX_NetXDuo_Init */
return ret;
}
/* USER CODE BEGIN 1 */
void nx_server_thread_entry(ULONG thread_input)
{
UINT status;
tx_thread_sleep(NX_IP_PERIODIC_RATE);
NX_PARAMETER_NOT_USED(thread_input);
// status = fx_media_open(&ram_disk, "STM32_SDIO_DISK", fx_stm32_sram_driver, (VOID *)SRAM2_BASE, DataBuffer, sizeof(DataBuffer));
// if (status != FX_SUCCESS)
// {
// /*Print Media Opening error. */
// printf("FX media opening failed : 0x%02x\n", status);
// /* Error, call error handler.*/
// Error_Handler();
// }
// tx_thread_sleep(NX_IP_PERIODIC_RATE);
status = nx_http_server_start(&my_server);
if (status != NX_SUCCESS)
{
/* Print HTTP WEB Server starting error. */
printf("HTTP WEB Server Starting Failed, error: 0x%02x\n", status);
/* Error, call error handler.*/
Error_Handler();
}
tx_thread_sleep(NX_IP_PERIODIC_RATE);
}
UINT webserver_request_notify_callback(NX_HTTP_SERVER *server_ptr, UINT request_type, CHAR *resource, NX_PACKET *packet_ptr)
{
CHAR temp_string[30] = {'\0'};
CHAR data[512] = {'\0'};
UINT string_length;
NX_PACKET *resp_packet_ptr;
UINT status;
NX_PARAMETER_NOT_USED(server_ptr);
NX_PARAMETER_NOT_USED(request_type);
NX_PARAMETER_NOT_USED(packet_ptr);
if (strcmp(resource, "/GetTXData") == 0)
{
/* Let HTTP server know the response has been sent. */
sprintf(data, "%lu.%lu.%lu.%lu,%u", (IpAddress >> 24) & 0xff, (IpAddress >> 16) & 0xff, (IpAddress >> 8) & 0xff, IpAddress& 0xff, CONNECTION_PORT);
}
else{
return NX_SUCCESS;
}
nx_http_server_type_get(server_ptr, server_ptr -> nx_http_server_request_resource, temp_string);
temp_string[string_length] = '\0';
status = nx_http_server_callback_generate_response_header(server_ptr, &resp_packet_ptr, NX_HTTP_STATUS_OK,
strlen(data), temp_string, NX_NULL);
status = nx_packet_data_append(resp_packet_ptr, data, strlen(data), server_ptr->nx_http_server_packet_pool_ptr, NX_WAIT_FOREVER);
status = nx_http_server_callback_packet_send(server_ptr, resp_packet_ptr);
if (status != NX_SUCCESS)
{
nx_packet_release(resp_packet_ptr);
return status;
}
return(NX_HTTP_CALLBACK_COMPLETED);
}
static VOID ip_address_change_notify_callback(NX_IP *ip_instance, VOID *ptr)
{
/* as soon as the IP address is ready, the semaphore is released to let the web server start */
tx_semaphore_put(&Semaphore);
}
static VOID App_Main_Thread_Entry(ULONG thread_input)
{
UINT ret;
ret = nx_ip_address_change_notify(&ip_0, ip_address_change_notify_callback, NULL);
if (ret != NX_SUCCESS)
{
Error_Handler();
}
ret = nx_dhcp_start(&DHCPClient);
if (ret != NX_SUCCESS)
{
Error_Handler();
}
/* wait until an IP address is ready */
// if(tx_semaphore_get(&Semaphore, TX_WAIT_FOREVER) != TX_SUCCESS)
// {
// Error_Handler();
// }
/* get IP address */
ret = nx_ip_address_get(&ip_0, &IpAddress, &NetMask);
if (ret != TX_SUCCESS)
{
Error_Handler();
}
/* the network is correctly initialized, start the nx_server_thread_entry */
tx_thread_resume(&AppWebServerThread);
/* this thread is not needed any more, we relinquish it */
tx_thread_relinquish();
return;
}
static VOID App_Link_Thread_Entry(ULONG thread_input)
{
ULONG actual_status;
UINT linkdown = 0, status;
while(1)
{
/* Get Physical Link stackavailtus. */
status = nx_ip_interface_status_check(&ip_0, 0, NX_IP_LINK_ENABLED,
&actual_status, 10);
if(status == NX_SUCCESS)
{
if(linkdown == 1)
{
linkdown = 0;
status = nx_ip_interface_status_check(&ip_0, 0, NX_IP_ADDRESS_RESOLVED,
&actual_status, 10);
if(status == NX_SUCCESS)
{
/* The network cable is connected again. */
printf("The network cable is connected again.\n");
/* Print Webserver Client is available again. */
printf("Webserver Client is available again.\n");
}
else
{
/* The network cable is connected. */
printf("The network cable is connected.\n");
/* Send command to Enable Nx driver. */
nx_ip_driver_direct_command(&ip_0, NX_LINK_ENABLE,
&actual_status);
/* Restart DHCP Client. */
nx_dhcp_stop(&DHCPClient);
nx_dhcp_start(&DHCPClient);
}
}
}
else
{
if(0 == linkdown)
{
linkdown = 1;
/* The network cable is not connected. */
printf("The network cable is not connected.\n");
}
}
tx_thread_sleep(NX_ETH_CABLE_CONNECTION_CHECK_PERIOD);
}
}
/* USER CODE END 1 */
app_netxduo.h
/* USER CODE BEGIN Header */
/**
******************************************************************************
* @file app_netxduo.h
* @author MCD Application Team
* @brief NetXDuo applicative header file
******************************************************************************
* @attention
*
* Copyright (c) 2020-2021 STMicroelectronics.
* All rights reserved.
*
* This software is licensed under terms that can be found in the LICENSE file
* in the root directory of this software component.
* If no LICENSE file comes with this software, it is provided AS-IS.
*
******************************************************************************
*/
/* USER CODE END Header */
/* Define to prevent recursive inclusion -------------------------------------*/
#ifndef __APP_NETXDUO_H__
#define __APP_NETXDUO_H__
#ifdef __cplusplus
extern "C" {
#endif
/* Includes ------------------------------------------------------------------*/
#include "nx_api.h"
/* Private includes ----------------------------------------------------------*/
#include "nx_stm32_eth_driver.h"
/* USER CODE BEGIN Includes */
#include "app_filex.h"
#include "tx_thread.h"
#include "main.h"
#include "nxd_http_server.h"
#include "tx_thread.h"
#include "nxd_dhcp_client.h"
/* USER CODE END Includes */
/* Exported types ------------------------------------------------------------*/
/* USER CODE BEGIN ET */
#define DEFAULT_MEMORY_SIZE 1024
#define SERVER_PACKET_SIZE (NX_HTTP_SERVER_MIN_PACKET_SIZE * 2)
#define NX_PACKET_POOL_SIZE ((1536 + sizeof(NX_PACKET)) * 8)
#define SERVER_POOL_SIZE (SERVER_PACKET_SIZE * 4)
#define ARP_CACHE_SIZE 1024
#define SERVER_STACK 4096
#define DEFAULT_MAIN_PRIORITY 10
#define DEFAULT_PRIORITY 5
#define LINK_PRIORITY 11
#define CONNECTION_PORT 80
/* USER CODE END ET */
/* Exported constants --------------------------------------------------------*/
/* USER CODE BEGIN EC */
/* USER CODE END EC */
/* Exported macro ------------------------------------------------------------*/
/* USER CODE BEGIN EM */
/* USER CODE END EM */
/* Exported functions prototypes ---------------------------------------------*/
UINT MX_NetXDuo_Init(VOID *memory_ptr);
/* USER CODE BEGIN EFP */
/* USER CODE END EFP */
/* Private defines -----------------------------------------------------------*/
/* USER CODE BEGIN PD */
/* USER CODE END PD */
/* USER CODE BEGIN 1 */
/* USER CODE END 1 */
#ifdef __cplusplus
}
#endif
#endif /* __APP_NETXDUO_H__ */
在这里设置导航，我写了一个/GetTXData，让它返回当前IP地址，大家自己实现自己的东西就可以。
