0

（下面列出的原始问题）原来我有一个“消费缓慢”的问题。由于我无法控制服务器程序，因此我尝试设置 setsockopt(m_sock,
IPPROTO_TCP,
TCP_NODELAY,
(char *) &flag,
sizeof(int));

但我仍然到了写入套接字需要几秒钟的时间。我错过了什么吗？原始问题：我使用创建了一个套接字

m_sock = socket(AF_INET, SOCK_STREAM, 0);

将其设置为非阻塞：

int opts = fcntl ( m_sock, F_GETFL );

opts = ( opts | O_NONBLOCK ); 

fcntl ( m_sock, F_SETFL,opts );

然后发送

send(m_sock, v_pData, v_iDataSize, MSG_NOSIGNAL);

我正在发送大约 200bytes ，大约 2 分钟后每秒 5 次，它会创建一个很大的缓冲区并在发送数据时产生很大的延迟。有没有办法提高发送性能？

第一次编辑： 我正在添加更多关于如何创建和使用套接字的代码：

m_sock = socket ( AF_INET,
        SOCK_STREAM,
        0 );

if ( ! is_valid() )
  return false;

int on = 1;
if ( setsockopt ( m_sock, SOL_SOCKET, SO_REUSEADDR, ( const char* ) &on, sizeof ( on ) ) == -1 )
return false;


server = gethostbyname(host.c_str());
if (server == NULL) {   

    return false;
}
bzero((char *) &serv_addr, sizeof(serv_addr));
serv_addr.sin_family = AF_INET;
bcopy((char *)server->h_addr, 
     (char *)&serv_addr.sin_addr.s_addr,
     server->h_length);
serv_addr.sin_port = htons(portno);

set_non_blocking(true);// Code for set_non_blocking mentioned above


connect(m_sock,(struct sockaddr *) &serv_addr,sizeof(serv_addr))  ;

我使用以下方法写入套接字：

iOut = send(m_sock, v_pData, v_iDataSize, MSG_NOSIGNAL);
4

2 回答 2

1

您会看到Nagle 算法的实际应用。

只需设置 TCP_NODELAY 套接字选项：

int value = 1;
setsockopt(m_sock, IPPROTO_TCP, TCP_NODELAY, (void*)&value, sizeof(value));

我认为您不需要 O_NONBLOCK，但这在很大程度上取决于您的用例。

于 2013-09-29T13:56:22.160 回答
1

特别是如果您使用非阻塞 I/O（例如O_NONBLOCK），您应该使用一些多路复用系统调用（例如 .eg poll(2)或旧的和过时的select(2)）来确保您的套接字确实是可读或可写的（即在read( 2)或recv(2)可读时，或在write(2)或send(2)时可写）。

当然，如果您有多个套接字，则需要多路复用多个套接字。

简而言之，您需要一个事件循环（您可能使用提供的库，例如libevent或libevpoll ...），或者在多路复用系统调用（如....）周围拥有自己的。即使使用一个双向套接字，您也需要多路复用其输入和输出（使用阻塞或非阻塞 I/O）。

阅读一些好书，例如Advanced Linux Programming 和一些Linux Socket Tutorial和Unix Network Programming书。

你的问题不够精确，无法回答。您应该提供更多代码，或者至少提供strace可疑系统调用的相关跟踪。

于 2013-09-29T15:38:02.930 回答