3

我正在通过套接字发送大数据（嗯...... 1Mb），但我不知道为什么发送操作会阻塞程序并且永远不会结束。小型发送完美运行，我找不到问题出在哪里。任何人都可以帮助我吗？

提前感谢您提供的任何帮助。

int liResult = 1;
int liConnection = 0;
int liSenderOption = 1;
struct addrinfo laiSenderAddrInfo;
struct addrinfo *laiResultSenderAddrInfo;

memset(&laiSenderAddrInfo,0,sizeof(laiSenderAddrInfo));
laiSenderAddrInfo.ai_socktype = SOCK_STREAM;
laiSenderAddrInfo.ai_flags = AI_PASSIVE;

liResult = getaddrinfo(_sIp.c_str(), _sPort.c_str(), &laiSenderAddrInfo, &laiResultSenderAddrInfo);

if (liResult > -1)
{
    liConnection = socket(laiResultSenderAddrInfo->ai_family, SOCK_STREAM, laiResultSenderAddrInfo->ai_protocol);
    liResult = liConnection;

    if (liConnection > -1)
    {
        setsockopt(liConnection, SOL_SOCKET, SO_REUSEADDR, &liSenderOption, sizeof(liSenderOption));
        liResult = connect(liConnection, laiResultSenderAddrInfo->ai_addr, laiResultSenderAddrInfo->ai_addrlen);
    }
}

size_t lBufferSize = psText->length();
long lBytesSent = 1;
unsigned long lSummedBytesSent = 0;

while (lSummedBytesSent < lBufferSize and lBytesSent > 0)
{
    lBytesSent = send(liConnection, psText->c_str() + lSummedBytesSent, lBufferSize - lSummedBytesSent, MSG_NOSIGNAL);

    if (lBytesSent > 0)
    {
        lSummedBytesSent += lBytesSent;
    }
}
4

3 回答 3

2

调用阻塞，send()直到所有数据都已发送或缓冲。如果套接字另一端的程序没有读取，因此没有数据流，那么你端的写缓冲区将填满并send()阻塞。很有可能，当您尝试发送较少量的数据时，它适合缓冲区。

另请参阅此答案。

于 2012-10-16T10:39:10.403 回答
2

检查缓冲区大小，您可以按照此答案进行操作

如何找到linux的套接字缓冲区大小

就我而言，这些值为

Minimum = 4096 bytes ~ 4KB
Default = 16384 bytes ~ 16 KB
Maximum = 4022272 bytes ~ 3.835 MB

您可以调整值net.core.rmem_max和net.core.wmem_maxin/etc/sysctl.conf以增加套接字缓冲区大小并重新加载sysctl -p.

来源：http ://www.runningunix.com/2008/02/increasing-socket-buffer-size-in-linux/

于 2012-10-16T10:54:50.387 回答
-1

对于 TCP，内核有一个固定大小的缓冲区，用于存储未发送的数据。此缓冲区的大小是 TCP 会话的当前窗口大小。一旦此缓冲区已满，任何新发送都将失败。这是一种 TCP 流控制机制，可防止您尝试发送数据的速度快于接收方消耗数据的速度，同时为丢失的数据提供自动重新发送。默认窗口可以小至 64K，但对于高延迟高带宽网络可以增大。

您可能需要做的是将数据分解成更小的发送块，然后确保在发送缓冲区已满时有一个流出机制。

于 2012-10-16T10:35:04.817 回答