android socket怎样实现断网重连

发布网友发布时间：2022-04-30 05:11

共1个回答

热心网友时间：2023-10-15 13:11

由于当网络出现故障时，recv要很长时间才能返回，如果你觉得这种方式不能接受，可以考虑select或者其他模型。

UINT CMonitorDlg::ThreadFunction(LPVOID pParam)
{

WSADATA wsaData;
WSAStartup(...);

while(1)
{

if (WaitSingleObject(hEventKill, 0) == WAIT_OBJECT_0) //
这个hEventKill到主线程里创建，用于控制线程退出
{
break;
}

SOCKET s; //创建套接字

int port=PORT;

int iLen; //从服务器接收的数据长度
TCHAR recvbuf[BufferLen]; //接受数据的缓冲器

struct sockaddr_in serv1; //服务器端地址

serv1.sin_family=AF_INET;
//需要连接的服务器地址信息
serv1.sin_port=htons(port); //需要连接的服务器地址信息

serv1.sin_addr.s_addr=inet_addr(p->Ip); //将命令行的IP地址转化为二进制表示的网络字节顺序IP地址

s=socket(AF_INET,SOCK_STREAM,0);

if(s==INVALID_SOCKET)
{

AfxMessageBox("socket()failed");//套接字失败
return 0;
}

if(connect(s,(struct
sockaddr*)&serv1,sizeof(serv1))==INVALID_SOCKET)
{
int
b=WSAGetLastError();
//连接失败
}
else
{ //连接成功

p->connectstate=true;

do{

在此循环体中我接收数据并对数据做处理（省略部分代码）

iLen=recv(s,recvbuf,sizeof(recvbuf),0); //接收套接字中的数据放入recvbuf1缓冲区

if(iLen==0) // server调用了close
{

strtempMsg.Format(_T("局 %s 数据传送结束"),p->Name);

break;
//return 0;
}
else
if(iLen==SOCKET_ERROR) // 网络错误
{
int
err=WSAGetLastError();
if (err==WSAECONNRESET
||err==WSAECONNABORTED)
strtempMsg.Format(_T("%s连接中断"),p->Name);

p->connectstate=false;

break; //
退出do-while循环准备重连
// return -2; //连接异常中断
}

......
.....省略代码

}while//do-while

} //else

closesocket(s); //关闭套接字
} // end of
while(1)

WSACleanup();

return 0;

}

热心网友时间：2023-10-15 13:11