关于c:Linux网络开发必学教程13数据收发的扩展用法-上

0次阅读

共计 5733 个字符，预计需要花费 15 分钟才能阅读完成。

write() 和 send() 都能够收发数据，有什么区别？

send 能够应用 flags 指定可选项信息，其中 0 示意默认发送行为
send 当 flags 为 0 时，会期待发送缓冲区数据清空之后才将数据放入发送缓冲器而后返回
write 不能指定可选项信息，同时不会阻塞

read() 和 recv() 都能够接收数据，有什么区别?

recv 能够应用 flags 指定可选项信息，其中 0 示意默认接管行为
recv 当 flags 为 0 时，会期待接收缓冲区有数据之后才将数据从接收缓冲区中取出而后返回
read 不能指定可选项信息，同时不会阻塞

#include <sys/socket.h>

ssize_t send(int socketfd, const void *buf, size_t nbytes, int flags);
ssize_t recv(int socketfd, void *buf, size_t nbytes, int flags);

flags – 收发数据时指定可选项信息，其中 0 为默认收发行为

可选项	含意	send	recv
MSG_OOB	用于传输带外数据（Out Of Band Data）, 即：紧急数据（优先发送）	√	√
MSG_PEEK	验证接收缓冲区是否存在数据（有什么数据）		√
MSG_DONTROUTE	数据传输过程不通过路由表，在本地局域网中寻找目的地	√
MSG_DONTWAIT	非阻塞模式，数据收发时立刻返回	√	√
MSG_WAITALL	在接管到申请的全副数据之前，不提前返回		√
MSG_MORE	有更多数据须要发送，批示内核期待数据	√
…	…

留神：不同的操作系统对上述可选项的反对不同，理论工程开发时，须要当时对指标零碎中反对的可选项进行调研

原生定义

应用与一般数据不同的的通道独立传输的数据
带外数据优先级比一般数据高（优先传输，对端优先接管）

TCP 中的带外数据

因为原生设计的限度，TCP 无奈提供真正意义上的带外数据
TCP 中仅能通过传输协定音讯头中的标记，传输紧急数据，且 长度仅 1 字节

URG 指针指向紧急音讯的下一个地位，即：URG 指针指向地位的前一个字节存储了紧急音讯

接收端优先接管紧急数据，并将其存储到非凡缓冲区，之后再接管一般数据

紧急数据：0x03
一般数据：0x01,0x02

因为 TCP 设计为流式数据，因而，无奈做到真正的带外数据
被标记的紧急数据可被提前接管，进入 非凡缓 冲区（仅一字节）
- 每个 TCP 包最多只有一个紧急数据
- 非凡缓冲区仅寄存最近的紧急数据（不及时接管将失落）

发送一般数据，一般形式接管：失常，数据按序达到
发送一般数据，紧急形式接管：谬误返回
发送紧急数据，一般形式接管：一般数据 recv 时阻塞
发送紧急数据，紧急形式接管：失常，收到紧急数据

client.c

#include <sys/types.h>
#include <sys/socket.h>
#include <netinet/in.h>
#include <arpa/inet.h>
#include <stdio.h>
#include <unistd.h>
#include <string.h>

int main()
{int sock = {0};
    struct sockaddr_in addr = {0};
    int len = 0;
    char *test = "Delpin-Tang";

    sock = socket(PF_INET, SOCK_STREAM, 0);

    if (sock == -1) {printf("socket error\n");
        return -1;
    }

    addr.sin_family = AF_INET;
    addr.sin_addr.s_addr = inet_addr("127.0.0.1");
    addr.sin_port = htons(8888);

    if (connect(sock, (struct sockaddr*)&addr, sizeof(addr)) == -1) {printf("connect error\n");
        return -1;
    }

    printf("connect success\n");

    len = send(sock, test, strlen(test), MSG_OOB);

    getchar();

    close(sock);

    return 0;
}

server.c

#include <sys/types.h>
#include <sys/socket.h>
#include <netinet/in.h>
#include <arpa/inet.h>
#include <stdio.h>
#include <unistd.h>
#include <string.h>

int main()
{
    int server = 0;
    struct sockaddr_in saddr = {0};
    int client = 0;
    struct sockaddr_in caddr = {0};
    socklen_t asize = 0;
    int len = 0;
    char buf[32] = {0};
    int r = 0;

    server = socket(PF_INET, SOCK_STREAM, 0);

    if (server == -1) {printf("server socket error\n");
        return -1;
    }

    saddr.sin_family = AF_INET;
    saddr.sin_addr.s_addr = htonl(INADDR_ANY);
    saddr.sin_port = htons(8888);

    if (bind(server, (struct sockaddr*)&saddr, sizeof(saddr)) == -1) {printf("server bind error\n");
        return -1;
    }

    if (listen(server, 1) == -1) {printf("server listen error\n");
        return -1;
    }

    printf("server start success\n");

    while (1) {asize = sizeof(caddr);

        client = accept(server, (struct sockaddr*)&caddr, &asize);

        if (client == -1) {printf("client accept error");
            return -1;
        }

        printf("client: %d\n", client);

        do {r = recv(client, buf, sizeof(buf), MSG_OOB);

            if (r > 0) {buf[r] = 0;
                printf("OOB: %s\n", buf);
            }

            r = recv(client, buf, sizeof(buf), 0);

            if (r > 0) {buf[r] = 0;
                printf("NORMAL: %s\n", buf);
            }
        }while (r > 0);

        close(client);
    }

    close(server);

    return 0;
}

输入：

server start success
client: 4
NORMAL: Delpin-Tan   // 留神，一般数据先输入（因为当 flags 为 MSG_OOB 时不阻塞，而为 0 时会阻塞，直到接管到数据）OOB: g               // 留神，仅输入最初一个字符！！

小问题：理论开发中，如何高效的接管 TCP 紧急数据?

socket 上收到一般数据和紧急数据时都会使得 select 立刻返回

一般数据：socket 处于数据可读状态（可读取一般数据）
紧急数据：socket 解决异样状态（可读取紧急数据）

num = select(max + 1, &temp, 0, &except, &timeout);

if (num > 0) {for (i=1; i<=max; ++i) {if (FD_ISSET(i, &except)) {if (i != server) {char buf[32] = {0};
                int r = recv(i, buf, sizeof(buf), MSG_OOB);
                if (r > 0) {buf[r] = 0;
                    printf("OOB: %s\n", buf);
                }
            }
        }

        if (FD_ISSET(I, &temp)) {// ...}
    }
}

client.c

#include <sys/types.h>
#include <sys/socket.h>
#include <netinet/in.h>
#include <arpa/inet.h>
#include <stdio.h>
#include <unistd.h>
#include <string.h>

int main()
{int sock = {0};
    struct sockaddr_in addr = {0};
    int len = 0;
    char *test = "Delpin-Tang";

    sock = socket(PF_INET, SOCK_STREAM, 0);

    if (sock == -1) {printf("socket error\n");
        return -1;
    }

    addr.sin_family = AF_INET;
    addr.sin_addr.s_addr = inet_addr("127.0.0.1");
    addr.sin_port = htons(8888);

    if (connect(sock, (struct sockaddr*)&addr, sizeof(addr)) == -1) {printf("connect error\n");
        return -1;
    }

    printf("connect success\n");

    len = send(sock, test, strlen(test), MSG_OOB);

    getchar();

    close(sock);

    return 0;
}

select-server.c

#include <sys/types.h>
#include <sys/socket.h>
#include <sys/select.h>
#include <netinet/in.h>
#include <arpa/inet.h>
#include <stdio.h>
#include <unistd.h>
#include <string.h>

int server_handler(int server) 
{struct sockaddr_in addr = {0};
    socklen_t asize = sizeof(addr);
    return accept(server, (struct sockaddr*)&addr, &asize);
}

int client_handler(int client) 
{char buf[32] = {0};

    int ret = recv(client, buf, sizeof(buf) - 1, 0);

    if (ret > 0) {buf[ret] = 0;

        printf("Recv: %s\n", buf);
    }

    return ret;
}

int clint_except_handler(int client) 
{char buf[2] = {0};
    int r = recv(client, buf, sizeof(buf), MSG_OOB);

    if (r > 0) {buf[r] = 0;
        printf("OOB: %s\n", buf);
    }

    return r;
}

int main()
{
    int server = 0;
    struct sockaddr_in saddr = {0};
    int max = 0;
    int num = 0;
    fd_set reads = {0};
    fd_set temps = {0};
    fd_set except = {0};
    struct timeval timeout = {0};

    server = socket(PF_INET, SOCK_STREAM, 0);

    if (server == -1) {printf("server socket error\n");
        return -1;
    }

    saddr.sin_family = AF_INET;
    saddr.sin_addr.s_addr = htonl(INADDR_ANY);
    saddr.sin_port = htons(8888);

    if (bind(server, (struct sockaddr*)&saddr, sizeof(saddr)) == -1) {printf("server bind error\n");
        return -1;
    }

    if (listen(server, 1) == -1) {printf("server listeb error\n");
        return -1;
    }

    printf("server start success\n");

    FD_ZERO(&reads);
    FD_SET(server, &reads);

    max = server;

    while (1) {
        temps = reads;
        except = reads;

        timeout.tv_sec = 0;
        timeout.tv_usec = 10000;

        num = select(max + 1, &temps, 0, &except, &timeout);

        if (num > 0) {
            int i = 0;

            for (i=0; i<=max; ++i) {if (FD_ISSET(i, &except)) {if (i != server) {clint_except_handler(i);
                    }
                }

                if (FD_ISSET(i, &temps)) {if (i == server) {int client = server_handler(server);

                        if (client > -1) {FD_SET(client, &reads);
                            max = (client > max) ? client : max;
                            printf("accept client: %d\n", client);
                        }
                    } else {int r = client_handler(i);

                        if (r == -1) {FD_CLR(i, &reads);
                            close(i);
                        }
                    }
                }
            }

            int client = server_handler(server);
        }
    }
}

输入：

server start success
accept client: 4
OOB: g
Recv: Delpin-Tan

read() / write() 可用于收发一般数据（不具备扩大性能）
send() / recv() 可通过选项信息扩大更多功能
TCP 紧急数据可标识 256 种紧急事件（异样事件）
通过 select 可能及时处理紧急数据，并辨别一般数据

正文完

c

发表至： c#

2022-05-07

0

关于c#:C-中-DateTime-的加减

关于c#:Winform-窗体缩放下-使用剪切板功能会出现页面闪动

关于c++:FFmpeg-播放-RTSPWebcam-流

关于c#:WinForm-DataGridView-控件中复选框的用法

关于golang:微服务从代码到k8s部署应有尽有系列十三服务监控

关于c:Linux网络开发必学教程13数据收发的扩展用法-上

数据收发选项

flags 选项信息（局部）

MSG_OOB（带外数据，紧急数据）

TCP 带外数据实现原理

TCP 带外数据处理策略

用上面的形式收发数据会产生什么

编程试验：TCP 紧急数据的发送与接管

应用 select 接管紧急数据

紧急数据接管示例

编程试验：应用 select 接管紧急数据

小结

站内搜索