STM32之LWIP协议栈应用

#include "lwip_config.h"
#include "lwip/tcp.h"
/*接收成功回调函数*/
u8 buff[1024];
u16 rx_len=0;
err_t tcp_recv_func(void *arg, struct tcp_pcb *tpcb,struct pbuf *p, err_t err)
{
	memset(buff,0,sizeof(buff));
	rx_len=0;
	if(p==NULL)
	{
		clinet_stat=0;
		printf("[%d.%d.%d.%d:%d]:客户端断开连接\r\n",(u8)(tpcb->remote_ip.addr),(u8)(tpcb->remote_ip.addr>>8),
                                                (u8)(tpcb->remote_ip.addr>>16),
                                                (u8)(tpcb->remote_ip.addr>>24),
           																			tpcb->remote_port);
	}
	else
	{
		if(p->tot_len==p->len)
		{
			memcpy(buff,p->payload,p->len);
			rx_len=p->len;
			pbuf_free(p);
		}
		else
		{
			struct pbuf *temp=p;
			struct pbuf *q=temp;
			while(temp!=NULL)
			{
				memcpy(buff+rx_len,temp->payload,temp->len);
				q=temp;
				temp=temp->next;
				rx_len+=temp->len;
				pbuf_free(q);
			}
		}
		buff[rx_len]='\0';
		printf("[%d.%d.%d.%d:%d]:%s\r\n",(u8)(tpcb->remote_ip.addr),(u8)(tpcb->remote_ip.addr>>8),
                                     (u8)(tpcb->remote_ip.addr>>16),														
                                     (u8)(tpcb->remote_ip.addr>>24),														
                                     tpcb->remote_port,buff);
	}
	return ERR_OK;
}
/*客户端连接成功回调函数*/
u8 client_addr[4];//IP地址
u16 client_prot=0;
u8 clinet_stat=0;
err_t tcp_client(void *arg, struct tcp_pcb *newpcb, err_t err)
{
	client_addr[0]=newpcb->remote_ip.addr>>0;
	client_addr[1]=newpcb->remote_ip.addr>>8;
	client_addr[2]=newpcb->remote_ip.addr>>16;
	client_addr[3]=newpcb->remote_ip.addr>>24;	
	clinet_stat=1;
	printf("客户端连接成功:%d.%d.%d.%d:%d\r\n",client_addr[0],client_addr[1],client_addr[2],client_addr[3],newpcb->remote_port);
	new_tcp=newpcb;
	tcp_recv(newpcb,tcp_recv_func);
	return ERR_OK;
}
/*TCP服务器创建*/
struct tcp_pcb *new_tcp;//tcp网络信息(套接字)
u8 LWIP_CreateTcpServer(u16 port)
{
	/*1.建立一个新的网卡设备*/
	new_tcp=tcp_new();
	if(new_tcp==NULL)return 1;
	/*2.绑定IP地址和端口号*/
	if(tcp_bind(new_tcp, IP_ADDR_ANY,port)!=ERR_OK)
	{
		return 2;//绑定端口号失败
	}
	/*开始监听*/
	new_tcp=tcp_listen(new_tcp);
	/*等待客户端连接*/
	tcp_accept(new_tcp,tcp_client);
	return 0;
}

连接服务器成功回调函数*/
err_t tcp_connect_func(void *arg, struct tcp_pcb *tpcb, err_t err)
{
	client_addr[0]=tpcb->local_ip.addr>>0;
	client_addr[1]=tpcb->local_ip.addr>>8;
	client_addr[2]=tpcb->local_ip.addr>>16;
	client_addr[3]=tpcb->local_ip.addr>>24;	
	new_tcp=tpcb;
	clinet_stat=1;
	printf("%d.%d.%d.%d连接服务器成功\r\n",client_addr[0],client_addr[1],client_addr[2],client_addr[3]);
	tcp_recv(tpcb,tcp_recv_func);
	return 0;
}
/**********TCP客户端创建*****************
**
**形  参：u8 a,u8 b,u8 c,u8 d -- 服务器IP地址
**				u16_t port -- 服务器端口号
**返回值：0 --服务器创建成功，其他值--失败
**
*****************************************/
u8 LWIP_CreateTcpClient(u8 a,u8 b,u8 c,u8 d,u16 port)
{
	ip_addr_t addr;
	/*1.创建新的网卡设备*/
	new_tcp=tcp_new();
	if(new_tcp==NULL)return 1;
	IP4_ADDR(&addr,a,b,c,d);/*将IP地址合成整数*/
	/*连接服务器*/
	tcp_connect(new_tcp,&addr,port,tcp_connect_func);
	return 0;
}