linux c 本地套接字

Linux C 本地套接字基础概念

本地套接字（Unix Domain Sockets）是一种进程间通信（IPC）机制，允许同一台机器上的进程之间进行通信。与网络套接字不同，本地套接字不涉及网络协议栈，因此它们通常比网络套接字更快且更安全。

类型

流式套接字（SOCK_STREAM）：提供可靠的、面向连接的通信，类似于TCP。
数据报套接字（SOCK_DGRAM）：提供无连接的、不可靠的通信，类似于UDP。

应用场景

进程间通信：在同一台机器上的不同进程之间传递数据。
守护进程与服务通信：例如，Web服务器与日志记录进程之间的通信。
高性能服务器：在需要低延迟和高吞吐量的场景中使用。

示例代码

创建和使用流式本地套接字

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

#define SOCKET_PATH "/tmp/my_socket"

int main() {
    int sockfd;
    struct sockaddr_un addr;
    char buffer[1024];

    // 创建套接字
    if ((sockfd = socket(AF_UNIX, SOCK_STREAM, 0)) == -1) {
        perror("socket");
        exit(EXIT_FAILURE);
    }

    // 绑定地址
    memset(&addr, 0, sizeof(struct sockaddr_un));
    addr.sun_family = AF_UNIX;
    strncpy(addr.sun_path, SOCKET_PATH, sizeof(addr.sun_path) - 1);

    unlink(SOCKET_PATH);
    if (bind(sockfd, (struct sockaddr*)&addr, sizeof(struct sockaddr_un)) == -1) {
        perror("bind");
        close(sockfd);
        exit(EXIT_FAILURE);
    }

    // 监听连接
    if (listen(sockfd, 5) == -1) {
        perror("listen");
        close(sockfd);
        exit(EXIT_FAILURE);
    }

    printf("Waiting for connection...\n");

    int connfd = accept(sockfd, NULL, NULL);
    if (connfd == -1) {
        perror("accept");
        close(sockfd);
        exit(EXIT_FAILURE);
    }

    // 接收数据
    ssize_t numbytes = recv(connfd, buffer, sizeof(buffer), 0);
    if (numbytes == -1) {
        perror("recv");
        close(connfd);
        close(sockfd);
        exit(EXIT_FAILURE);
    }

    buffer[numbytes] = '\0';
    printf("Received message: %s\n", buffer);

    // 关闭连接
    close(connfd);
    close(sockfd);

    return 0;
}

创建和使用数据报本地套接字

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

#define SOCKET_PATH "/tmp/my_udp_socket"

int main() {
    int sockfd;
    struct sockaddr_un addr;
    char buffer[1024];

    // 创建套接字
    if ((sockfd = socket(AF_UNIX, SOCK_DGRAM, 0)) == -1) {
        perror("socket");
        exit(EXIT_FAILURE);
    }

    // 绑定地址
    memset(&addr, 0, sizeof(struct sockaddr_un));
    addr.sun_family = AF_UNIX;
    strncpy(addr.sun_path, SOCKET_PATH, sizeof(addr.sun_path) - 1);

    unlink(SOCKET_PATH);
    if (bind(sockfd, (struct sockaddr*)&addr, sizeof(struct sockaddr_un)) == -1) {
        perror("bind");
        close(sockfd);
        exit(EXIT_FAILURE);
    }

    // 接收数据
    ssize_t numbytes = recvfrom(sockfd, buffer, sizeof(buffer), 0, NULL, NULL);
    if (numbytes == -1) {
        perror("recvfrom");
        close(sockfd);
        exit(EXIT_FAILURE);
    }

    buffer[numbytes] = '\0';
    printf("Received message: %s\n", buffer);

    // 关闭套接字
    close(sockfd);

    return 0;
}