内容营销的定义,网站排名优化软件电话,本地wordpress环境,沈阳网站设计营销型一、LWIP 中 中 RAW API 编程接口中与 TCP 相关的函数 二、LWIP TCP RAW API 函数 三、LwIP_Periodic_Handle函数
LwIP_Periodic_Handle 函数是一个必须被无限循环调用的 LwIP支持函数#xff0c;一般在 main函数的无限循环中调用#xff0c;主要功能是为 LwIP各个模块提供…一、LWIP 中 中 RAW API 编程接口中与 TCP 相关的函数 二、LWIP TCP RAW API 函数 三、LwIP_Periodic_Handle函数
LwIP_Periodic_Handle 函数是一个必须被无限循环调用的 LwIP支持函数一般在 main函数的无限循环中调用主要功能是为 LwIP各个模块提供时间并查询链路状态该 函数有一个形参用于指示当前时间单位为 ms。 对于 TCP功能每 250ms执行一次 tcp_tmr函数对于 ARP每 5s 执 行一次 etharp_tmr函数对于链路状态检测每 1s 执行一次ETH_CheckLinkStatus 函数 对于 DHCP功能每 500ms执行一次 dhcp_fine_tmr函数如果 DHCP处于DHCP_START 或 DHCP_WAIT_ADDRESS 状态就执行LwIP_DHCP_Process_Handle 函数对于 DHCP功 能还有每 60s 执行一次 dhcp_coarse_tmr函数。 四、TCP客户端连接代码
tcpclinet.c
#include lwip/netif.h
#include lwip/ip.h
#include lwip/tcp.h
#include lwip/init.h
#include netif/etharp.h
#include lwip/udp.h
#include lwip/pbuf.h
#include stdio.h
#include string.h
#include main.hstatic void client_err(void *arg, err_t err) //出现错误时调用这个函数打印错误信息并尝试重新连接
{printf(连接错误!!\n);printf(尝试重连!!\n);printf(重新初始化客户端\n);TCP_Client_Init();
}static err_t client_send(void *arg, struct tcp_pcb *tpcb) //发送函数调用了tcp_write函数
{uint8_t send_buf[] 我是客户端是你的好哥哥\n;//发送数据到服务器tcp_write(tpcb, send_buf, sizeof(send_buf), 1); return ERR_OK;
}static err_t client_recv(void *arg, struct tcp_pcb *tpcb, struct pbuf *p, err_t err)
{if (p ! NULL) { /* 接收数据*/tcp_recved(tpcb, p-tot_len);/* 返回接收到的数据*/ tcp_write(tpcb, p-payload, p-tot_len, 1);memset(p-payload, 0 , p-tot_len);pbuf_free(p);} else if (err ERR_OK) {//服务器断开连接printf(服务器断开连接!\n);tcp_close(tpcb);//重新连接TCP_Client_Init();}return ERR_OK;
}static err_t client_connected(void *arg, struct tcp_pcb *pcb, err_t err)
{printf(connected ok!\n);//注册一个周期性回调函数tcp_poll(pcb,client_send,2);//注册一个接收函数tcp_recv(pcb,client_recv);return ERR_OK;
}void TCP_Client_Init(void)
{ struct tcp_pcb *client_pcb NULL; //这一句一定要放在里面否则会没用ip4_addr_t server_ip; //因为客户端要主动去连接服务器所以要知道服务器的IP地址/* 创建一个TCP控制块 */client_pcb tcp_new(); IP4_ADDR(server_ip, DEST_IP_ADDR0,DEST_IP_ADDR1,DEST_IP_ADDR2,DEST_IP_ADDR3);//合并IP地址printf(客户端开始连接!\n);//开始连接tcp_connect(client_pcb, server_ip, TCP_CLIENT_PORT, client_connected);ip_set_option(client_pcb, SOF_KEEPALIVE); printf(已经调用了tcp_connect函数\n);//注册异常处理tcp_err(client_pcb, client_err);printf(已经注册异常处理函数\n);
}tcpclinet.h
#ifndef _TCPCLIENT_H_
#define _TCPCLIENT_H_#define TCP_CLIENT_PORT 5001void TCP_Client_Init(void);#endif五、TCP服务器连接代码
tcpserver.c
#include tcpserver.h
#include lwip/netif.h
#include lwip/ip.h
#include lwip/tcp.h
#include lwip/init.h
#include netif/etharp.h
#include lwip/udp.h
#include lwip/pbuf.h
#include stdio.h
#include string.hstatic err_t tcpecho_recv(void *arg, struct tcp_pcb *tpcb, struct pbuf *p, err_t err)
{ //对应接收数据连接的控制块 接收到的数据 if (p ! NULL) { //int a 666;/* 更新窗口*/tcp_recved(tpcb, p-tot_len); //读取数据的控制块 得到所有数据的长度 /* 返回接收到的数据*/ //tcp_write(tpcb, p-payload, p-tot_len, 1);uint8_t send_buf1[] 我收到了你的信息是;uint8_t send_buf2[] 吗\n; tcp_write(tpcb, send_buf1, sizeof(send_buf1), 1);tcp_write(tpcb, p-payload, p-tot_len, 1); tcp_write(tpcb, send_buf2, sizeof(send_buf2), 1); memset(p-payload, 0 , p-tot_len);pbuf_free(p);} else if (err ERR_OK) //检测到对方主动关闭连接时也会调用recv函数此时p为空{return tcp_close(tpcb);}return ERR_OK;
}static err_t tcpecho_accept(void *arg, struct tcp_pcb *newpcb, err_t err) //由于这个函数是*tcp_accept_fn类型的//形参的数量和类型必须一致
{ tcp_recv(newpcb, tcpecho_recv); //当收到数据时回调用户自己写的tcpecho_recvreturn ERR_OK;
}void TCP_Echo_Init(void)
{struct tcp_pcb *server_pcb NULL; /* 创建一个TCP控制块 */server_pcb tcp_new(); printf(创建了一个控制块\n);/* 绑定TCP控制块 */tcp_bind(server_pcb, IP_ADDR_ANY, TCP_ECHO_PORT); printf(已经绑定一个控制块\n);/* 进入监听状态 */server_pcb tcp_listen(server_pcb);printf(进入监听状态\n); /* 处理连接 注册函数侦听到连接时被注册的函数被回调 */ tcp_accept(server_pcb, tcpecho_accept); //侦听到连接后回调用户编写的tcpecho_accept //这个函数是*tcp_accept_fn类型的
}tcpserver.h
#ifndef _TCPECHO_H_
#define _TCPECHO_H_#define TCP_ECHO_PORT 5001void TCP_Echo_Init(void);#endif
