socket回顾

socket地址（以Internet Socket为例）：

本地IP地址与端口；
远程IP地址与端口（适用于已经建立的TCP连接）；
协议（TCP、UDP）。

流程图：

socket API:

socket() 创建一个新的套接字并分配资源
bind()用于服务端，将套接字与套接字地址(IP+port)绑定
listen()用于服务端，将绑定的TCP置于监听状态
connect()用于客户端，分配一个本地的空闲端口，并与远程地址连接
accpet()用于服务端，接受一个新的连接请求，并创建一个与其绑定的套接字
select()用于等待一个或者多个指定套接字的下一个读写事件
poll()用于测试一个或者多个套接字的读写状态
setsockopt()配置指定套接字的参数

用于mydb的_ossSocket套接字类

类示意图：其中-代表private,#代表protected,+代表public.
接下来会挑几个重要的函数解析。

big endian/little endian

数值0x2211用两个字节存储，高位字节为0x22，低位字节为0x11。
big endian：0x2211
little endian: 0x1122
网络字节序一般为big endian。
(既然big endian符合人类从高位读的习惯，为什么还要有little endian？
这是因为计算电路一般从低位开始读起，运算效率高。)

创建socket:

//socket的创建函数分为了
//创建一个socket
//创建一个用于listen的socket
//创建一个用于connect的socket
//创建一个已经存在的socket
//这里我们以listen socket为例：
_ossSocket::_ossSocket(unsigned int port,int timeout)
{//初始化信息_init=false;_fd=0;_timeout=timeout;//清空本机及对方地址memset(&_sockAddress,0,sizeof(sockaddr_in));memset(&_peerAddress,0,sizeof(sockaddr_in));//设置本机和远程的地址长度_peerAddressLen=sizeof(_peerAddress);_addressLen=sizeof(_sockAddress);//本机选择IPV4,接受任意地址_sockAddress.sin_family=AF_INET;//htonl 将主机的长整型转换成网络字节顺序//htons 将主机的整形转换成网络字节顺序_sockAddress.sin_addr.s_addr=htonl(INADDR_ANY);_sockAddress.sin_port=htons(port);
}

初始化socket

//需要注意的是我们将创建socket的准备工作放到了前面去做
//具体的socket创建放到了init中
int _ossSocket::initSocket()
{int rc=EDB_OK;if(_init) goto done;memset(&_peerAddress,0,sizeof(sockaddr_in));_peerAddressLen=sizeof(_peerAddress);//创建socket SOCK_STREAM为有保障的,SOCK_DGRAM为无保障的_fd=socket(AF_INET,SOCK_STREAM,IPPROTO_TCP);if(-1==_fd){printf("Failed to initialize socket,error=%d",SOCKET_GETLASTERROR);rc=EDB_NETWORK;goto error;}_init=true;setTimeout(_timeout);done:return rc;error:goto done;
}

socket的linger机制

//socket的linger，为close以后等待缓冲区发送晚的驻留时间
//l_onoff为是否在close后等待缓冲区发送完，l_linger为驻留时间
int _ossSocket::setSocketLi(int lOnOff,int linger)
{int rc=EDB_OK;struct linger _linger;_linger.l_onoff=lOnOff;_linger.l_linger=linger;//setsockopt，SOL_SOCKET代表需要在socket层面上进行设置，后面跟需要设置的内容rc=setsockopt(_fd,SOL_SOCKET,SO_LINGER,(const char*)&_linger,sizeof(_linger));return rc;
}

bind与listen

int _ossSocket::bind_listen()
{int rc=EDB_OK;int temp=1;//设置地址可重用rc=setsockopt(_fd,SOL_SOCKET,SO_REUSEADDR,(char*)&temp,sizeof(int));if(rc)  printf("Failed to setsocktopt SO_REUSEADDR,rc=%d",SOCKET_GETLASTERROR);//设置linger时间rc=setSocketLi(1,30);if(rc)  printf("Failed to setsocktopt SO_LINGER,rc=%d",SOCKET_GETLASTERROR);//进行bind,需要fd,本机地址，地址长度rc=::bind(_fd,(struct sockaddr*)&_sockAddress,_addressLen);if(rc){printf("Failed to bind socket,rc=%d",SOCKET_GETLASTERROR);rc=EDB_NETWORK;goto error;}//进行listen,需要fd，最大连接数rc=listen(_fd,SOMAXCONN);if(rc){printf("Failed to listen socket,rc=%d",SOCKET_GETLASTERROR);rc=EDB_NETWORK;goto error;}
done:return rc;
error:close();goto done;
}

send发送数据

int _ossSocket::send(const char *pMsg,int len,int timeout,int flags)
{int rc=EDB_OK;int maxFD=_fd;struct timeval maxSelectTime;//fd_set用于select，实际上是一个数组，检查哪个句柄可读fd_set fds;maxSelectTime.tv_sec=timeout/1000000;maxSelectTime.tv_usec=timeout%1000000;//len为0则返回if(0==len)      return EDB_OK;//给一个循环用于等待socket就绪while(true){FD_ZERO(&fds);  //将set中清零，无fdFD_SET(_fd,&fds);//将_fd加入set//select非阻塞轮询函数，根据对应的poll判断是否有资源可用(可读或者可写)//需要检查的文件描述字个数，用于检查可读性的一组文件描述字，可写性文件描述字，异常情况的文件描述字，//超时，NULL为阻塞，0为非阻塞，其他为超时时间rc=select(maxFD+1,NULL,&fds,NULL,timeout>=0?&maxSelectTime:NULL);//select超时if(0==rc){rc=EDB_TIMEOUT;goto done;}if(0>rc){rc=SOCKET_GETLASTERROR;//错误是中断则继续selectif(EINTR==rc)continue;printf("Failed to select from socket,rc=%d",rc);rc=EDB_NETWORK;goto error;}//检查fd是否已经在set中if(FD_ISSET(_fd,&fds))break;}while(len>0){       //连接断开时，系统会返回一个SIGPIPE。我们设置成不要返回。rc=::send(_fd,pMsg,len,MSG_NOSIGNAL|flags);if(-1==rc){printf("Failed to send,rc=%d",SOCKET_GETLASTERROR);rc=EDB_NETWORK;goto error;}//每次发送后，待发送的长度减去rc；len-=rc;//在发送缓冲区后加上已发送长度。pMsg+=rc;}rc=EDB_OK;
done:return rc;
error:goto done;
}

recv接受数据

//recv设置了两个函数，一个是将缓冲区的数据全部发出，另一个为recvNF有多少发多少
//其区别在于有无while循环检测
#define MAX_RECV_RETRIES 5      //中断重连的次数
int _ossSocket::recv(char *pMsg,int len,int timeout,int flags)
{int rc=EDB_OK;int retries=0;int maxFD=_fd;struct timeval maxSelectTime;fd_set fds;maxSelectTime.tv_sec=timeout/1000000;maxSelectTime.tv_usec=timeout%1000000;if(0==len)      return EDB_OK;while(true){FD_ZERO(&fds);  //将set中清零，无fdFD_SET(_fd,&fds);//将_fd加入setrc=select(maxFD+1,NULL,&fds,NULL,timeout>=0?&maxSelectTime:NULL);if(0==rc){rc=EDB_TIMEOUT;goto done;}if(0>rc){rc=SOCKET_GETLASTERROR;if(EINTR==rc)continue;printf("Failed to select from socket,rc=%d",rc);rc=EDB_NETWORK;goto error;}if(FD_ISSET(_fd,&fds))break;}while(len>0){rc=::recv(_fd,pMsg,len,MSG_NOSIGNAL|flags);if(rc>0){       //MSG_PEEK,读取数据包的时候，不会把该数据包从缓存队列中删除if(flags & MSG_PEEK)    goto done;len-=rc;pMsg+=rc;}else if(rc==0){printf("Peer unexpected shutdown");rc=EDB_NETWORK_CLOSE;goto error;}else{       //EAGAIN代表在非阻塞模式下调用了阻塞操作，EWOULDBLOCK是在windows下的EAGAINrc=SOCKET_GETLASTERROR;if((EAGAIN==rc||EWOULDBLOCK==rc)&&_timeout>0){printf("Recv() timeout: rc=%d",rc);rc=EDB_NETWORK;goto error;}//EINTR操作被中断唤醒if((EINTR==rc)&&(retries<MAX_RECV_RETRIES)){retries++;continue;}printf("Recv() Failed: rc=%d",rc);rc=EDB_NETWORK;goto error;}}rc=EDB_OK;
done:return rc;
error:goto done;}

connect客户端连接

int _ossSocket::connect()
{int rc=EDB_OK;//建立连接rc=::connect(_fd,(struct sockaddr *)&_sockAddress,_addressLen);if(rc){printf("Failed to connect,rc=%d",SOCKET_GETLASTERROR);rc=EDB_NETWORK;goto error;}//获取本机地址rc=getsockname(_fd,(sockaddr*)&_sockAddress,&_addressLen);if(rc){printf("Failed to get local address,rc=%d",rc);rc=EDB_NETWORK;goto error;}//获取对方地址rc=getpeername(_fd,(sockaddr*)&_peerAddress,&_peerAddressLen);if(rc){printf("Failed to get peer address,rc=%d",rc);rc=EDB_NETWORK;goto error;}
done:return rc;
error:goto done;}

服务端的accept函数

int _ossSocket::accept(int *sock,struct sockaddr *addr,socklen_t *addrlen,int timeout)
{int rc=EDB_OK;int maxFD=_fd;struct timeval maxSelectTime;fd_set fds;maxSelectTime.tv_sec=timeout/1000000;maxSelectTime.tv_usec=timeout%1000000;while(true){FD_ZERO(&fds);  //将set中清零，无fdFD_SET(_fd,&fds);//将_fd加入setrc=select(maxFD+1,NULL,&fds,NULL,timeout>=0?&maxSelectTime:NULL);if(0==rc){rc=EDB_TIMEOUT;goto done;}if(0>rc){rc=SOCKET_GETLASTERROR;if(EINTR==rc)continue;printf("Failed to select from socket,rc=%d",rc);rc=EDB_NETWORK;goto error;}if(FD_ISSET(_fd,&fds))break;}//上面与send的检查一致rc=EDB_OK;*sock=::accept(_fd,addr,addrlen);if(-1==*sock){printf("Failed to accept socket,rc=%d",SOCKET_GETLASTERROR);rc=EDB_NETWORK;goto error;}
done:return rc;
error:close();goto done;
}

disableNagle机制

//防止多个小包打包成大包
int _ossSocket::disableNagle()
{int rc=EDB_OK;int temp=1;//TCP往往会把多个小包打包成大包，防止由于封装拆包影响传输//但是对于数据库实时性要求性高的系统，我们需要NODELAYrc=setsockopt(_fd,IPPROTO_TCP,TCP_NODELAY,(char*)&temp,sizeof(int));if(rc)  printf("Failed to setsockopt,rc=%d",SOCKET_GETLASTERROR);rc=setsockopt(_fd,SOL_SOCKET,SO_KEEPALIVE,(char*)&temp,sizeof(int));if(rc)  printf("Failed to setsockopt,rc=%d",SOCKET_GETLASTERROR);return rc;
}

超时机制

int _ossSocket::setTimeout(int seconds)
{//windows把毫秒作为参数，linux把timeval作为参数int rc=EDB_OK;struct timeval tv;tv.tv_sec=seconds;tv.tv_usec=0;rc=setsockopt(_fd,SOL_SOCKET,SO_RCVTIMEO,(char*)&tv,sizeof(tv));if(rc)  printf("Failed to setsockopt,rc=%d",SOCKET_GETLASTERROR);rc=setsockopt(_fd,SOL_SOCKET,SO_SNDTIMEO,(char*)&tv,sizeof(tv));if(rc)  printf("Failed to setsockopt,rc=%d",SOCKET_GETLASTERROR);return rc;
}

对了最后向好心人求助一下Makefile的missing separator. Stop.问题，网上的tab方法并不适用，在autoconf的环境搭建下老是会出现此类问题…