linux客户端 存活检测,Linux下客户端检测服务器的 heartbeat
客戶端代碼，和一般的客戶端不一樣
#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("創建套接字失敗!\n");
exit(1);
}
//創建套接字成功后設置其可重用的屬性
int KeepAlive=1;
socklen_t KPlen=sizeof(int);
if(setsockopt(sockfd,SOL_SOCKET,SO_KEEPALIVE,(char *)&KeepAlive,KPlen)!=0){
perror("設置周期測試連接是否仍存活失敗!\n");
exit(1);
}
int keepIdle = 10;//每次檢測的相隔時間
int keepInterval = 1;//檢測前的空間時間
int keepCount = 3;//最大檢測次數
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("請輸入要連接主機的IP地址：\n");
scanf("%s",buf_serv_ip);
printf("請輸入要連接主機的端口號:\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("連接服務器失敗!\n");
exit(1);
}
if((getsockopt(sockfd,SOL_SOCKET,SO_KEEPALIVE,(char*)&KeepAlive,&KPlen))==0){
printf("SO_KEEPALIVE Value: %d\n", KeepAlive);
}
printf("連接服務器成功!\n");
//在此處可以先接受判斷將要接受數據的長度再創建數組
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)
{//檢測連接是否超時，可能服務器長時間沒發數據
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("超時連接服務器失敗!\n");
errcode = errno;u
//close(sockfdtemp);
if (errcode != ENOENT && errcode != ECONNREFUSED) {
printf("Failed to establish connection: %d\n", errcode);
}
//continue;
//exit(1);
}else
{
printf("服務器沒掛!\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("接受數據失敗!\n");
errcode = errno;
if(errcode == ETIMEDOUT)
{//服務器真正的掛掉
printf("******服務器掛掉 %d : %d \n", errno, ETIMEDOUT);
exit(1);
}
}
if (nbytes == 0)
{
printf("數據為空： %d\n", i);
}
else
{
buf[nbytes]='\0';
printf("接受的數據為:%d\n", i);
}
}else
{
printf("the socket is not OK\n");
exit(1);
}
i++;
}
close(sockfd);
return 0;
}
總結
以上是生活随笔為你收集整理的linux客户端 存活检测,Linux下客户端检测服务器的 heartbeat的全部內容，希望文章能夠幫你解決所遇到的問題。
- 上一篇： 93没有了_杭州1米93程序员征婚贴火了
- 下一篇： linux下将多个文件去除文件头合并_命