linux 网络编程 socket选项

时间  2019-12-09
标签 linux 网络 编程 socket 选项 栏目 Linux 繁體版
原文   原文链接

socket选项函数

  • 功能：用来读取和设置socket文件描述符属性的方法
#include <sys/scoket.h>
int getsockopt ( int sockfd, int level, int option_name, void* option_value, socklen_t* restrict option_len );
int setsockopt ( int sockfd, int level, int option_name, const void* option_value, socklen_t option_len);

socket选项表以下：linux

clipboard.png

  • getsockopt和setsockopt 这两个函数成功时返回0，失败时返回-1并设置errno。
  • 对于服务器而言，有部分socket选项只能在调用listen系统调用前针对监听socket设置才有效。这是由于链接socket只能由accept调用返回，而accept从listen监听队列接受的链接至少已经完成了TCP三次握手的前两个步骤（由于listen监听队列中的链接至少已进入SYN_RCVD状态），这说明服务器已经往被接收链接上发送出了TCP同步报文段。但有的socket选项却应该在TCP同步报文段中设置，好比TCP最大报文段选项。对这种状况，linux给开发人员提供的解决方案是：对监听socket设置这些socket选项，那么accept返回的链接socket将自动继承这些选项。这些选项包括：SO_DEBUG、SO_DONTROUTE、SO_KEEPALIVE、SO_LINGER、SO_OOBINLINE、SO_RCVBUF、SO_RCVLOWAT、SO_SNDBUF、SO_SNDLOWAT、TCP_MAXSEG和TCP_NODELAY。
  • 对于客户端而言，这些socket选项则应该在调用connect函数以前设置，由于connect调用成功返回以后，TCP三次握手已完成。

SO_REUSEADDR选项

  • 前面讨论过TCP链接的TIME_WAIT状态，并提到服务器程序能够经过设置socket选项SO_REUSEADDR来强制使用被处于TIME_WAIT状态的链接占用的socket地址。
#include <sys/socket.h>
#include <netinet/in.h>
#include <arpa/inet.h>
#include <assert.h>
#include <stdio.h>
#include <unistd.h>
#include <stdlib.h>
#include <errno.h>
#include <string.h>
 
int main( int argc, char* argv[] )
{
    if( argc <= 2 )
    {
        printf( "usage: %s ip_address port_number\n", basename( argv[0] ) );
        return 1;
    }
    const char* ip = argv[1];
    int port = atoi( argv[2] );
 
    int sock = socket( PF_INET, SOCK_STREAM, 0 );
    assert( sock >= 0 );
    int reuse = 1;
    setsockopt( sock, SOL_SOCKET, SO_REUSEADDR, &reuse, sizeof( reuse ) );
 
    struct sockaddr_in address;
    bzero( &address, sizeof( address ) );
    address.sin_family = AF_INET;
    inet_pton( AF_INET, ip, &address.sin_addr );
    address.sin_port = htons( port );
    int ret = bind( sock, ( struct sockaddr* )&address, sizeof( address ) );
    assert( ret != -1 );
 
    ret = listen( sock, 5 );
    assert( ret != -1 );
 
    struct sockaddr_in client;
    socklen_t client_addrlength = sizeof( client );
    int connfd = accept( sock, ( struct sockaddr* )&client, &client_addrlength );
    if ( connfd < 0 )
    {
        printf( "errno is: %d\n", errno );
    }
    else
    {
        char remote[INET_ADDRSTRLEN ];
        printf( "connected with ip: %s and port: %d\n", 
            inet_ntop( AF_INET, &client.sin_addr, remote, INET_ADDRSTRLEN ), ntohs( client.sin_port ) );
        close( connfd );
    }
 
    close( sock );
    return 0;
}
  • 通过setsocketopt的设置以后，即便sock处于TIME_WAIT状态，与之绑定的socket地址也能够当即被重用。此外，咱们也能够经过修改内核参数/proc/sys/net/ipv4/tcp_tw_recycle 来快速回收被关闭的socket，从而使得TCP链接根本就不进入TIME_WAIT状态，进而容许应用程序当即重用本地的socket地址。

SO_RCVBUF和SO_SNDBUF选项

  • SO_RCVBUF和SO_SNDBUF选项分别表示TCP接收缓冲区和发送缓冲区的大小。不过，当咱们用setsockopt来设置TCP的接收缓冲区和发送缓冲区的大小时，系统都会将其值加倍，而且不得小于其个最小值。TCP接收缓冲区的最小值是256字节，而发送缓冲区的最小值是2048字节（不过，不一样的系统可能有不一样的默认最小值）。此外，咱们能够直接修改内核参数/proc/sys/net/ipv4/tcp_rmem和/proc/sys/net/ipv4/tcp_wmem来强制TCP接收缓冲区和发送缓冲区的大小没有最小值限制。

修改TCP发送缓冲区的客户端程序：服务器

#include <sys/socket.h>
#include <arpa/inet.h>
#include <assert.h>
#include <stdio.h>
#include <unistd.h>
#include <string.h>
#include <stdlib.h>
 
#define BUFFER_SIZE 512
 
int main( int argc, char* argv[] )
{
    if( argc <= 3 )
    {
        printf( "usage: %s ip_address port_number send_bufer_size\n", basename( argv[0] ) );
        return 1;
    }
    const char* ip = argv[1];
    int port = atoi( argv[2] );
 
    struct sockaddr_in server_address;
    bzero( &server_address, sizeof( server_address ) );
    server_address.sin_family = AF_INET;
    inet_pton( AF_INET, ip, &server_address.sin_addr );
    server_address.sin_port = htons( port );
 
    int sock = socket( PF_INET, SOCK_STREAM, 0 );
    assert( sock >= 0 );
 
    int sendbuf = atoi( argv[3] );
    int len = sizeof( sendbuf );
    setsockopt( sock, SOL_SOCKET, SO_SNDBUF, &sendbuf, sizeof( sendbuf ) );
    getsockopt( sock, SOL_SOCKET, SO_SNDBUF, &sendbuf, ( socklen_t* )&len );
    printf( "the tcp send buffer size after setting is %d\n", sendbuf );
 
    if ( connect( sock, ( struct sockaddr* )&server_address, sizeof( server_address ) ) != -1 )
    {
        char buffer[ BUFFER_SIZE ];
        memset( buffer, 'a', BUFFER_SIZE );
        send( sock, buffer, BUFFER_SIZE, 0 );
    }
 
    close( sock );
    return 0;
}

修改TCP接收缓冲区的服务器程序：socket

#include <sys/socket.h>
#include <netinet/in.h>
#include <arpa/inet.h>
#include <assert.h>
#include <stdio.h>
#include <unistd.h>
#include <stdlib.h>
#include <errno.h>
#include <string.h>
 
#define BUFFER_SIZE 1024
 
int main( int argc, char* argv[] )
{
    if( argc <= 3 )
    {
        printf( "usage: %s ip_address port_number receive_buffer_size\n", basename( argv[0] ) );
        return 1;
    }
    const char* ip = argv[1];
    int port = atoi( argv[2] );
 
    struct sockaddr_in address;
    bzero( &address, sizeof( address ) );
    address.sin_family = AF_INET;
    inet_pton( AF_INET, ip, &address.sin_addr );
    address.sin_port = htons( port );
 
    int sock = socket( PF_INET, SOCK_STREAM, 0 );
    assert( sock >= 0 );
    int recvbuf = atoi( argv[3] );
    int len = sizeof( recvbuf );
    setsockopt( sock, SOL_SOCKET, SO_RCVBUF, &recvbuf, sizeof( recvbuf ) );
    getsockopt( sock, SOL_SOCKET, SO_RCVBUF, &recvbuf, ( socklen_t* )&len );
    printf( "the receive buffer size after settting is %d\n", recvbuf );
 
    int ret = bind( sock, ( struct sockaddr* )&address, sizeof( address ) );
    assert( ret != -1 );
 
    ret = listen( sock, 5 );
    assert( ret != -1 );
 
    struct sockaddr_in client;
    socklen_t client_addrlength = sizeof( client );
    int connfd = accept( sock, ( struct sockaddr* )&client, &client_addrlength );
    if ( connfd < 0 )
    {
        printf( "errno is: %d\n", errno );
    }
    else
    {
        char buffer[ BUFFER_SIZE ];
        memset( buffer, '\0', BUFFER_SIZE );
        while( recv( connfd, buffer, BUFFER_SIZE-1, 0 ) > 0 ){}
        close( connfd );
    }
 
    close( sock );
    return 0;
}

运行结果：tcp

root@iZbp1anc6yju2dks3nw5j0Z:~/test/socket# ./client 127.0.0.1 12345 2000
the tcp send buffer size after setting is 4608
root@iZbp1anc6yju2dks3nw5j0Z:~/test/socket# ./server 127.0.0.1 12345 50
the receive buffer size after settting is 2304

如上说明：当咱们用setsockopt来设置TCP的接收缓冲区和发送缓冲区的大小时，系统都会将其值加倍，而且不得小于其个最小值。函数

SO_RCVLOWAT和SO_SNDLOWAT选项

  • SO_RCVLOWAT和SO_SNDLOWAT选项分别表示TCP接收缓冲区和发送缓冲区的低水位标记。它们通常被I/O复用系统调用，用来判断socket是否可读或可写。当TCP接收缓冲区中可读数据的总数大于其低水位标记时，I/O复用系统调用将通知应用程序能够从对应的socket上读取数据；当TCP发送缓冲区中的空闲空间（能够写入数据的空间）大于其低水位标记时，I/O复用系统调用将通知应用程序能够往对应的socket上写入数据。
  • 默认状况下，TCP接收缓冲区的低水位标记和TCP发送缓冲区的低水位标记均为1字节。

SO_LINGER选项

SO_LINGER选项用于控制close系统调用在关闭TCP链接时的行为。默认状况下，当咱们使用close系统调用来关闭一个socket时，close将当即返回，TCP模块负责把该socket对应的TCP发送缓冲区中残留的数据发送给对方。
       设置SO_LINGER选项的值时，咱们须要给setsockopt（getsockopt）系统调用传递一个linger类型的结构体，其定义以下：
       spa

#include <sys/socket.h>
struct linger
{
    int  l_onoff; //开启（非0）仍是关闭（0）该选项
    int  l_linger; // 滞留时间
};

根据linger结构体中两个成员变量的不一样值，close 系统调用可能产生以下3种行为之一：rest

  • l_onoff 等于0。此时SO_LINGER选项不起做用，close用默认行为关闭socket。
  • l_onoff 不为0，l_linger等于0. 此时close 系统调用当即返回，TCP模块将丢弃被关闭的socket对应的TCP发送缓冲区中残留的数据，同时给对方一个复位报文段。所以，这种状况给服务器提供了异常终止一个链接的方法。
  • l_onoff不为0，l_linger大于0 。此时close的行为取决于两个条件：（1）被关闭的socket对应的TCP发送缓冲区中是否还有残留的数据；（2）该socket是阻塞的仍是非阻塞的。 对于阻塞的socket，close将等待一段长为l_linger的时间，直到TCP模块发送完全部残留数据并获得对方的确认。若是这段之间内TCP模块没有发送完残留数据并获得对方的确认，那么close系统调用将返回-1并设置errno为EWOULDBLOCK。 若是socket是非阻塞的，close将当即返回，此时咱们须要根据其返回值和errno来判断残留数据是否已经发送完毕。
相关文章
相关标签/搜索
每日一句
    每一个你不满意的现在，都有一个你没有努力的曾经。
本站公众号
   欢迎关注本站公众号,获取更多信息
联系我们 最近搜索 最新文章 沪ICP备13005482号-10 MyBatis教程 SQL 教程 MySQL教程 Java 教程 Thymeleaf 教程 Hibernate教程 Spring教程 Redis教程