嵌入式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 通信流程

服务端 客户端 socket() bind() listen() socket() connect() accept() send() recv() close() close() 服务端 客户端

三、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专用配置
domainAF_UNIX(必须)
typeSOCK_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在本地通信场景中性能更优、资源占用更少,非常适用于嵌入式设备的多模块协作!

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.rhkb.cn/news/42947.html

如若内容造成侵权/违法违规/事实不符,请联系长河编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

06-SpringBoot3入门-常见注解(简介)

1、Controller ResponseBody Controller是Spring MVC 中的注解&#xff0c;负责处理 HTTP 请求。 ResponseBody是Spring MVC 中的注解&#xff0c;用于直接将方法的返回值作为 HTTP 响应体。 2、RestController RestController Controller ResponseBody 3、RequestMappin…

工作记录 2017-03-10

工作记录 2017-03-10 序号 工作 相关人员 1 修改邮件上的问题。 更新RD服务器。 郝 更新的问题 1、修改了payment detail和patient insurance的health plan的输入方式。 2、new payment detail时&#xff0c;增加了allowable的处理。 3、选择payer的窗体&#xff0c;增…

MySQL数据库和表的操作

#使用数据库 use 数据库名; # 查询当前数据库是哪个数据库 select database(); 查看数据库版本 SELECT VERSION(); 查看当前用户 SELECT USER(); 查看所有用户() SELECT User,Host,Password FROM mysql.user;数据库 MySQL自带数据库&#xff1a; Information_schema: 主要存储…

lxd-dashboard 图形管理LXD/LXC

前言 LXD-WEBGUI是一个完全用AngularJS编写的Web应用程序,无需应用服务器、数据库或其他后端服务支持。只需要简单地托管静态HTML和JavaScript文件,就能立即投入使用。这个项目目前处于测试阶段,提供了直观的用户界面,帮助用户便捷地管理和控制LXD实例。 安装lxd-dashboa…

[GESP202503 C++一级题解]:B4257:图书馆里的老鼠

[GESP202503 C++一级题解]:B4257:图书馆里的老鼠 题目描述 图书馆里有 n n n 本书,不幸的是,还混入了一只老鼠,老鼠每 x x x 小时能啃光一本书,假设老鼠在啃光一本书之前,不会啃另一本。请问 y y y 小时后图书馆里还剩下多少本完整的书。 输入格式 三行,第一行一…

从零构建大语言模型全栈开发指南:第二部分:模型架构设计与实现-2.2.2文本生成逻辑:Top-k采样与温度控制

👉 点击关注不迷路 👉 点击关注不迷路 👉 点击关注不迷路 文章大纲 2.2.2 文本生成逻辑:Top-k采样与温度控制1. 文本生成的核心挑战与数学框架1.1 自回归生成的基本流程2. `Top-k`采样原理与工程实现2.1 数学定义与算法流程2.2 PyTorch实现优化3. 温度控制的数学本质与参…

Unity中实现UI的质感和圆角

质感思路有两种&#xff1a; 一种是玻璃质感的做法&#xff0c;抓取UI后面的图像做模糊&#xff08;build是GrabPass&#xff0c;urp抓图像我有写过在往期文章&#xff09;&#xff0c;这个方式网络上有很多就不写了&#xff1b; 另外一种是使用CubeMap的方式去模拟质感&…

[异步监听事件、异步绑定属性]通过vue的this.$refs.组件.$props和.$on实现异步绑定组件属性和事件监听

child.vue <template><div><el-button type"primary" click.stop"$emit(get, data)">点击传参</el-button></div> </template> <script> export default { name: "child", props: ["data"…

第六届 蓝桥杯 嵌入式 省赛

参考 第六届蓝桥杯嵌入式省赛程序设计题解析&#xff08;基于HAL库&#xff09;_蓝桥杯嵌入式第六届真题-CSDN博客 一、分析功能 RTC 定时 1&#xff09;时间初始化 2&#xff09;定时上报电压时间 ADC测量 采集电位器的输出电压信号。 串行功能 1&#xff09;传送要设置…

为什么要将项目部署到外部tomcat

一、是什么 指将你的Java Web应用程序&#xff08;如WAR包&#xff09;安装并运行在一个独立安装的、位于项目外部的Tomcat服务器上&#xff0c;而不是使用内嵌的或开发环境自带的服务器。 外部Tomcat 指独立安装的Tomcat服务器&#xff08;如从Apache官网下载的Tomcat&#…

企业级全栈开发终极指南:Spring Boot+Vue3+Kubernetes实战,从0到上线高并发系统

简介 本文以电商系统为例,完整呈现从需求分析到上线运维的企业级开发全流程。包含12个关键步骤、30+代码示例、5个架构设计图,以及完整的Docker/Kubernetes部署方案。所有代码均符合企业级规范,可直接用于生产环境。 企业级开发的终极挑战 行业痛点: 90%的开发者在企业级…

蓝桥杯嵌入式赛道复习笔记8(eeprom读写)

原理学习 自己看一下江科大的存储器的读取&#xff0c;原理是一样的。只是使用了IIC原理是不变的 代码 cubeMX的配置 代码 eeprom层代码的书写 #include "eeprom_display.h" uint8_t data; uint8_t eeprom_read(uint8_t addr){I2CStart();I2CSendByte(0xa0);I2…

IP数据报报文格式

一 概述 IP数据报由两部分组成&#xff1a;首部数据部分。首部的前一部分是固定长度&#xff0c;一共20字节大小&#xff0c;是所有IP数据报文必须具有的&#xff1b;固定部分后面是一些可选字段&#xff0c;其长度是可变的。 二 首部固定部分各字段意义 &#xff08;1&…

高光谱工业相机+LED光源系统助力材料分类和异物检测、实现高速在线检测

检测光源包括可见光&#xff0c;如红光、蓝光和绿光以及其他波长的光&#xff0c;如紫外和红外波长&#xff0c;可以选择与检测对象物相应的波长。但由于能够照射的波长较窄&#xff0c;例如受到同色异物混入或多个素材的材质分类等&#xff0c;可能需要使用可照射多种波长的光…

如何快速解决django存储session变量时出现的django.db.utils.DatabaseError错误

我们在学习django进行web编程的时候&#xff0c;有时需要将一些全局变量信息存储在session中&#xff0c;但使用过程中&#xff0c;却发现会引起数据库的报错。通过查看django源码信息&#xff0c;发现其对session信息进行了ORM映射&#xff0c;如果数据库中不存在对应的表信息…

kubeadm部署k8s-1.32版本集群(1个master,1个worker)

使用最新版的kubeadm部署一个最小版的k8s集群&#xff0c;只有一个master和1个worker&#xff0c;这种部署方式&#xff0c;不满足高可用&#xff0c;仅限于本地学习使用&#xff0c;不可以放到生产上用&#xff0c;先看一下文章的目录。 文章目录 1、基本信息1.1、服务器基本…

阀门流量控制系统MATLAB仿真PID

以下是一个基于MATLAB的PID控制仿真程序&#xff0c;用于模拟智能阀门流量控制系统。该程序包含系统模型、PID控制器以及饱和限制处理。 % 石油管道流量PID控制仿真 % 系统参数 valve_min 4; % 阀门最小电流 (mA) valve_max 25; % 阀门最大电流 (mA) max_flow 10…

UE4学习笔记 FPS游戏制作30 显示击杀信息 水平框 UI模板(预制体)

文章目录 一制作单条死亡信息框水平框的使用创建一个水平框添加子元素调整子元素顺序子元素的布局插槽尺寸填充对齐 制作UI 根据队伍&#xff0c;设置文本的名字和颜色声明变量 将变量设置为构造参数根据队伍&#xff0c;设置文本的名字和颜色在构造事件中&#xff0c;获取玩家…

机器学习——LightGBM

LightGBM(light gradient boosting machine&#xff0c;轻量梯度提升机)是对XGBoost进行改进的模型版本&#xff0c;其三者之间的演变关系为&#xff1a;GBDT-》XGBoost-》LightGBM&#xff0c;依次对性能进行优化&#xff0c;尽管XGBoost已经很高效了&#xff0c;但是仍然有缺…

什么是SQL作业

SQL作业是在数据库服务器上按特定时间或间隔自动执行的计划任务或流程&#xff0c;这些作业由Microsoft SQL Server中的SQL Server代理管理&#xff0c;对于自动执行日常任务&#xff08;如数据库系统中的备份、数据导入和报告生成&#xff09;以及确保及时准确地处理和更新数据…