【TCP/IP网络编程】：09套接字的多种可选项

本篇文章主要介绍了套接字的几个常用配置选项，包括SO_SNDBUF & SO_RCVBUF、SO_REUSEADDR及TCP_NODELAY等。

套接字可选项和I/O缓冲大小

前文关于套接字的描述仅仅是使用其默认套接字特性来进行数据通信，这对于简单的使用场景来说似乎是可以的，然而实际工作场景中的确需要配置相关套接字选项来满足一些特殊需求。下图所示是一些常用的套接字可选配置选项。

#include <stdio.h>
#include <stdlib.h>
#include <unistd.h>
#include <sys/socket.h>
void error_handling(char *message);

int main(int argc, char *argv[])
{
int tcp_sock, udp_sock;
int sock_type;
socklen_t optlen;
int state;

optlen=sizeof(sock_type);
tcp_sock=socket(PF_INET, SOCK_STREAM, 0);
udp_sock=socket(PF_INET, SOCK_DGRAM, 0);
printf("SOCK_STREAM: %d \n", SOCK_STREAM);
printf("SOCK_DGRAM: %d \n", SOCK_DGRAM);

state=getsockopt(tcp_sock, SOL_SOCKET, SO_TYPE, (void*)&sock_type, &optlen);
if(state)
error_handling("getsockopt() error!");
printf("Socket type one: %d \n", sock_type);

state=getsockopt(udp_sock, SOL_SOCKET, SO_TYPE, (void*)&sock_type, &optlen);
if(state)
error_handling("getsockopt() error!");
printf("Socket type two: %d \n", sock_type);
return 0;
}

void error_handling(char *message)
{
fputs(message, stderr);
fputc('\n', stderr);
exit(1);
}

sock_type

#include <stdio.h>
#include <stdlib.h>
#include <unistd.h>
#include <sys/socket.h>
void error_handling(char *message);

int main(int argc, char *argv[])
{
int sock;
int snd_buf, rcv_buf, state;
socklen_t len;

sock=socket(PF_INET, SOCK_STREAM, 0);
len=sizeof(snd_buf);
state=getsockopt(sock, SOL_SOCKET, SO_SNDBUF, (void*)&snd_buf, &len);
if(state)
error_handling("getsockopt() error");

len=sizeof(rcv_buf);
state=getsockopt(sock, SOL_SOCKET, SO_RCVBUF, (void*)&rcv_buf, &len);
if(state)
error_handling("getsockopt() error");

printf("Input buffer size: %d \n", rcv_buf);
printf("Outupt buffer size: %d \n", snd_buf);
return 0;
}

void error_handling(char *message)
{
fputs(message, stderr);
fputc('\n', stderr);
exit(1);
}

get_buf

#include <stdio.h>
#include <stdlib.h>
#include <unistd.h>
#include <sys/socket.h>
void error_handling(char *message);

int main(int argc, char *argv[])
{
int sock;
int snd_buf=1024*3, rcv_buf=1024*3;
int state;
socklen_t len;

sock=socket(PF_INET, SOCK_STREAM, 0);
state=setsockopt(sock, SOL_SOCKET, SO_RCVBUF, (void*)&rcv_buf, sizeof(rcv_buf));
if(state)
error_handling("setsockopt() error!");

state=setsockopt(sock, SOL_SOCKET, SO_SNDBUF, (void*)&snd_buf, sizeof(snd_buf));
if(state)
error_handling("setsockopt() error!");

len=sizeof(snd_buf);
state=getsockopt(sock, SOL_SOCKET, SO_SNDBUF, (void*)&snd_buf, &len);
if(state)
error_handling("getsockopt() error!");

len=sizeof(rcv_buf);
state=getsockopt(sock, SOL_SOCKET, SO_RCVBUF, (void*)&rcv_buf, &len);
if(state)
error_handling("getsockopt() error!");

printf("Input buffer size: %d \n", rcv_buf);
printf("Output buffer size: %d \n", snd_buf);
return 0;
}

void error_handling(char *message)
{
fputs(message, stderr);
fputc('\n', stderr);
exit(1);
}
/*
root@com:/home/swyoon/tcpip# gcc get_buf.c -o getbuf
root@com:/home/swyoon/tcpip# gcc set_buf.c -o setbuf
root@com:/home/swyoon/tcpip# ./setbuf
Input buffer size: 2000
Output buffer size: 2048
*/

set_buf

#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <unistd.h>
#include <arpa/inet.h>
#include <sys/socket.h>

#define TRUE 1
#define FALSE 0
void error_handling(char *message);

int main(int argc, char *argv[])
{
int serv_sock, clnt_sock;
char message[30];
int option, str_len;
socklen_t optlen, clnt_adr_sz;
struct sockaddr_in serv_adr, clnt_adr;

if(argc!=2) {
printf("Usage : %s <port>\n", argv[0]);
exit(1);
}

serv_sock=socket(PF_INET, SOCK_STREAM, 0);
if(serv_sock==-1)
error_handling("socket() error");
/*
optlen=sizeof(option);
option=TRUE;
setsockopt(serv_sock, SOL_SOCKET, SO_REUSEADDR, &option, optlen);
*/

memset(&serv_adr, 0, sizeof(serv_adr));
serv_adr.sin_family=AF_INET;
serv_adr.sin_addr.s_addr=htonl(INADDR_ANY);
serv_adr.sin_port=htons(atoi(argv[1]));

if(bind(serv_sock, (struct sockaddr*)&serv_adr, sizeof(serv_adr)))
error_handling("bind() error ");

if(listen(serv_sock, 5)==-1)
error_handling("listen error");
clnt_adr_sz=sizeof(clnt_adr);
clnt_sock=accept(serv_sock, (struct sockaddr*)&clnt_adr,&clnt_adr_sz);

while((str_len=read(clnt_sock,message, sizeof(message)))!= 0)
{
write(clnt_sock, message, str_len);
write(1, message, str_len);
}
close(clnt_sock);
return 0;
}

void error_handling(char *message)
{
fputs(message, stderr);
fputc('\n', stderr);
exit(1);
}

reuseaddr_server 客户端通过输入“Q”消息，或是通过CTRL+C终止程序，两种方式客户端都会执行close函数向服务器端传递EOF消息结束标志。服务器端收到EOF消息，也可以正常退出程序。现在考虑另一种情况，如果服务器端和客户端在已建立连接的状态下，向服务器端执行CTRL+C终止程序，会发生什么？

这种情况，服务器端会主动向客户端发送FIN消息断开连接并退出程序。此时，如果再次以相同端口号启动服务器端则会发生错误（bind()报错：“Address already in use”），通常需要等待1~4分钟才能再次运行服务器端。客户端主动发送FIN消息断开连接，不影响客户端或服务器端的再次运行；而服务器端主动发送FIN消息断开连接，则会影响服务器端的再次运行，为什么会出现这种现象呢？

TIME_WAIT状态

TIME_WAIT状态下的套接字

上图展示的就是前文有提到过的四次握手断开连接的过程。从图中可以看出，主动断开连接的主机（先发送FIN消息）会经过TIME_WAIT的状态，持续时间为2MSL（Maximum Segment Lifetime，最长分节生命期，30s或2min）。而处于TIME_WAIT状态时，相应的端口号是正在使用状态，因此，若服务器端先断开连接则无法立即重新运行。与服务器端不同，客户端由于每次运行都会动态分配端口号，因此不受TIME_WAIT状态的影响。

原来是TIME_WAIT的作怪，导致主动断开连接的服务器端不能立即以相同的端口号重新运行。既然对服务器端有这种影响，那为什么要有TIME_WAIT状态呢？（以下描述主要摘录自UNP，以客户端先发送FIN消息断开连接为例）

TIME_WAIT状态的存在有两个理由：

• 可靠地实现TCP全双工连接的终止
• 允许老的重复分节在网络中消逝

第一个理由可以假设上述四次握手过程最终的ACK丢失了来解释。主机B将重新发送它的最终那个FIN，因此主机A必须维护状态信息，以允许它重新发送最终那个ACK。如果主机A不维护状态信息，它将以一个RST（另外一种类型的TCP分节）消息来响应，该分节将被主机B解释为一个错误消息。如果TCP打算执行所有必要的工作以彻底终止某个连接上两个方向的数据流（即全双工关闭），那么它必须正确处理连接终止序列4个分节中任何一个分节丢失的情况。本例也说明了为什么执行主动关闭的那一端需要处于TIME_WAIT状态，因为它可能不得不重传最终那个ACK。

为理解存在TIME_WAIT状态的第二个理由，我们假设在12.106.32.254的1500端口和206.168.112.219的21端口之间有一个TCP连接。我们关闭这个连接，过一段时间后在相同的IP地址和端口之间建立另一个连接。后一个连接称为前一个连接的化身（incarnation），因为它们的IP地址和端口号都相同。TCP必须防止来自某个连接的老的重复分组在该连接已终止后再现，从而被误解成属于同一连接的某个新的化身。为做到这一点，TCP将不给处于TIME_WAIT状态的连接发起新的化身。既然TIME_WAIT状态的持续时间是MSL的2倍，这就足以让某个方向上的分组最多存活MSL秒即被丢弃，另一个方向上的应答最多存活MSL秒也被丢弃。通过实施这个规则，我们就能保证每成功建立一个TCP连接时，来自该连接先前化身的老的重复分组都已在网络中消逝了（单向传输一个分节的最长生命周期是MSL，TIME-WAIT状态的2MSL是考虑了一次双向信息交互的最长时间。比如最后的ACK丢失后，来自对端重发的FIN消息也会在2MSL内消逝）。

地址再分配

从上文的描述来看，TIME_WAIT状态在可靠通信过程中似乎起到了重要的作用，但它也有其自身的缺点。比如下图的情况，收到FIN消息的主机A发送ACK消息至主机B并启动Time-wait定时器，如果网络状态不好致使ACK消息不断丢失，则TIME-WAIT状态可能一直持续下去。

 重启Time-wait定时器

另一种情况，考虑正在工作中的服务器突然故障停机而需要快速重启，这时由于TIME_WAIT状态则必须等几分钟，也会带来严重的影响（时间就是money）。

针对以上TIME_WAIT状态所带来的影响，可以通过配置可选项SO_REUSEADDR来解决。默认情况下，SO_REUSEADDR选项处于关闭状态（值为0，假），即无法分配处于TIME_WAIT状态下套接字端口。因此，我们需要将该选项置为1（真）即可。

int opt_val = 1;
setsockopt(sock, SOL_SOCKET, SO_REUSEADDR, &opt_val, sizeof(opt_val));

SO_REUSEADDR可选项有效解决了以上问题，UNP中也有这么一句描述“所有TCP服务器都应该指定本套接字选项，以允许服务器在这种情形下被重新启动”。同时我们也应该意识到SO_REUSEADDR其实无视了TIME_WAIT状态的一些作用，此时如果收到一些不期望的数据（旧连接的分片）可能会导致服务程序混乱，不过这种可能性极低。

TCP_NODELAY

Nagle算法

Nagle算法的出现是为了防止因数据包过多而导致的网络过载，它应用于TCP层，其作用如下图所示。

 Nagle算法

不难看出，只有收到ACK消息，Nagle算法才会发送下一数据。TCP套接字默认使用Nagle算法，因此可以最大限度地进行缓冲，直到收到ACK。上图的演示中，使用Nagle算法发送一个字符串消息需要传递4个数据包，而不使用Nagle算法则需要传递10个数据包，对网络流量（Traffic，网络负载或混杂程度）产生了较大的影响。当然，上图的演示只是一种极端的情况（特定场景下，字符串中的字符需要间隔一定的时间来传输至缓冲区），实际程序中将字符串传输至缓冲区并非逐个字符进行的。

根据数据传输的特性，网络流量未受太大影响时，不使用Nagle算法反而更快。典型的场景就是“传输大文件数据”，此时即使不使用Nagle算法，也会在填满缓冲区时传输数据。这种情况并没有增加数据包的数量，反而由于无需等待ACK而可以连续传输，大大提高了传输速度。禁止Nagle算法的方法如下。

int opt_val = 1;
setsockopt(sock, IPPROTO_TCP, TCP_NODELAY, &opt_val, sizeof(opt_val));

是否使用Nagle算法，需要根据使用与否对网络流量影响的差别大小确定。通常情况，不使用Nagle算法确实可以获得更快的传输速度。但为了保证网络流量，在未准确判断数据特性时不应该禁止Nagle算法。