Unix/Linux编程：UDS 流（Stream）

〇、前言

socket 是一种 IPC （Inter-Process Communication，进程间通信）方法，它允许位于同一主机（计算机）或使用网络连接起来的不同主机上的应用程序之间交换数据。通过使用Socket，开发人员可以创建网络应用程序，使其能够通过网络进行数据交换和通信。

Socket API通常用于基于TCP/IP协议栈的网络通信，但也可以用于其他网络协议。它提供了一组函数和数据结构，允许应用程序创建、连接、发送和接收数据，并管理网络连接。

Socket API的使用通常涉及以下几个步骤：

创建Socket：使用socket()函数创建一个Socket对象，该函数指定了协议族（例如，IPv4、IPv6）和Socket类型（例如，流式Socket或数据报Socket）。
绑定Socket：对于服务器应用程序，需要使用bind()函数将Socket绑定到一个特定的IP地址和端口号。
监听连接请求（可选）：对于服务器应用程序，可以使用listen()函数开始监听传入的连接请求。
接受连接请求（可选）：对于服务器应用程序，使用accept()函数接受传入的连接请求，并创建一个新的Socket对象来处理与客户端的通信。

对于客户端：

建立连接（可选）：对于客户端应用程序，使用connect()函数与服务器建立连接。
发送和接收数据：使用send()函数将数据发送到远程主机，使用recv()函数从远程主机接收数据。
关闭Socket：使用close()函数关闭Socket连接。

这只是Socket编程的基本概念和步骤，具体的使用方法和函数会根据编程语言和操作系统而有所不同。常见的编程语言，如C、C++、Java和Python，都提供了相应的Socket API库，使开发人员能够使用Socket进行网络编程。

通过Socket编程，应用程序可以实现客户端-服务器模型，建立网络通信、传输数据和实现各种网络应用，如Web服务器、聊天应用、文件传输等。

流程图如下：

在这里插入图片描述

本文将会写一个简单的、基本的服务器和客户端，并且成功让两者通信，平台为mac M1。

一、地址结构

对于各种 socket domain 都需要定义一个不同的结构类型来存储socket地址。然而由于诸如bind()之类的系统调用适用于所有 socket domain ，因此它们必须要能够接受任意类型的地址结构。为支持这种行为，socket API 定义了一个通用的地址结构 struct sockaddr。这个类型的唯一用途是将各种 domain 特定的地址结构转换成单个类型以供 socket 系统调用中的各个参数使用。sockaddr 结构通常被定义成如下所示的结构：·

struct  sockaddr_un {
	unsigned char   sun_len;        /* sockaddr len including null */
	sa_family_t     sun_family;     /* [XSI] AF_UNIX */
	char            sun_path[104];  /* [XSI] path name (gag) */
};

因此，服务器中首先得创建一个 socket，并做好准备工作以及初始化：

#define BACKLOG 5
#define SV_SOCK_PATH "/tmp/us_xfr"
#define BUF_SIZE 100


	struct sockaddr_un addr;
    int sfd, cfd;
    ssize_t numRead;
    char buf[BUF_SIZE];

    // 创建一个 socket
    sfd = socket(AF_UNIX, SOCK_STREAM, 0);
    if (sfd == -1) {
        perror("socket");
        exit(EXIT_FAILURE);
    }
    // 对这个长度是有规定的
    if (strlen(SV_SOCK_PATH) > sizeof(addr.sun_path) - 1) {
        printf("Server socket path too long: %s", SV_SOCK_PATH);
        exit(EXIT_FAILURE);
    }

    // 绑定之前，先将这个文件删除了，因为如果它存在的话，说明已经被绑定到了其它 socket 上
    if (remove(SV_SOCK_PATH) == -1 && errno != ENOENT) {
        printf("remove-%s", SV_SOCK_PATH);
        exit(EXIT_FAILURE);
    }

    // 初始化 socket
    memset(&addr, 0, sizeof(struct sockaddr_un));
    addr.sun_family = AF_UNIX;
    strncpy(addr.sun_path, SV_SOCK_PATH, sizeof(addr.sun_path) - 1);

二、绑定地址

在Socket编程中，bind()函数用于将一个特定的网络地址或者本地地址绑定到一个Socket对象上。这个绑定操作指定了Socket要使用的本地网络地址和端口，使得其他进程可以通过这个地址和端口与该Socket进行通信。

bind() 函数的原型如下：

#include <sys/types.h>
#include <sys/socket.h>

int bind(int sockfd, const struct sockaddr *addr, socklen_t addrlen);

sockfd：Socket文件描述符，表示要进行绑定的Socket对象。
addr：指向struct sockaddr类型的指针，包含要绑定的本地地址信息。
addrlen：addr结构体的大小。

以下是一个绑定网络地址的例子：

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

int main() {
	// ipv4
    int sockfd = socket(AF_INET, SOCK_STREAM, 0);

    struct sockaddr_in addr;
    // 初始化
    addr.sin_family = AF_INET;
    addr.sin_port = htons(8080);
    addr.sin_addr.s_addr = INADDR_ANY;

    if (bind(sockfd, (struct sockaddr*)&addr, sizeof(addr)) == 0) {
        printf("Socket绑定成功\n");
    } else {
        perror("Socket绑定失败\n");
    }

    return 0;
}

三、监听：listen()

在Socket编程中，listen()函数用于将一个已绑定的Socket对象标记为被动状态，以便它可以开始监听传入的连接请求。listen()函数告知操作系统，该Socket将用于接受传入的连接，从而创建一个服务器端的Socket。
listen() 函数定义如下：

#include <sys/types.h>
#include <sys/socket.h>

int listen(int sockfd, int backlog);

sockfd：Socket文件描述符，表示要监听的Socket对象。
backlog：等待连接队列的最大长度。

在调用listen() 函数时，需要提供一个已绑定的Socket对象，并指定等待连接队列的最大长度。等待连接队列是一个存储传入连接请求的缓冲区，如果该队列已满，新的连接请求将被拒绝。

四、请求链接：connect()

当服务器在 listen()的时候，这时候就可以由客户端发起链接请求。在Socket编程中，connect()函数用于建立客户端与服务器之间的连接。通过connect()函数，客户端可以向特定的服务器地址和端口发起连接请求，以便进行数据交换和通信。
以下是connect() 的原型：

#include <sys/types.h>
#include <sys/socket.h>

int connect(int sockfd, const struct sockaddr *addr, socklen_t addrlen);

sockfd：Socket文件描述符，表示要进行连接的Socket对象。
addr：指向struct sockaddr类型的指针，包含要连接的服务器地址信息。
addrlen：addr结构体的大小。

在调用connect() 函数时，需要传递一个struct sockaddr结构体指针作为参数，其中包含要连接的服务器地址信息。具体的地址信息结构体取决于使用的网络协议族，例如struct sockaddr_in用于IPv4地址。
以下是一个连接网络地址的示例：

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

int main() {
    int sockfd = socket(AF_INET, SOCK_STREAM, 0);

    struct sockaddr_in server_addr;
    server_addr.sin_family = AF_INET;
    server_addr.sin_port = htons(8080);
    server_addr.sin_addr.s_addr = inet_addr("127.0.0.1");

    if (connect(sockfd, (struct sockaddr*)&server_addr, sizeof(server_addr)) == 0) {
        printf("成功与服务器建立连接\n");
    } else {
        perror("连接失败");
    }

    return 0;
}

需要注意的是，connect() 函数是一个阻塞调用，它会阻塞当前进程，直到连接建立成功或失败。如果连接成功建立，客户端就可以通过Socket与服务器进行数据交换。

五、接受链接请求：accept()

在Socket编程中，accept()函数用于服务器端接受客户端的连接请求，并创建一个新的Socket对象来与客户端进行通信。accept()函数在服务器端被调用，用于接受传入的连接请求，并返回一个新的Socket文件描述符，以便与客户端进行数据交换。
这里需要格外理解的是，如果在 accept()之前，没有客户端请求 connect()（未决的请求），那么服务端就会阻塞，直到有请求链接 connect()。accept()会创建一个新的 socket，并将这个新的 socket 替换为原来的 socket，这样原来的 socket 就可以一直处在监听状态！

accept()函数的原型如下：

1
2
3

#include <sys/types.h>
#include <sys/socket.h>
int accept(int sockfd, struct sockaddr *addr, socklen_t *addrlen);

sockfd：Socket文件描述符，表示要接受连接请求的Socket对象；
addr：指向struct sockaddr类型的指针，用于存储客户端的地址信息；
addrlen：指向socklen_t类型的指针，用于存储addr结构体的大小。

六、关闭：close()

在Socket编程中，close()函数用于关闭一个打开的Socket连接或文件描述符。在网络编程中，close()函数用于关闭与对方主机的连接或者释放已创建的Socket对象。

close()函数的原型如下：

1 2	`#include <unistd.h> int close(int sockfd);`

sockfd：Socket文件描述符或者文件描述符，表示要关闭的连接或文件。

在调用close()函数时，需要提供要关闭的Socket文件描述符或文件的文件描述符。close()函数将关闭指定的连接或文件，并释放相关的资源。

七、一个服务端的例子

这里会展示一个服务端的例子，这个例子给出了基本的创建方式和功能：

#include <errno.h>
#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <sys/socket.h>
#include <sys/un.h>
#include <zconf.h>


#define BACKLOG 5
#define SV_SOCK_PATH "/tmp/us_xfr"
#define BUF_SIZE 100
int main(int argc, char *argv[]) {
    struct sockaddr_un addr;

    int sfd, cfd;
    ssize_t numRead;
    char buf[BUF_SIZE];

    // 创建一个 socket
    sfd = socket(AF_UNIX, SOCK_STREAM, 0);
    if (sfd == -1) {
        perror("socket");
        exit(EXIT_FAILURE);
    }
    // 对这个长度是有规定的
    if (strlen(SV_SOCK_PATH) > sizeof(addr.sun_path) - 1) {
        printf("Server socket path too long: %s", SV_SOCK_PATH);
        exit(EXIT_FAILURE);
    }

    // 删除所有与路径名一致的既有文件，这样才能将 socket 绑定到这个路径名上
    if (remove(SV_SOCK_PATH) == -1 && errno != ENOENT) {
        printf("remove-%s", SV_SOCK_PATH);
        exit(EXIT_FAILURE);
    }

    // 初始化 socket
    memset(&addr, 0, sizeof(struct sockaddr_un));
    addr.sun_family = AF_UNIX;
    strncpy(addr.sun_path, SV_SOCK_PATH, sizeof(addr.sun_path) - 1);

    //将 socket 绑定到该地址上
    if (bind(sfd, (struct sockaddr *)&addr, sizeof(struct sockaddr_un)) == -1) {
        printf("bind");
        exit(EXIT_FAILURE);
    }

    // 将这个 socket 标记为监听 socket。
    if (listen(sfd, BACKLOG) == -1) {
        printf("listen");
        exit(EXIT_FAILURE);
    }

    // 执行一个无限循环来处理进入的客户端请求。每次循环迭代执行下列任务
    for (;;) {
        // 接受一个连接，为该连接获取一个新 socket cfd
        cfd = accept(sfd, NULL, NULL);
        if (cfd == -1) {
            printf("accept");
            exit(EXIT_FAILURE);
        }

        //从已连接的 socket 中读取所有数据并将这些数据写入到标准输出中
        while ((numRead = read(cfd, buf, BUF_SIZE)) > 0)

            if (write(STDOUT_FILENO, buf, numRead) != numRead) {
                printf("partial/failed write");
                exit(EXIT_FAILURE);
            }

        if (numRead == -1) {
            printf("read");
            exit(EXIT_FAILURE);
        }

        // 关闭已连接的 socket cfd
        if (close(cfd) == -1) {
            printf("close");
            exit(EXIT_FAILURE);
        }
    }
}

这里需要注意的是：服务端在处理字符的时候，用了系统调用 read()和 write()，其中 read()从 cfd 中读取了某些字符存储到 buf 中；而 write()则是将 buff 中的数据写入到STDOUT_FILENO中，STDOUT_FILENO为标准输出，通常用文件描述符 1 表示，标准错误通常用文件描述符 2 表示，标准输入通常用文件描述符 0 表示。

八、一个客户端的例子

// us_xfr.h
#include <errno.h>
#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <sys/socket.h>
#include <sys/un.h>
#include <zconf.h>

#define BACKLOG 5
#define SV_SOCK_PATH "/tmp/us_xfr"
#define BUF_SIZE 100
int main(int argc, char *argv[]) {
    struct sockaddr_un addr;
    int sfd;
    ssize_t numRead;
    char buf[BUF_SIZE];

    sfd = socket(AF_UNIX, SOCK_STREAM, 0); /* Create client socket */
    if (sfd == -1) {
        perror("socket");
        exit(EXIT_FAILURE);
    }
    // 初始化
    memset(&addr, 0, sizeof(struct sockaddr_un));
    addr.sun_family = AF_UNIX;
    strncpy(addr.sun_path, SV_SOCK_PATH, sizeof(addr.sun_path) - 1);

    if (connect(sfd, (struct sockaddr *)&addr, sizeof(struct sockaddr_un)) ==
        -1) {
        perror("connect");
        exit(EXIT_FAILURE);
    }

    /* Copy stdin to socket */
    while ((numRead = read(STDIN_FILENO, buf, BUF_SIZE)) > 0)
        if (write(sfd, buf, numRead) != numRead) {
            printf("partial/failed write");
            exit(EXIT_FAILURE);
        }

    if (numRead == -1) {
        printf("read");
        exit(EXIT_FAILURE);
    }

    exit(EXIT_SUCCESS); /* Closes our socket; server sees EOF */
}

九、启动客户端和服务端，并进行通信

编译，运行服务端：

(base) ***@shenjian Test % gcc 1.c -o server
(base) ***@shenjian Test % gcc 2.c -o client
./server

在另一个窗口运行客户端：

1
2
3

./client
hello

结果在服务端成功地接收到了客户端发来的消息hello:

1 2	`(base) ***@shenjian Test % ./server hello`

这就是一个简单的UDS 例子了，全文完，感谢阅读。

socket Web Unix/Linux

#网络 #服务器 #linux #unix

Unix/Linux编程：UDS 流（Stream）

http://blog.luliang.online/2023/06/07/Unix!Linux编程：UDS 流（Stream）/

作者

Luyoung

发布于

2023年6月7日

许可协议

Unix/Linux编程：UDS 数据报上一篇

Golang框架：cobra 下一篇