客戶端代碼，和一般的客戶端不一樣

#include

#include

#include

#include

#include

#include

#include

#include

#include

#include

#include

#include

#define MAXDATASIZE 100

int main()

{

int sockfd,nbytes,serv_port;

char buf_serv_ip[16],buf[260];

struct sockaddr_in serv_addr;

if((sockfd=socket(/*AF_INET,SOCK_STREAM,0*/PF_INET, SOCK_STREAM, IPPROTO_TCP))==-1){

perror("創(chuàng)建套接字失敗!\n");

exit(1);

}

//創(chuàng)建套接字成功后設(shè)置其可重用的屬性

int KeepAlive=1;

socklen_t KPlen=sizeof(int);

if(setsockopt(sockfd,SOL_SOCKET,SO_KEEPALIVE,(char *)&KeepAlive,KPlen)!=0){

perror("設(shè)置周期測試連接是否仍存活失敗!\n");

exit(1);

}

int keepIdle = 10;//每次檢測的相隔時間

int keepInterval = 1;//檢測前的空間時間

int keepCount = 3;//最大檢測次數(shù)

setsockopt(sockfd,SOL_TCP,TCP_KEEPINTVL,(void *)&keepIdle,sizeof(keepIdle));

setsockopt(sockfd,SOL_TCP,TCP_KEEPIDLE,(void *)&keepInterval,sizeof(keepInterval));

setsockopt(sockfd,SOL_TCP,TCP_KEEPCNT,(void *)&keepCount,sizeof(keepCount));

printf("請輸入要連接主機(jī)的IP地址：\n");

scanf("%s",buf_serv_ip);

printf("請輸入要連接主機(jī)的端口號:\n");

scanf("%d",&serv_port);

serv_addr.sin_family=AF_INET;

serv_addr.sin_addr.s_addr=inet_addr(buf_serv_ip);

serv_addr.sin_port=htons(serv_port);

bzero(&(serv_addr.sin_zero),8);

if(connect(sockfd,(struct sockaddr *)&serv_addr,sizeof(struct sockaddr))==-1){

perror("連接服務(wù)器失敗!\n");

exit(1);

}

if((getsockopt(sockfd,SOL_SOCKET,SO_KEEPALIVE,(char*)&KeepAlive,&KPlen))==0){

printf("SO_KEEPALIVE Value: %d\n", KeepAlive);

}

printf("連接服務(wù)器成功!\n");

//在此處可以先接受判斷將要接受數(shù)據(jù)的長度再創(chuàng)建數(shù)組

int i =0;

int res = 0;

int errcode;

fd_set?readmask;

struct timeval?timeout;

while(1){

FD_ZERO(&readmask);

FD_SET(sockfd, &readmask);

timeout.tv_sec = 1;

timeout.tv_usec = 0;

if ((res = select(sockfd + 1, &readmask, NULL, NULL, &timeout)) < 0)

{

printf("the socket is error\n");

exit(1);

}

printf("select return %d\n", res);

if(res == 0)

{//檢測連接是否超時，可能服務(wù)器長時間沒發(fā)數(shù)據(jù)

int sockfdtemp;

errno = 0;

printf("連接超時\n");

/*

if((sockfdtemp=socket(AF_INET,SOCK_STREAM,0))==-1){

perror("超時接字失敗!\n");

exit(1);

}

if(connect(sockfdtemp,(struct sockaddr *)&serv_addr,sizeof(struct sockaddr))==-1){

printf("超時連接服務(wù)器失敗!\n");

errcode = errno;u

//close(sockfdtemp);

if (errcode != ENOENT && errcode != ECONNREFUSED) {

printf("Failed to establish connection: %d\n", errcode);

}

//continue;

//exit(1);

}else

{

printf("服務(wù)器沒掛!\n");

//close(sockfdtemp);

}

close(sockfdtemp);

*/

continue;

}

/* 處理Slave端連接請求 */

if( (sockfd != -1 ) && FD_ISSET(sockfd, &readmask) )

{

printf("the socket is ok\n");

memset(buf, 0, 260);

errno = 0;

if((nbytes=recv(sockfd,buf,260,0))==-1){

printf("接受數(shù)據(jù)失敗!\n");

errcode = errno;

if(errcode == ETIMEDOUT)

{//服務(wù)器真正的掛掉

printf("******服務(wù)器掛掉 %d : %d \n", errno, ETIMEDOUT);

exit(1);

}

}

if (nbytes == 0)

{

printf("數(shù)據(jù)為空： %d\n", i);

}

else

{

buf[nbytes]='\0';

printf("接受的數(shù)據(jù)為:%d\n", i);

}

}else

{

printf("the socket is not OK\n");

exit(1);

}

i++;

}

close(sockfd);

return 0;

}

總結(jié)

以上是生活随笔為你收集整理的linux客户端 存活检测,Linux下客户端检测服务器的 heartbeat的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯，歡迎將生活随笔推薦給好友。