Linux下客户端检测服务器的 heartbeat

对于heartbeat检测，常用的是在通迅协议上面做，比如pgpool，一台机器会定时向另一台新建一个联接，写和读一些特定字符，之后关闭这个检测用的连接，能连上表明对方没有挂机

对于通过TCP/IP本身这样做，网上win平台下面的例子比较多，相对Linux，MS确实增加了一些特定的函数来检测状态，Linux下面就没有特定的函数这样做了

下面这部分代码就是通过TCP/IP本身客户端检测服务器是否挂掉，挂掉的意义就是拔网线或断电，测试时要在两台不同的机器上，或是两台虚拟机上，同一台的话，测不出来

代码目的是 使用TCP/IP本身 SO_KEEPALIVE 来检测，不需要辅助协议的支持 当服务器意外挂掉后，客户端能检测出来

代码是演示原理用的，实际使用请自已封装，

服务器端代码，这个没什么可说的

#include<stdio.h>
#include<stdlib.h>
#include<sys/socket.h>
#include<error.h>
#include<string.h>
#include<sys/types.h>
#include<netinet/in.h>
#include<sys/wait.h>
#include<arpa/inet.h>
#include<unistd.h>

#define SERVPORT 6123 //设定服务器服务端口
#define MAX_LISTEN_SOCK_NUM 20 //设定可监听套接字的最大个数为20
int main()
{
//sockfd为本地监听套接字标识符，client_fd为客户端套接字标识符
int sockfd,client_fd;
struct sockaddr_in my_addr;
struct sockaddr_in client_addr;
int i;
//创建本地监听套接字
if((sockfd=socket(/*AF_INET,SOCK_STREAM,0*/PF_INET, SOCK_STREAM, IPPROTO_TCP))==-1){
perror("套接字创建失败!\n");
exit(1);
}

//设置套接字的属性使它能够在计算机重启的时候可以再次使用套接字的端口和IP
int err,sock_reuse=1;
//err=setsockopt(sockfd,SOL_SOCKET,SO_REUSEADDR,(char *)&sock_reuse,sizeof(sock_reuse));
//if(err!=0){
//printf("套接字可重用设置失败!\n");
//exit(1);
//}

int opt = 1;
socklen_t len=sizeof(int);

my_addr.sin_family=AF_INET;
my_addr.sin_port=htons(SERVPORT);
my_addr.sin_addr.s_addr=INADDR_ANY;
bzero(&(my_addr.sin_zero),8);
//绑定套接字
if(bind(sockfd,(struct sockaddr *)&my_addr,sizeof(struct sockaddr))==-1){
perror("绑定失败!\n");
exit(1);
}
//设置监听
if((listen(sockfd,MAX_LISTEN_SOCK_NUM))==-1){
perror("设置监听失败!\n");
exit(1);
}
printf("套接字进入监听状态，等待请求连接：\n");

while(1){

//有连接请求时进行连接
socklen_t sin_size=sizeof(struct sockaddr_in);
if((client_fd=accept(sockfd,(struct sockaddr *)&client_addr,&sin_size))==-1){
perror("接受连接失败!\n");
continue;
}

 
if((getsockopt(client_fd,SOL_SOCKET,SO_KEEPALIVE,(char*)&opt,&len))==0){
printf("SO_KEEPALIVE Value: %d\n", opt);
}
printf("接到一个来自%s的连接\n",inet_ntoa(client_addr.sin_addr));
//创建子进程来处理已连接的客户端套接字

for(i=0; i<3; i++){

 if(send(client_fd,"您好，您已经连接成功!\n",50,0)==-1){
 perror("发送通知信息失败!\n");
 exit(0);
 }
 else
  {
   printf("成功： %d\n", i);
   }
 sleep(10);
}

while(1)
{
 if(send(client_fd,"abcdef",6,0)==-1){
 perror("发送通知信息失败!\n");
 exit(0);
 }
 else
  {
   printf("成功： %d\n", i);
  }
  i++;
}
 
close(client_fd);
}

return 0;
}