LWIP UDP通信，单片机作为服务端，接收数据

明天，你好 · 发表于 2020-3-26 18:13:58

1.使用STM32F4作为服务端，网络调试助手多次发送数据，服务端才能接受到数据，有哪位大神知道原因吗？下面是我的UDP配置与回调函数。@原子哥能够帮忙看一下吗？谢谢
//UDP测试
void udp_demo_test(void)
{
  err_t err;
struct udp_pcb *udppcb; //定义一个TCP服务器控制块
struct ip_addr rmtipaddr; //远端ip地址
u8 *tbuf;
tbuf=mymalloc(SRAMIN,200); //申请内存
if(tbuf==NULL)return ;  //内存申请失败了,直接退出
udppcb=udp_new();
if(udppcb)//创建成功
{
  err=udp_bind(udppcb,IP_ADDR_ANY,UDP_DEMO_PORT);//绑定本地IP地址与端口号
  if(err==ERR_OK) //绑定完成
  {
udp_recv(udppcb,udp_demo_recv,NULL);//注册接收回调函数
  }
}
else
{
  return;
}
if(udp_demo_flag&1<<6)//是否收到数据?
{
  udp_demo_senddata(udppcb);
  udp_demo_flag&=~(1<<6);//标记数据已经被处理了
  lwip_periodic_handle();
}

udp_demo_connection_close(udppcb);
myfree(SRAMIN,tbuf);

}
//UDP回调函数
void udp_demo_recv(void *arg,struct udp_pcb *upcb,struct pbuf *p,struct ip_addr *addr,u16_t port)
{
u32 data_len = 0;
struct pbuf *q;
if(p!=NULL) //接收到不为空的数据时
{
  memset(udp_demo_recvbuf,0,UDP_DEMO_RX_BUFSIZE);  //数据接收缓冲区清零
  for(q=p;q!=NULL;q=q->next)  //遍历完整个pbuf链表
  {
//判断要拷贝到UDP_DEMO_RX_BUFSIZE中的数据是否大于UDP_DEMO_RX_BUFSIZE的剩余空间，如果大于
//的话就只拷贝UDP_DEMO_RX_BUFSIZE中剩余长度的数据，否则的话就拷贝所有的数据
if(q->len > (UDP_DEMO_RX_BUFSIZE-data_len)) memcpy(udp_demo_recvbuf+data_len,q->payload,(UDP_DEMO_RX_BUFSIZE-data_len));//拷贝数据
else memcpy(udp_demo_recvbuf+data_len,q->payload,q->len);
data_len += q->len;
if(data_len > UDP_DEMO_RX_BUFSIZE) break; //超出TCP客户端接收数组,跳出
  }
  upcb->remote_ip=*addr;    //记录远程主机的IP地址
  upcb->remote_port=port;    //记录远程主机的端口号
  lwipdev.remoteip[0]=upcb->remote_ip.addr&0xff; //IADDR4
  lwipdev.remoteip[1]=(upcb->remote_ip.addr>>8)&0xff; //IADDR3
  lwipdev.remoteip[2]=(upcb->remote_ip.addr>>16)&0xff;//IADDR2
  lwipdev.remoteip[3]=(upcb->remote_ip.addr>>24)&0xff;//IADDR1
  udp_demo_flag|=1<<6; //标记接收到数据了
  pbuf_free(p);//释放内存
}else
{
  udp_disconnect(upcb);
  udp_demo_flag &= ~(1<<5); //标记连接断开
}
}
//UDP服务器发送数据
void udp_demo_senddata(struct udp_pcb *upcb)
{
struct pbuf *ptr;
ptr=pbuf_alloc(PBUF_TRANSPORT,strlen((char*)tcp_demo_sendbuf),PBUF_POOL); //申请内存
if(ptr)
{
  pbuf_take(ptr,(char*)tcp_demo_sendbuf,strlen((char*)tcp_demo_sendbuf)); //将tcp_demo_sendbuf中的数据打包进pbuf结构中
  udp_send(upcb,ptr); //udp发送数据
  pbuf_free(ptr);//释放内存
}
}
//关闭UDP连接
void udp_demo_connection_close(struct udp_pcb *upcb)
{
udp_disconnect(upcb);
udp_remove(upcb); //断开UDP连接
udp_demo_flag &= ~(1<<5); //标记连接断开
}