linux下tcp重连机制,tcpsocket客户端重连机制
在Linux下编程使⽤socket 客户端连接服务器时发现⼀个问题
有⽹友测试
(1)客户端已经连接，当服务端关闭程序时，客户端调⽤send函数发送失败，WSAGetLastError() 返回10054(远程主机强迫关闭了⼀个现有的连接)
(2)客户端已经连接，当客户端关闭程序时，服务端调⽤recv函数接收失败，WSAGetLastError() 返回10054(远程主机强迫关闭了⼀个现有的连接) ，这时对这个客户端的socket调⽤select函数时，会⽴即返回可读。
(3)客户端已经连接，当服务端关闭程序时，客户端调⽤recv函数接收失败，WSAGetLastError() 返回10054
(4)WSAAsyncSelect模式的服务端，当客户端软件关闭时，服务器收到的消息为FD_CLOSE，错误代码为10053(您的主机中的软件中⽌了⼀个已建⽴的连接)
本⼈发现的⼀个现象是
当tcp socket 和服务器程序已经建⽴连接⽽服务器在关闭socket，⽽客户端在未知其关闭的情况下，如果继续向socket发送数据，那么将会导致程序崩溃或异常退出，这个时候所以加上⼼跳判断还是很有必要的，如果⼼跳超时，将不在socket⾥边发数据，⽽是建⽴重连机制。
以下是是实现代码
代码⼤概原理就是，重连的⼀个进程，socket使⽤的是阻塞模式这样在畅通的情况下，是会⼀直阻塞在接收receive 的函数⾥，当receive 发⽣异常时，程序会直接跳到while(1)下，如果服务器还没连接，则会goto 重新来，直到连接成功，重新连接的时间是5s。
void *socket_tcp_handle (void *arg)
{
s32 socketfd_client = 0 ;
socklen_t addr_len = 0 ;linux下的sleep函数
s32 num_bytes = 0 ;
struct timeval tm;
fd_set rfds;
int ret = 0 ;
int error=-1;
int len;
u8 i;
char recvbuffer[250];
app_task_attr *taskattr = NULL ;
u8 msg_buf[MAX_MSG_BUFSIZE] = { 0 } ;
struct sockaddr_in remoteSockAddr;
DEBUG(LOG_DEBUG,"socket tcp bind 3333333333\n");
if (0 == arg)
{
DEBUG(LOG_ERR,"arg error!\n");
return NULL;
taskattr = (app_task_attr *) arg;
socketfd_local = taskattr->msg_id;
remoteSockAddr.sin_family = AF_INET;
remoteSockAddr.sin_port = htons(cloud_port);
//inet_addr函数将⽤点分⼗进制字符串表⽰的IPv4地址转化为⽤⽹络
//字节序整数表⽰的IPv4地址
remoteSockAddr.sin_addr.s_addr = inet_addr(cloud_ip);
addr_len = sizeof (remoteSockAddr);
DEBUG(LOG_DEBUG,"socket tcp bind socket success\n");
while(1){
loop:
DEBUG(LOG_DEBUG,"socket tcp process loop \n");
if((heartbeat_cnt!=0))
{
DEBUG(LOG_DEBUG,"socket tcp repeat connect \n");
connect_flg =0;
close (socketfd_local);
sleep(5);
if ((socketfd_local = socket (AF_INET, SOCK_STREAM, 0)) == -1){ DEBUG(LOG_ERR,"build socket error!\n");
return (-1);
}
int opts = fcntl(socketfd_local,F_GETFL);
if (opts < 0 ){
DEBUG(LOG_ERR,"fcntl get fl failed\n" );
return (-1);
}
remoteSockAddr.sin_family = AF_INET;
remoteSockAddr.sin_port = htons(cloud_port);
//inet_addr函数将⽤点分⼗进制字符串表⽰的IPv4地址转化为⽤⽹络
//字节序整数表⽰的IPv4地址
remoteSockAddr.sin_addr.s_addr = inet_addr(cloud_ip);
addr_len = sizeof (remoteSockAddr);
int connect_fd = connect(socketfd_local, (struct sockaddr*)&remoteSockAddr, addr_len); if(connect_fd < 0)
{
if (errno != EINPROGRESS)
{
perror("connect");
DEBUG(LOG_DEBUG,"connect 1!\n");
goto loop;
break;
}
perror("connect");
DEBUG(LOG_DEBUG,"connect 2!\n");
}
if(connect_fd ==0 )
{
// goto done;
DEBUG(LOG_DEBUG,"connect ok!\n");
system("aplay /home/user/yhfwqlj.wav");
connect_flg = 1;
// DEBUG(LOG_ERR,"connect error!\n");
#if 0
/
/ return 2;
tm.tv_sec = 2;
tm.tv_usec = 0;
FD_ZERO(&rfds);
FD_SET(socketfd_local,&rfds);
ret = select(1+socketfd_local,NULL,&rfds,NULL,&tm);
switch(ret)
{
case -1:
perror("select");
close(socketfd_local);
connect_flg =0;
return 1;
case 0:
close(socketfd_local);
DEBUG(LOG_ERR,"timeout\n");
break;
default:
if(FD_ISSET(socketfd_local,&rfds))
{
if(getsockopt(socketfd_local,SOL_SOCKET,SO_ERROR,&error,(socklen_t *)&len)<0)
{
return 1;
}
printf("error=%d\n",error);//error ==0 时 连接成功
if(error==0)
{
DEBUG(LOG_DEBUG,"connect ok!\n");
ret=1;
}
else
{
ret=0;
errno=error;
}
}
break;
}
fcntl(socketfd_local,F_SETFL,fcntl(socketfd_local,F_GETFL) & O_NONBLOCK); //set back to block mode /* if(!ret)
{
connect_flg =0;
close(socketfd_local);
perror("connect failed");
return 1;
}
*/
#endif
}
char buf[1024];
// unsigned long ul = 1;
// ioctl( socketfd_local, FIONBIO, &ul ); //设置为⾮阻塞模式
/*user task init func */
if(connect_flg ==1 )
{
if(taskattr->task_init != NULL){
(taskattr->task_init) (NULL);
}
// DEBUG(LOG_DEBUG,"socket_tcp client_handle loop\n");
tm.tv_sec = 1;
tm.tv_usec = 0;
select (0, NULL, NULL, NULL, &tm);
recv(socketfd_local,recvbuffer,250,0);//如果设置成阻塞模式，当recv的返回值为0时则代表服务器关闭//for(i=0;i<46;i++)
// printf("%x ",recvbuffer[i]);
// printf(" ------------\n");
if(recvbuffer[0]==0x68)
{
if(taskattr->task_handle!= NULL){
(taskattr->task_handle) (recvbuffer, 250);;
}
}
}
}
close (socketfd_local);
socketfd_local = 0;
return NULL ;
}
版权声明：本站内容均来自互联网，仅供演示用，请勿用于商业和其他非法用途。如果侵犯了您的权益请与我们联系QQ:729038198，我们将在24小时内删除。
发表评论