嵌入式Linux网络编程：UNIX Domain Socket进程间通信（IPC）

---

嵌入式Linux网络编程：UNIX Domain Socket进程间通信（IPC）

【本文代码已在Linux平台验证通过】

---

一、UNIX Domain Socket核心优势

1.1 本地IPC方案对比

特性	UNIX Domain Socket	管道(Pipe)	消息队列(Message Queue)	共享内存(Shared Memory)
跨进程通信	✔️	✔️	✔️	✔️
双向通信	✔️	❌（半双工）	✔️	✔️
支持字节流/数据报	✔️（SOCK_STREAM/DGRAM）	❌	❌	❌
传输效率	★★★★★	★★★	★★★★	★★★★★★
资源占用	低	低	中	高

---

二、UNIX Domain Socket核心原理

2.1 地址结构

struct sockaddr_un {sa_family_t sun_family;        // AF_UNIXchar        sun_path[108];     // 套接字文件路径（如/tmp/my_socket）
};

2.2 通信流程

---

三、UNIX Domain Socket服务端实现

#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <unistd.h>
#include <sys/socket.h>
#include <sys/un.h>#define SOCKET_PATH "/tmp/unix_socket_example"  // 套接字文件路径
#define BUFFER_SIZE 128int main() {int server_fd, client_fd;struct sockaddr_un serv_addr, cli_addr;socklen_t cli_len = sizeof(cli_addr);char buffer[BUFFER_SIZE];// 1. 创建Unix域流式套接字if ((server_fd = socket(AF_UNIX, SOCK_STREAM, 0)) == -1) {perror("socket创建失败");exit(EXIT_FAILURE);}// 2. 配置地址结构memset(&serv_addr, 0, sizeof(serv_addr));serv_addr.sun_family = AF_UNIX;strncpy(serv_addr.sun_path, SOCKET_PATH, sizeof(serv_addr.sun_path)-1);// 3. 确保文件不存在unlink(SOCKET_PATH);// 4. 绑定套接字if (bind(server_fd, (struct sockaddr*)&serv_addr, sizeof(serv_addr)) == -1) {perror("绑定失败");close(server_fd);exit(EXIT_FAILURE);}// 5. 设置监听队列（最大5个等待连接）if (listen(server_fd, 5) == -1) {perror("监听失败");close(server_fd);exit(EXIT_FAILURE);}printf("服务端已启动，等待客户端连接...\n");// 6. 接受客户端连接if ((client_fd = accept(server_fd, (struct sockaddr*)&cli_addr, &cli_len)) == -1) {perror("接受连接失败");close(server_fd);exit(EXIT_FAILURE);}printf("客户端已连接: %s\n", serv_addr.sun_path);// 7. 通信循环while (1) {ssize_t num_bytes = recv(client_fd, buffer, BUFFER_SIZE, 0);if (num_bytes == -1) {perror("接收错误");break;} else if (num_bytes == 0) {printf("客户端断开连接\n");break;}buffer[num_bytes] = '\0';printf("收到消息: %s\n", buffer);// 构造响应char reply[BUFFER_SIZE];snprintf(reply, sizeof(reply), "服务端已接收 %zd 字节", num_bytes);if (send(client_fd, reply, strlen(reply), 0) == -1) {perror("发送失败");break;}}// 8. 清理资源close(client_fd);close(server_fd);unlink(SOCKET_PATH);  // 删除套接字文件return 0;
}

---

四、UNIX Domain Socket客户端实现

#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <unistd.h>
#include <sys/socket.h>
#include <sys/un.h>#define SOCKET_PATH "/tmp/unix_socket_example"
#define BUFFER_SIZE 128int main() {int sockfd;struct sockaddr_un serv_addr;char buffer[BUFFER_SIZE];// 1. 创建套接字if ((sockfd = socket(AF_UNIX, SOCK_STREAM, 0)) == -1) {perror("socket创建失败");exit(EXIT_FAILURE);}// 2. 配置服务端地址memset(&serv_addr, 0, sizeof(serv_addr));serv_addr.sun_family = AF_UNIX;strncpy(serv_addr.sun_path, SOCKET_PATH, sizeof(serv_addr.sun_path)-1);// 3. 连接服务端if (connect(sockfd, (struct sockaddr*)&serv_addr, sizeof(serv_addr)) == -1) {perror("连接失败");close(sockfd);exit(EXIT_FAILURE);}printf("已连接到服务端\n");// 4. 通信循环while (1) {printf("输入消息（输入exit退出）: ");fgets(buffer, BUFFER_SIZE, stdin);buffer[strcspn(buffer, "\n")] = '\0';if (strcmp(buffer, "exit") == 0) break;// 发送数据if (send(sockfd, buffer, strlen(buffer), 0) == -1) {perror("发送失败");break;}// 接收响应ssize_t num_bytes = recv(sockfd, buffer, BUFFER_SIZE, 0);if (num_bytes == -1) {perror("接收失败");break;}buffer[num_bytes] = '\0';printf("服务端响应: %s\n", buffer);}close(sockfd);return 0;
}

---

五、核心API详解

5.1 socket()

int socket(int domain, int type, int protocol);

参数	UNIX Domain Socket专用配置
domain	AF_UNIX（必须）
type	SOCK_STREAM（可靠字节流）或 SOCK_DGRAM（数据报）
protocol	通常填0

5.2 bind()

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

• 关键点：绑定的sun_path需有目录写权限（嵌入式系统常用/tmp或/var/run）

5.3 connect()与accept()

• 连接特性：无需三次握手，内核直接复制路径名

---

六、编译与测试

6.1 编译命令

# 服务端
gcc unix_server.c -o server -Wall -O2# 客户端
gcc unix_client.c -o client -Wall -O2

6.2 运行演示

# 终端1：启动服务端
$ ./server
服务端已启动，等待客户端连接...
客户端已连接: /tmp/unix_socket_example# 终端2：启动客户端
$ ./client
已连接到服务端
输入消息（输入exit退出）: Hello UNIX Socket!
服务端响应: 服务端已接收 15 字节
输入消息（输入exit退出）: exit

---

七、嵌入式场景优化建议

7.1 提升安全性

// 设置套接字文件权限（0600仅允许所有者访问）
chmod(SOCKET_PATH, S_IRUSR | S_IWUSR);

7.2 抽象命名空间

// 使用抽象套接字名（Linux特有）
serv_addr.sun_path[0] = '\0';  // 第一个字符为NULL
strncpy(serv_addr.sun_path+1, "my_abstract_socket", sizeof(serv_addr.sun_path)-2);

7.3 多客户端处理

// 使用epoll实现多路复用
struct epoll_event ev;
epoll_fd = epoll_create1(0);
ev.events = EPOLLIN;
ev.data.fd = server_fd;
epoll_ctl(epoll_fd, EPOLL_CTL_ADD, server_fd, &ev);

---

八、常见问题排查

8.1 连接失败：Permission denied

# 检查套接字文件权限
ls -l /tmp/unix_socket_example
# 解决方案：
sudo chmod 777 /tmp/unix_socket_example

8.2 地址已在使用：Address already in use

# 强制删除残留套接字文件
rm -f /tmp/unix_socket_example

8.3 跨用户通信问题

• 原因：Linux权限系统限制
• 解决：设置用户组权限或使用sudo

---

扩展阅读：
Linux Programmer’s Manual: unix(7) | POSIX IPC 标准 | Linux man-pages

---

通过本文，您可掌握UNIX Domain Socket在嵌入式Linux中的高效IPC实现方法。相比网络套接字，UDS在本地通信场景中性能更优、资源占用更少，非常适用于嵌入式设备的多模块协作！