LWIP做客户端 如何检测服务器断开情况下 重新连接

yangzi6000

我的程序是参考战舰上面改过来的：按复位键  程序连接两次可以连接上，如果断电重连  就连不上，调试助手 显示1035错误
硬件没问题  因为运行 其他程序 上电和复位是一样的

void  tcp_client_init(void) //服务器初始化函数

{

     struct tcp_client_state* ts;

 struct ip_addr ipaddr; 

 err_t ret_err;

 IP4_ADDR(&ipaddr,192,168,0,122);      //目标IP

 tcp_client_pcb = tcp_new();                        /*  建立通信的 TCP 控制块(Clipcb)               */ 

 tcp_bind( tcp_client_pcb,IP_ADDR_ANY,TCP_CLIENT_PORT);         /*  绑定本地 IP 地址和端口号 不绑定也可以运行 端口号自己分配                      */ 

 if(tcp_client_pcb!=NULL)

{  printf("初始化进入");

     ts = mem_malloc(sizeof(struct tcp_client_state)); //申请内存

   tcp_arg(tcp_client_pcb, ts);   //将程序的协议控制块的状态传递给多有的回调函数

 tcp_connect(tcp_client_pcb,&ipaddr,6000,tcp_client_connect); //连接函数 tcp_client_accept成功连接到主机调用

 tcp_recv(tcp_client_pcb, tcp_client_recv); //指定连接接收到新的数据之后将要调用的回调函数

 tcp_poll(tcp_client_pcb, tcp_client_poll, 2); //轮询函数  发送数据 时间为2/2=1

 

}

 

}
检测状态在主程序中 5S检测一次，connect_net是连接状态标志位

   if(connect_net==1)

  { 

         printf("开始重新连接   ");

tcp_closed();

tcp_client_init();

if(connect_net==0)  

{

printf("重新连接   ");

}

xiaoyan

回复【楼主位】yangzi6000:
-----------------------------
你参考的是我发的那个例程么？

yangzi6000

回复【2楼】xiaoyan:
---------------------------------
是的   这个问题貌似解决了  ENC28J60的复位时间一定要长 。。。。。。。。。不过例程里面的处理流程 我觉得说的不是很明白，尤其是为什么这样处理，LWIP 我属于菜鸟，见谅
目前客户端测试程序基本稳定  重连也OK  ，现在就是应用中。。。。

还有问题请教
1.做客户端的时候 如何主动发数据 我用tcp_write在采集完数据后发送 不出来  不可能只能在POLL里面循环发吧
2.ethernetif_input(&enc28j60_netif); 多长时间查询一次，连同时间心跳查询可以放到定时器中断里面吗，因为主程序中 有数据采集部分 延时可能长点 
3.tcp_poll(tcp_client_pcb, tcp_client_poll, 0);  后面是0  是什么意思  一般不是2的倍数吗  
4.关闭连接中用到tcp_close(tpcb);   我试着用tcp_abort也可以，那么用tcp_close好处那些

xiaoyan

回复【3楼】yangzi6000:
---------------------------------
1.应该可以发送的，你要确保TCP是连接上的
2.ethernetif_input(&enc28j60_netif); 我在代码中为了保证不掉包，一直查询的。放在定时器中断函数中应该没问题的，这个查询函数，不怎么消耗时间。
3.“一般是2的倍数”不知道你是在哪里看到的。这个参数用来设置查询的间隔，以TCP的周期处理时间为单位。
4.用tcp_abort是终止连接，并没有关闭连接，为他分配的Listening pcbs还是工作的。如果你不用了这个连接建议用tcp_close。
PSWIP 我懂得也不是很多，如果错误请指正，我们一起讨论下。

lxrhy198308

楼主在吗？connect_net 这个是哪个函数的返回值？
你用哪个函数判断网络连接还在不在的？

rockmanxyj

楼主你移植到mini开发板的吗？能不能指点下

oceanzi

回复【3楼】yangzi6000:
---------------------------------
关于客户端重连的问题能发个程序共享下不？谢谢！

rosewoman

楼主，请问下，我也是用LWIP，发现发送一段时间就发送不出去，已经调用了tcp_write,但是发送不出去，然后我就在这里close_pcb，然后重连，再发送一段时间，重复几次后就再也连接不上服务器了！

穹鸟无痕

static err_t tcp_echoclient_recv(void *arg, struct tcp_pcb *tpcb, struct pbuf *p, err_t err)
{
  struct echoclient *es;
  err_t ret_err;
  

  LWIP_ASSERT("arg != NULL",arg != NULL);
  
  es = (struct echoclient *)arg;
  
  /* if we receive an empty tcp frame from server => close connection */
if (p == NULL)
  {
    /* remote host closed connection */
    es->state = ES_CLOSING;
    if(es->p_tx == NULL)
    {
       /* we're done sending, close connection */
       tcp_echoclient_connection_close(tpcb, es);
    }
    else
    {   
      /* send remaining data*/
      tcp_echoclient_send(tpcb, es);
    }
    ret_err = ERR_OK;
  }   
  /* else : a non empty frame was received from echo server but for some reason err != ERR_OK */
  else if(err != ERR_OK)
  {
    /* free received pbuf*/
    if (p != NULL)
    {
      pbuf_free(p);
    }
    ret_err = err;
  }
  else if(es->state == ES_CONNECTED)
  {
    /* increment message count */
    message_count++;
         
    /* Acknowledge data reception */
    tcp_recved(tpcb, p->tot_len);  
   
    pbuf_free(p);
    tcp_echoclient_connection_close(tpcb, es);
    ret_err = ERR_OK;
  }

  /* data received when connection already closed */
  else
  {
    /* Acknowledge data reception */
    tcp_recved(tpcb, p->tot_len);
   
    /* free pbuf and do nothing */
    pbuf_free(p);
    ret_err = ERR_OK;
  }
  return ret_err;
}
标色的就是检测到连接断开。

穹鸟无痕

static err_t tcp_echoclient_recv(void *arg, struct tcp_pcb *tpcb, struct pbuf *p, err_t err)
{
  struct echoclient *es;
  err_t ret_err;
  

  LWIP_ASSERT("arg != NULL",arg != NULL);
  
  es = (struct echoclient *)arg;
  
  /* if we receive an empty tcp frame from server => close connection */
  if (p == NULL)
  {
    /* remote host closed connection */
    es->state = ES_CLOSING;
    if(es->p_tx == NULL)
    {
       /* we're done sending, close connection */
       tcp_echoclient_connection_close(tpcb, es);
    }
    else
    {   
      /* send remaining data*/
      tcp_echoclient_send(tpcb, es);
    }
    ret_err = ERR_OK;
  }   
  /* else : a non empty frame was received from echo server but for some reason err != ERR_OK */
  else if(err != ERR_OK)
  {
    /* free received pbuf*/
    if (p != NULL)
    {
      pbuf_free(p);
    }
    ret_err = err;
  }
  else if(es->state == ES_CONNECTED)
  {
    /* increment message count */
    message_count++;
         
    /* Acknowledge data reception */
    tcp_recved(tpcb, p->tot_len);  
   
    pbuf_free(p);
    tcp_echoclient_connection_close(tpcb, es);
    ret_err = ERR_OK;
  }

  /* data received when connection already closed */
  else
  {
    /* Acknowledge data reception */
    tcp_recved(tpcb, p->tot_len);
   
    /* free pbuf and do nothing */
    pbuf_free(p);
    ret_err = ERR_OK;
  }
  return ret_err;
}
上面标错地方了。。

rosewoman

穹鸟无痕 发表于 2016-6-14 13:48
static err_t tcp_echoclient_recv(void *arg, struct tcp_pcb *tpcb, struct pbuf *p, err_t err)
{
   ...

我检测到断开连接，前面几次可以重连上，但是之后就重连不上了！

feelingtaking

rosewoman 发表于 2016-6-14 15:14
我检测到断开连接，前面几次可以重连上，但是之后就重连不上了！

我也是多少次断开网线后，不能重新连接上PC的服务器端。