Chinaunix

标题: socket断开重连问题 [打印本页]

作者: 小路子122    时间: 2015-11-30 16:23
标题: socket断开重连问题
客户端:     1、socket创建套接字
                2、connect连接设备端
                3、开启发送线程
                4、开启接收线程
                5、开启监测线程

有的时候在客户端接收数据时,设备端会断开,为了监测啥时候断开,设备端发送心跳包,客户端10次接收不到就说明连接断开了;
问题:我怎么再进行重连呢? 再创建一个socket和connect吗?可是创建了新的socket后,接收数据会返回error,不知道该怎么搞了。。。
还有,我的接收线程和发送线程需要重新创建吗?


作者: windoze    时间: 2015-11-30 16:58
不贴代码你说个Justin Bieber……
作者: 小路子122    时间: 2015-11-30 18:02
BOOL RecvTCP_Len(SOCKET sock,fd_set *pFD_read,TIMEVAL *pTime,CHAR *Buf,INT Len)
{       
        while(TRUE)
        {
                FD_ZERO(pFD_read);
                FD_SET(sock,pFD_read);

                int Returned=select(0,pFD_read,NULL,NULL,pTime);

                LOG4CPLUS_DEBUG(Logger::getInstance(_T("LoggerName")), "1092行:进入-Returned"<<"returned="<<Returned);

                if(Returned>0)
                {       
                        LOG4CPLUS_DEBUG(Logger::getInstance(_T("LoggerName")), "1096行:进入-Returned>0,准备recv");

                    int c = recv(sock,Buf,Len,0);

                        if(c == SOCKET_ERROR || c == 0)
                        {
                                int R=WSAGetLastError();
                                LOG4CPLUS_DEBUG(Logger::getInstance(_T("LoggerName")), "返回的错误码R="<<R);
                                LOG4CPLUS_DEBUG(Logger::getInstance(_T("LoggerName")), "c="<<c);
                               
                                return FALSE;
                        }
                        if(c == Len)
                        {                               
                                return TRUE;//返回的是接收到的字节数
                        }
                        else
                        {
                                LOG4CPLUS_DEBUG(Logger::getInstance(_T("LoggerName")), "c不等于len"<<c);
                                Buf += c;
                                Len -= c;
                                LOG4CPLUS_DEBUG(Logger::getInstance(_T("LoggerName")), "c不等于len,len="<<Len);

                        }
                }
                 if(Returned==SOCKET_ERROR)
                {
                        int r=WSAGetLastError();
                        LOG4CPLUS_DEBUG(Logger::getInstance(_T("LoggerName")), "select返回错误"<<r);
                        return FALSE;
                }
        }       
}
好吧,贴代码。。这是接收数据的,创建了新的socket和connect后,会执行到c == SOCKET_ERROR,此时recv函数中的socket还是旧的那个,并不是新的,不知该咋弄?难道要重新再建立接收数据线程吗




欢迎光临 Chinaunix (http://bbs.chinaunix.net/) Powered by Discuz! X3.2