文档建议反馈控制台
首页
学习
活动
专区
圈层
工具
MCP广场
文章/答案/技术大牛
发布
社区首页 >问答首页 >Recv-q+发送-q>写字节

问Recv-q+发送-q>写字节
EN

Stack Overflow用户
提问于 2016-03-28 02:57:12
回答 1查看 147关注 0票数 1

我编写了一个tcp服务器和一个tcp客户机，客户机只向服务器发送数据并打印它写入的字节数，服务器只接受连接，然后使用netstat显示套接字的Recv-Q和send，我发现Recv-q+send>写字节。这是怎么回事？

代码语言：javascript
复制
client code:
#include <unistd.h>
#include <sys/socket.h>
#include <netinet/in.h>
#include <arpa/inet.h>
#include <stdlib.h>
#include <stdio.h>
#include <string.h>
#include <netdb.h>
#include <stdarg.h>
#include <errno.h>

void error(int status, int err, const char *fmt, ...)
{
    va_list args;

    va_start(args, fmt);

    vfprintf(stderr, fmt, args);

    va_end(args);

    if (err != 0)
    {
        fprintf(stderr, "errno = %d, errmsg = %s\n", err, strerror(err));
    }

    if (status != 0)
    {
        exit(err);
    }
}

int set_address(const char *host, const char *serv, const char *protocol, sockaddr_in *addr)
{
    struct hostent *host_info;
    struct servent *serv_info;

    memset(addr, 0, sizeof(sockaddr_in));

    addr->sin_family = AF_INET;

    if (host != NULL)
    {
        if (inet_aton(host, &addr->sin_addr) != 0)
        {
            host_info = gethostbyname(host);

            if (host_info == NULL)
            {
                error(1, h_errno, "set_address failed, gethostbyname(%s) failed, errno = %d, errmsg = %s\n", host, h_errno, hstrerror(h_errno));
            }
            else
            {
                inet_aton(host_info->h_addr_list[0], &addr->sin_addr);
            }
        }
    }
    else
    {
        addr->sin_addr.s_addr = INADDR_ANY;
    }

    if (serv != NULL)
    {
        char * end_pos;

        addr->sin_port = htons(strtol(serv, &end_pos, 10));

        if (*end_pos != '\0')
        {
            serv_info = getservbyname(serv, protocol);

            if (serv_info == NULL)
            {
                error(1, h_errno, "set_address failed, getservbyname(%s, %s) faield\n", serv, protocol);
            }
            else
            {
                addr->sin_port = serv_info->s_port;
            }
        }
    }
}

int tcp_client(const char *host, const char *serv)
{
    struct sockaddr_in server;
    int fd;
    const int on = 1;

    set_address(host, serv, "tcp", &server);

    fd = socket(AF_INET, SOCK_STREAM, 0);

    if (fd < 0)
    {
        error(1, errno, "create socket failed\n");
    }

    if (connect(fd, (struct sockaddr *)&server, sizeof(server)) != 0)
    {
        error(1, errno, "connect to server failed\n");
    }

    return fd;
}

int main (int argc, char **argv)
{
    if (argc != 3)
    {
        printf("usage: %s <host> <port>\n", basename(argv[0]));
        exit(1);
    }

    char buf[1024];
    int fd;
    int total_write_bytes = 0, cur_write_bytes = 0;

    fd = tcp_client(argv[1], argv[2]);

    while (true)
    {
        cur_write_bytes = write(fd, buf, sizeof(buf));
        if (cur_write_bytes <= 0)
        {
            break;
        }
        total_write_bytes += cur_write_bytes;
        printf("total_write_bytes = %d, curr_write_bytes = %d\n", total_write_bytes, cur_write_bytes);
    }

    return 0;
}

server code:
#include <unistd.h>
#include <sys/socket.h>
#include <netinet/in.h>
#include <arpa/inet.h>
#include <stdlib.h>
#include <stdio.h>
#include <string.h>
#include <netdb.h>
#include <stdarg.h>
#include <errno.h>

void error(int status, int err, const char *fmt, ...)
{
    va_list args;

    va_start(args, fmt);

    vfprintf(stderr, fmt, args);

    va_end(args);

    if (err != 0)
    {
        fprintf(stderr, "errno = %d, errmsg = %s\n", err, strerror(err));
    }

    if (status != 0)
    {
        exit(err);
    }
}

int set_address(const char *host, const char *serv, const char *protocol, sockaddr_in *addr)
{
    struct hostent *host_info;
    struct servent *serv_info;

    memset(addr, 0, sizeof(sockaddr_in));

    addr->sin_family = AF_INET;

    if (host != NULL)
    {
        if (inet_aton(host, &addr->sin_addr) != 0)
        {
            host_info = gethostbyname(host);

            if (host_info == NULL)
            {
                error(1, h_errno, "set_address failed, gethostbyname(%s) failed, errno = %d, errmsg = %s\n", host, h_errno, hstrerror(h_errno));
            }
            else
            {
                inet_aton(host_info->h_addr_list[0], &addr->sin_addr);
            }
        }
    }
    else
    {
        addr->sin_addr.s_addr = INADDR_ANY;
    }

    if (serv != NULL)
    {
        char * end_pos;

        addr->sin_port = htons(strtol(serv, &end_pos, 10));

        if (*end_pos != '\0')
        {
            serv_info = getservbyname(serv, protocol);

            if (serv_info == NULL)
            {
                error(1, h_errno, "set_address failed, getservbyname(%s, %s) faield\n", serv, protocol);
            }
            else
            {
                addr->sin_port = serv_info->s_port;
            }
        }
    }
}

int tcp_server(const char *host, const char *serv)
{
    struct sockaddr_in local;
    int fd;
    const int on = 1;

    set_address(host, serv, "tcp", &local);

    fd = socket(AF_INET, SOCK_STREAM, 0);

    if (fd < 0)
    {
        error(1, errno, "create socket failed");
    }

    if (bind(fd, (sockaddr *)&local, sizeof(local)) != 0)
    {
        error(1, errno, "bind to port %s:%s failed\n", host, serv);
    }

    if (setsockopt(fd, SOL_SOCKET, SO_REUSEADDR, &on, sizeof(on)) != 0)
    {
        error(1, errno, "set SO_REUSEADDR failed\n");
    }

    if (listen(fd, 100) != 0)
    {
        error(1, errno, "listen on %s:%s failed\n", host, serv);
    }

    return fd;
}

int main (int argc, char **argv)
{
    if (argc != 3)
    {
        printf("usage: %s <host> <port>\n", basename(argv[0]));
        exit(1);
    }

    int listen_fd, fd;
    struct sockaddr_in addr;
    socklen_t len;

    listen_fd = tcp_server(argv[1], argv[2]);

    fd = accept(listen_fd, (struct sockaddr *)&addr, &len);

    if (fd < 0)
    {
        error(1, errno, "accept an connection failed\n");
    }

    while (true)
    {
        sleep(5);
    }

    return 0;
}

这就是结果：

标准输出结果：标准输出

netstat结果：netstat结果

tcpdump结果：

14:17:16.633105 IP localhost.54393 >localhost.私人代理:s 4282375064:4282375064(0) win 32767 14:17:16.633106 IP localhost.Personalhost.54393:s 4268411460:4268411460(0) ack 4282375065 win 32767 14:17:16.633115 IP localhost.54393 >localhost.私人代理：ack 1 win 8192 14:17:16.633127 IP localhost.54393 >localhost.sonal-agent:P 1:1025(1024) ack 1 win 8192 14:17:16.633130 IP localhost.Personalhost.54393：。ack 1025 win 8704 14:17:16.633156 IP localhost.54393 >localhost.sonal-agent:P 1025:2049(1024) ack 1 win 8192 14:17:16.633159 IP localhost.Personalhost.54393：。ack 2049 win 8704 14:17:16.633167 IP localhost.54393 >localhost.sonal-agent:P 2049:3073(1024) ack 1 win 8192 14:17:16.633169 IP localhost.Personalhost.54393：。ack 3073 win 8704 14:17:16.633176 IP localhost.54393 >localhost.sonal-agent:P 3073:4097(1024) ack 1 win 8192 14:17:16.633179 IP localhost.Personalhost.54393：。ack 4097 win 8704 14:17:16.633185 IP localhost.54393 >localhost.sonal-agent:P 4097:5121(1024) ack 1 win 8192 14:17:16.633188 IP localhost.Personalhost.54393：。ack 5121 win 8704 14:17:16.633195 IP localhost.54393 >localhost.sonal-agent:P 5121:6145(1024) ack 1 win 8192 14:17:16.633198 IP localhost.Personalhost.54393：。ack 6145 win 8704 14:17:16.633204 IP localhost.54393 >localhost.sonal-agent:P 6145:7169(1024) ack 1 win 8192 14:17:16.633206 IP localhost.Personalhost.54393：。ack 7169 win 8704 14:17:16.633213 IP localhost.54393 >localhost.sonal-agent:P 7169:8193(1024) ack 1 win 8192 14:17:16.633215 IP localhost.Personalhost.54393：。ack 8193 win 8704 14:17:16.633222 IP localhost.54393 >localhost.sonal-agent:P 8193:9217(1024) ack 1 win 8192 14:17:16.633224 IP localhost.Personalhost.54393：。ack 9217 win 8704 14:17:16.633230 IP localhost.54393 >localhost.sonal-agent:P 9217:10241(1024) ack 1 win 8192 14:17:16.633233 IP localhost.Personalhost.54393：。ack 10241 win 8704 14:17:16.633239 IP localhost.54393 >localhost.sonal-agent:P 10241:11265(1024) ack 1 win 8192 14:17:16.633242 IP localhost.Personalhost.54393：。ack 11265 win 8448 14:17:16.633249 IP localhost.54393 >localhost.sonal-agent:P 11265:12289(1024) ack 1 win 8192 14:17:16.633251 IP localhost.Personalhost.54393：。ack 12289 win 8192 14:17:16.633258 IP localhost.54393 >localhost.sonal-agent:P 12289:13313(1024) ack 1 win 8192 14:17:16.633261 IP localhost.Personalhost.54393：。ack 13313赢7936 14:17:16.633269 IP本地主机.个人-代理>本地主机.54393：.ack 14337赢7680 14:17:16.671777 IP本地主机.个人-代理>本地主机.54393：.ack 31757 win 3325 14:17:16.879921 IP localhost.54393 >localhost.sonal-agent:P 31757:45057(13300) ack 1 win 8192 14:17:16.959771 IP localhost.Personalhost.54393：。ack 45057赢0 14:17:17.175771 IP localhost.54393 >localhost.sonal-agent：.1Win 8192 14:17:17.175786 IP localhost.personal-agent > localhost.54393：.ack 45057赢0 14:17:17.607770 IP localhost.54393 >localhost.sonal-agent：.1Win 8192 14:17:17.607782 IP localhost.personal-agent > localhost.54393：.ack 45057赢0 14:17:18.471768 IP localhost.54393 >localhost.sonal-agent：.1Win 8192 14:17:18.471775 IP localhost.personal-agent > localhost.54393：.ack 45057赢0

sockets
c++11
tcp
c++
c
EN

回答 1

Stack Overflow用户

发布于 2016-03-28 05:31:17

在发送队列和接收队列中，已接收但尚未接收到确认的字节都位于发送队列和接收队列中。它们保持在发送队列中，因为在确认它们之前，发送方必须准备好重新发送它们。它们一直保留在接收队列中，直到应用程序调用接收函数并将它们从队列中取出为止。

票数 0
EN
页面原文内容由Stack Overflow提供。腾讯云小微IT领域专用引擎提供翻译支持
原文链接：

https://stackoverflow.com/questions/36255275

复制
相关文章

相似问题

领券

腾讯云开发者

扫码关注腾讯云开发者

扫码关注腾讯云开发者

领取腾讯云代金券

热门产品

热门推荐

更多推荐

Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有 

深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 粤公网安备44030502008569号

腾讯云计算（北京）有限责任公司 京ICP证150476号 |  京ICP备11018762号

问题归档专栏文章快讯文章归档关键词归档开发者手册归档开发者手册 Section 归档