Lwip的udp编程

全栈程序员-用户IM • 2022年9月3日上午10:00 • 未分类

大家好，又见面了，我是你们的朋友全栈君。如果您正在找激活码,请点击查看最新教程,关注关注公众号 “全栈程序员社区” 获取激活教程,可能之前旧版本教程已经失效.最新Idea2022.1教程亲测有效,一键激活。

Jetbrains全系列IDE使用 1年只要46元售后保障童叟无欺

第一次写博客，主要是想记录自己过程过程中接触到的知识：

在嵌入式系统中需要用到网络的地方很多，下面是Lwip中实现udp的例子：

#define UDP_DEMO_PORT 8087
struct netif lwip_netif; //定义一个全局的网络接口
int main(void)
{

struct netif *Netif_Init_Flag;
struct ip_addr ipaddr; //ip地址
struct ip_addr netmask; //子网掩码
struct ip_addr gw; //默认网关
struct udp_pcb *udppcb; //定义一个TCP服务器控制块
struct ip_addr rmtipaddr; //远端ip地址

lwip_init();

IP4_ADDR(&ipaddr,192,168,1,xxx);			//设置本机IP
IP4_ADDR(&netmask,255,255,255,0);
IP4_ADDR(&gw,192,168,1,1);
Netif_Init_Flag=netif_add(&lwip_netif,&ipaddr,&netmask,&gw,NULL,&ethernetif_init,&ethernet_input);  //添加网口

#ifdef DHCP
dhcp_start(&lwip_netif);	
#endif /*DHCP*/

netif_set_default(&lwip_netif); 	//设置netif为默认网口
netif_set_up(&lwip_netif);			//打开netif网口

udppcb=udp_new();
IP4_ADDR(&rmtipaddr, xxx, xxx, xxx, xxx);	//设置远端IP

udp_connect(udppcb,&rmtipaddr,UDP_DEMO_PORT);	//UDP客户端连接到指定远端服务器
udp_bind(udppcb,IP_ADDR_ANY,UDP_DEMO_PORT);	//绑定远端IP地址与端口号
udp_recv(udppcb,udp_demo_recv,NULL);							//注册接收回调函数，udp_demo_recv用于处理接收到的数据,该函数在特定
																							//的时候会被Lwip内核调用
_Bool DisConnetFlag=0;																//断开连接标志
while(1)
{
		LwipPriodTask();	//Lwip周期处理任务
		if(DisConnetFlag)
		
		{//断开udp连接时，记得执行以下函数，释放upcb内存块
			udp_disconnect(upcb); 
			udp_remove(upcb);			
		}
}

}

void LwipPriodTask(void)
{ Lwip周期处理任务
//如果使用tcp，每250ms调用一次tcp_tmr()函数
tcp_tmr();

  	//每5s周期性调用一次ARP
   	etharp_tmr();
  
	//如果使用DHCP
    dhcp_fine_tmr();			//  1)每500ms调用一次dhcp_fine_tmr()
	dhcp_coarse_tmr();		//  2)每60s执行一次DHCP粗糙处理

}

//Lwip在收到数据后，为用户处提供理数据的接口
#define UDP_DEMO_RX_BUFSIZE 1024
#define udp_demo_recvbuf[UDP_DEMO_RX_BUFSIZE]
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_recvbuf中的数据是否大于udp_demo_recvbuf的剩余空间，如果大于
//的话就只拷贝udp_demo_recvbuf中剩余长度的数据，否则的话就拷贝所有的数据
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;  				//记录远程主机的端口号
	pbuf_free(p);//释放内存
}
else
{
	uudp_disconnect(upcb); 
	udp_remove(upcb);			
}

}

//UDP服务器发送数据
unsigend char tcp_demo_sendbuf = “this is udp send Test!”
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);//释放内存
}
}