我試圖在我的STM32F107上做一個3或4個tcp服務器。我正在使用freeRTOS和LwIP(以及CubeMX + ST HAL庫)。STM32 LwiP多個TCP服務器
我創建了一個任務tcp_server,並在任務內部創建了3個netconn結構,每個結構都具有不同的tcp端口。 回調:
void socket_callback(struct netconn * conn, enum netconn_evt evt, u16_t len)
{
queue_event_t msg;
if (evt == NETCONN_EVT_RCVPLUS)
{
msg.cmd = MSG_TEST;
if (conn == user_conn.conn_modbus)
msg.cmd = MSG_MODBUS;
else if (conn == user_conn.conn_modbus_listen)
msg.cmd = MSG_MODBUS_LISTEN;
else if (conn == user_conn.conn_rs232)
msg.cmd = MSG_RS232;
else if (conn == user_conn.conn_rs232_listen)
msg.cmd = MSG_RS232_LISTEN;
else if (conn == user_conn.conn_rs485)
msg.cmd = MSG_RS485;
else if (conn == user_conn.conn_rs485_listen)
msg.cmd = MSG_RS485_LISTEN;
xQueueSend(user_conn.evtQueue, &msg, 1000);
}
}
服務器創建:
static struct netconn * createServer(int port)
{
struct netconn * conn;
err_t err;
conn = netconn_new_with_callback(NETCONN_TCP, socket_callback);
if (conn == NULL)
{
char *msg = "Cannot create netconn\n\r";
HAL_UART_Transmit(&huart3, (uint8_t*)msg, strlen(msg), 0xFFFF);
return NULL;
}
err = netconn_bind(conn, NULL, port);
if (err != ERR_OK)
{
char *msg = "Error in Binding \n\r";
HAL_UART_Transmit(&huart3, (uint8_t*)msg, strlen(msg), 0xFFFF);
print_error(err);
netconn_delete(conn);
return NULL;
}
err = netconn_listen(conn);
if (err != ERR_OK)
{
char *msg = "Error in listenning \n\r";
HAL_UART_Transmit(&huart3, (uint8_t*)msg, strlen(msg), 0xFFFF);
print_error(err);
netconn_delete(conn);
return NULL;
}
return conn;
}
主題:
static void servertcp_thread()
{
queue_event_t evt;
user_conn.evtQueue = xQueueCreate(10, sizeof (queue_event_t));
user_conn.conn_modbus_listen = createServer(502);
user_conn.conn_rs232_listen = createServer(10001);
user_conn.conn_rs485_listen = createServer(50001);
while(1)
{
waitServer(&user_conn, &evt);
send_rs232(&user_conn);
send_rs485(&user_conn);
if((user_conn.conn_modbus_listen != NULL) && (evt.cmd == MSG_MODBUS_LISTEN))
processModbusListen(&user_conn);
if((user_conn.conn_rs232_listen != NULL) && (evt.cmd == MSG_RS232_LISTEN))
processRS232Listen(&user_conn);
if((user_conn.conn_rs485_listen != NULL) && (evt.cmd == MSG_RS485_LISTEN))
processRS485Listen(&user_conn);
if((user_conn.conn_modbus != NULL) && (evt.cmd == MSG_MODBUS))
modbus_tcp_server(&user_conn);
if((user_conn.conn_rs232 != NULL) && (evt.cmd == MSG_RS232))
rs232_tcp_server(&user_conn);
if((user_conn.conn_rs485 != NULL) && (evt.cmd == MSG_RS485))
rs485_tcp_server(&user_conn);
}
}
創建成功(netconn_new_with_callback/netconn_bind並沒有錯誤netconn_listen)。
當我試圖連接到1個TCP端口時,它被接受,一切正常。
但是,當我試圖連接到第二個端口,而第一個連接仍然活着時,調用回調,但netconn_accept(conn,& newconn);失敗並報告ERR_ABRT,我不知道爲什麼。
的3個功能(processModbusListen,processRS232Listen和processRS485Listen)被編碼以下相同的原型:
static int processXXXListen(user_conn_t * user_data)
{
struct netconn *newconn;
err_t error_accept;
error_accept = netconn_accept(user_data->conn_XXX_listen, &newconn);
if (error_accept == ERR_OK)
{
if (user_data->conn_rs485)
{
// Close unwanted connection
netconn_close(newconn);
netconn_delete(newconn);
char *msg = "Error XXX Connection during establishement\n\r";
HAL_UART_Transmit(&huart3, (uint8_t*)msg, strlen(msg), 0xFFFF);
}
else
{
// connection established
char *msg = "XXX Connection established\n\r";
HAL_UART_Transmit(&huart3, (uint8_t*)msg, strlen(msg), 0xFFFF);
user_data->conn_XXX = newconn;
}
}
else
{
char *msg = "Error in acceptation TCP XXX connection\n\r";
HAL_UART_Transmit(&huart3, (uint8_t*)msg, strlen(msg), 0xFFFF);
print_error(error_accept);
}
return 0;
}
奇怪的是,當我只創建2 netconn結構,我有與2連接沒有問題在同一時間。
什麼會導致連接中止? 如何在同一時間獲得3連接? 如果可能的話,當然...
我發現問題......這是 #define MEMP_NUM_NETCONN 10默認情況下,它被設置爲4.但是這個參數隱藏在高級參數... – Bobnono
如果您確定它是正確的答案,您應該將您的評論發佈爲答案。 –