使用tcp方式的socket传递数据的方式?

发布于 2022-08-26 18:58:33 字数 3165 浏览 8 评论 0

我写了两个server端的代码:

1.第一个是:

int
main(int argc, char **argv)
{
    int                 listenfd, connfd;
    struct sockaddr_in  servaddr;
    char                buff[MAXLINE];
    time_t              ticks;
        char                            temp[1];
        int                             i = 0;

    listenfd = Socket(AF_INET, SOCK_STREAM, 0);

    bzero(&servaddr, sizeof(servaddr));
    servaddr.sin_family      = AF_INET;
    servaddr.sin_addr.s_addr = htonl(INADDR_ANY);
    servaddr.sin_port        = htons(9999); /* daytime server */

    Bind(listenfd, (SA *) &servaddr, sizeof(servaddr));

    Listen(listenfd, LISTENQ);

    for ( ; ; ) {
        connfd = Accept(listenfd, (SA *) NULL, NULL);

        ticks = time(NULL);
        snprintf(buff, sizeof(buff), "%.24s\r\n", ctime(&ticks));

        for(i = 0; i < strlen(buff); i++)
        {
            temp[0] = buff[i];
            Write(connfd, temp, strlen(temp));
    }

        Close(connfd);
}
}

2. 第二种方式是把buff的字符串一次性的write进去

int
main(int argc, char **argv)
{
    int                 listenfd, connfd;
    struct sockaddr_in  servaddr;
    char                buff[MAXLINE];
    time_t              ticks;
        char                            temp[1];
        int                             i = 0;

    listenfd = Socket(AF_INET, SOCK_STREAM, 0);

    bzero(&servaddr, sizeof(servaddr));
    servaddr.sin_family      = AF_INET;
    servaddr.sin_addr.s_addr = htonl(INADDR_ANY);
    servaddr.sin_port        = htons(9999); /* daytime server */

    Bind(listenfd, (SA *) &servaddr, sizeof(servaddr));

    Listen(listenfd, LISTENQ);

    for ( ; ; ) {
        connfd = Accept(listenfd, (SA *) NULL, NULL);

        ticks = time(NULL);
        snprintf(buff, sizeof(buff), "%.24s\r\n", ctime(&ticks));

        Write(connfd, buff, strlen(buff));
        Close(connfd);
}
}

3. 我的客户端的代码是:

int
main(int argc, char **argv)
{
    int                 sockfd, n;
    char                recvline[MAXLINE + 1];
    struct sockaddr_in  servaddr;
        int count = 0;

    if (argc != 2)
        err_quit("usage: a.out <IPaddress>");

    if ( (sockfd = socket(AF_INET, SOCK_STREAM, 0)) < 0)
        err_sys("socket error");

    bzero(&servaddr, sizeof(servaddr));
    servaddr.sin_family = AF_INET;
    servaddr.sin_port   = htons(9999);  /* daytime server */
    if (inet_pton(AF_INET, argv[1], &servaddr.sin_addr) <= 0)
        err_quit("inet_pton error for %s", argv[1]);

    if (connect(sockfd, (SA *) &servaddr, sizeof(servaddr)) < 0)
        err_sys("connect error");

    while ( (n = read(sockfd, recvline, MAXLINE)) > 0) {
        recvline[n] = 0;    /* null terminate */
                count++;
        if (fputs(recvline, stdout) == EOF)
            err_sys("fputs error");
    }
    if (n < 0)
        err_sys("read error");
        printf("read time:%d\n", count);

    exit(0);
}

在两种情况下,客户端的输出count值都是1,我想问的是第二种服务端一个个的向客户端传递数据时,为什么客户端只要接受一次就完成了字符串的接收呢?

如果你对这篇内容有疑问,欢迎到本站社区发帖提问 参与讨论,获取更多帮助,或者扫码二维码加入 Web 技术交流群。

扫码二维码加入Web技术交流群

发布评论

需要 登录 才能够评论, 你可以免费 注册 一个本站的账号。

评论(2

月寒剑心 2022-09-02 18:58:33

默认情况下TCP_NODELAY是不启用的,也就是说(linux内核)会启用 Naggle's Algorithm ,将多个小packet合并成大packet以提高带宽的利用率(一个tcp header通常是40Bytes,1个字节一个packet太浪费)。

紙鸢 2022-09-02 18:58:33

这正是 SOCK_STREAMSOCK_DGRAM 的区别。前者是流式传输,保证顺序,但是不保证消息边界,也就是说多次发送可能一次接受完,也可能一次发送花了多次接收。TCP 是其典型。后者数据报方式的话,是不可靠的消息传输,保持消息边界的。UDP 是其典型。

就像 felix021 说的,内核会按它的想法自行处理这些本来就不向用户作任何保证的细节。

~没有更多了~
我们使用 Cookies 和其他技术来定制您的体验包括您的登录状态等。通过阅读我们的 隐私政策 了解更多相关信息。 单击 接受 或继续使用网站,即表示您同意使用 Cookies 和您的相关数据。
原文