stm32f407+lan8720实现UCOSII 下LWIP网络联网问题

ID:338503 · 发表于 2025-5-21 15:19

#include "tcp_server_demo.h"
#include "lwip/opt.h"
#include "lwip_comm.h"
#include "led.h"
#include "lwip/lwip_sys.h"
#include "lwip/api.h"
///
//本程序只供学习使用，未经作者许可，不得用于其它任何用途
//ALIENTEK STM32F407开发板
//NETCONN API编程方式的TCP服务器测试代码
//正点原子@ALIENTEK

//创建日期:2014/8/15
//版本：V1.0
//版权所有，盗版必究。
//Copyright(C) 广州市星翼电子科技有限公司 2009-2019
//All rights reserved
//*******************************************************************************
//修改信息
//无
//

u8 tcp_server_recvbuf[TCP_SERVER_RX_BUFSIZE];       //TCP客户端接收数据缓冲区
u8 *tcp_server_sendbuf="Explorer STM32F407 NETCONN TCP Server send data\r\n";
u8 tcp_server_flag;                                                             //TCP服务器数据发送标志位

//TCP客户端任务
#define TCPSERVER_PRIO             6
//任务堆栈大小
#define TCPSERVER_STK_SIZE       300
//任务堆栈
OS_STK TCPSERVER_TASK_STK[TCPSERVER_STK_SIZE];

//tcp服务器任务
static void tcp_server_thread(void *arg)
{
      OS_CPU_SR cpu_sr;
      u32 data_len = 0;
      struct pbuf *q;
      err_t err,recv_err;
      u8 remot_addr[4];
      struct netconn *conn, *newconn;
      static ip_addr_t ipaddr;
      static u16_t                      port;

      LWIP_UNUSED_ARG(arg);

      conn = netconn_new(NETCONN_TCP);  //创建一个TCP链接
      netconn_bind(conn,IP_ADDR_ANY,TCP_SERVER_PORT);  //绑定端口 8号端口
      netconn_listen(conn);                //进入监听模式
      conn->recv_timeout = 10;       //禁止阻塞线程等待10ms
      while (1)
      {
            err = netconn_accept(conn,&newconn);  //接收连接请求
            if(err==ERR_OK)newconn->recv_timeout = 10;

            if (err == ERR_OK) //处理新连接的数据
            {
                     struct netbuf *recvbuf;

                     netconn_getaddr(newconn,&ipaddr,&port,0); //获取远端IP地址和端口号

                     remot_addr[3] = (uint8_t)(ipaddr.addr >> 24);
                     remot_addr[2] = (uint8_t)(ipaddr.addr>> 16);
                     remot_addr[1] = (uint8_t)(ipaddr.addr >> 8);
                     remot_addr[0] = (uint8_t)(ipaddr.addr);
                     printf("主机%d.%d.%d.%d连接上服务器,主机端口号为:%d\r\n",remot_addr[0], remot_addr[1],remot_addr[2],remot_addr[3],port);

                     while(1)
                     {
                              if((tcp_server_flag & LWIP_SEND_DATA) == LWIP_SEND_DATA) //有数据要发送
                              {
                                    err = netconn_write(newconn ,tcp_server_sendbuf,strlen((char*)tcp_server_sendbuf),NETCONN_COPY); //发送tcp_server_sendbuf中的数据
                                    if(err != ERR_OK)
                                    {
                                             printf("发送失败\r\n");
                                    }
                                    tcp_server_flag &= ~LWIP_SEND_DATA;
                              }

                              if((recv_err = netconn_recv(newconn,&recvbuf)) == ERR_OK)       //接收到数据
                              {
                                    OS_ENTER_CRITICAL(); //关中断
                                    memset(tcp_server_recvbuf,0,TCP_SERVER_RX_BUFSIZE);  //数据接收缓冲区清零
                                    for(q=recvbuf->p;q!=NULL;q=q->next)  //遍历完整个pbuf链表
                                    {
                                             //判断要拷贝到TCP_SERVER_RX_BUFSIZE中的数据是否大于TCP_SERVER_RX_BUFSIZE的剩余空间，如果大于
                                             //的话就只拷贝TCP_SERVER_RX_BUFSIZE中剩余长度的数据，否则的话就拷贝所有的数据
                                             if(q->len > (TCP_SERVER_RX_BUFSIZE-data_len)) memcpy(tcp_server_recvbuf+data_len,q->payload,(TCP_SERVER_RX_BUFSIZE-data_len));//拷贝数据
                                             else memcpy(tcp_server_recvbuf+data_len,q->payload,q->len);
                                             data_len += q->len;
                                             if(data_len > TCP_SERVER_RX_BUFSIZE) break; //超出TCP客户端接收数组,跳出
                                    }
                                    OS_EXIT_CRITICAL();  //开中断
                                    data_len=0;  //复制完成后data_len要清零。
                                    printf("%s\r\n",tcp_server_recvbuf);  //通过串口发送接收到的数据
                                    netbuf_delete(recvbuf);
                              }else if(recv_err == ERR_CLSD)  //关闭连接
                              {
                                    netconn_close(newconn);
                                    netconn_delete(newconn);
                                    printf("主机:%d.%d.%d.%d断开与服务器的连接\r\n",remot_addr[0], remot_addr[1],remot_addr[2],remot_addr[3]);
                                    break;
                              }
                     }
            }
      }
}

//创建TCP服务器线程
//返回值:0 TCP服务器创建成功
//             其他 TCP服务器创建失败
INT8U tcp_server_init(void)
{
      INT8U res;
      OS_CPU_SR cpu_sr;

      OS_ENTER_CRITICAL();       //关中断
      res = OSTaskCreate(tcp_server_thread,(void*)0,(OS_STK*)&TCPSERVER_TASK_STK[TCPSERVER_STK_SIZE-1],TCPSERVER_PRIO); //创建TCP服务器线程
      OS_EXIT_CRITICAL();             //开中断

      return res;
}
以上是正点原子的代码，正常开机可以联网收发数据，拔掉网线再插上就连不上网，必须断电重启才可以。怎样修改以上代码，才能实现网线热插拔自动重联网？

帐号		自动登录	找回密码
密码			立即注册