共享内存通过映射同一物理内存实现高效数据交换,适用于大量数据传输;管道则分为匿名和命名两种,前者用于父子进程间单向通信,后者支持无亲缘关系进程通信。
在C++中实现进程间通信(IPC),共享内存和管道(Pipe)是两种高效且常用的方式。它们适用于不同场景,共享内存适合大量数据的快速交换,而管道更适合父子进程间的简单通信。下面分别介绍这两种机制的基本原理与编程方法。
共享内存:跨进程直接访问同一块内存区域
共享内存允许两个或多个进程映射同一段物理内存,从而实现数据的高速共享。在Linux系统下,通常使用
POSIX共享内存
(shm_open + mmap)或
System V共享内存
(shmget)来实现。
使用POSIX共享内存的基本步骤:
使用
shm_open
创建或打开一个命名的共享内存对象
用
ftruncate
设置共享内存大小
调用
mmap
将该对象映射到进程地址空间
读写内存如同操作普通指针
通信结束后调用
munmap
解除映射,并用
shm_unlink
删除共享对象
示例代码片段(服务端创建共享内存):
立即学习
“
C++免费学习笔记(深入)
”;
}
另一个进程可用相同名称打开并读取数据。注意需包含头文件并链接
-lrt
库。
匿名管道:用于有亲缘关系进程间的单向通信
管道分为匿名管道和命名管道。匿名管道常用于父子进程之间,通过
pipe()
系统调用创建一对文件描述符:一个用于读,一个用于写。
使用匿名管道的关键点:
CentOS Linux 7.9.2009
CentOS Linux 7.9.2009是传统CentOS Linux 7的最后主要版本,也是很多企业历史服务器中仍可能遇到的系统版本。它以稳定、兼容RHEL 7生态、文档丰富和软件支持广泛著称,曾长期用于Web服务、数据库、虚拟化节点和企业内部业务系统。不过CentOS Linux 7已于2024年6月30日停止维护,现在继续使用会面临安全补丁缺失风险。该版本更适合旧业务迁移、历史环境恢复或离线兼容性测试。
下载
调用
pipe(int fd[2])
生成读写端
使用
fork()
创建子进程
父进程关闭写端,子进程关闭读端(或相反),形成单向通道
用
read()
和
write()
进行数据传输
示例:父进程向子进程发送消息
}
匿名管道只能单向通信,若需双向通信,可创建两个管道。它简单可靠,但仅限于有亲缘关系的进程。
命名管道(FIFO):支持无亲缘关系进程通信
命名管道是一种特殊文件,存在于文件系统中,不同进程可通过文件路径打开它进行通信。使用
mkfifo()
创建,之后像操作普通文件一样读写。
基本流程:
用
mkfifo("fifo_path", 0666)
创建FIFO文件
一个进程以只读方式打开,另一个以只写方式打开
使用
read/write
进行通信
通信完成后关闭文件并删除FIFO(可选)
命名管道的好处是不依赖fork,任意两个进程只要知道路径就能通信。
基本上就这些。共享内存速度快,适合
大数据
量;管道更简单,适合控制流或小数据传递。选择哪种方式取决于你的具体需求和运行环境。
#include
#include
#include
#include
#include
int main() {
const char* name = "/my_shm";
const size_t size = 4096;
int fd = shm_open(name, O_CREAT | O_RDWR, 0666);
ftruncate(fd, size);
void* ptr = mmap(0, size, PROT_READ | PROT_WRITE, MAP_SHARED, fd, 0);
strcpy((char*)ptr, "Hello from shared memory!");
// 等待其他进程读取...
sleep(2);
munmap(ptr, size);
close(fd);
shm_unlink(name);
return 0;
#include
#include
#include
#include
int main() {
int fd[2];
pipe(fd);
pid_t pid = fork();
if (pid == 0) {
// 子进程:读取数据
close(fd[1]);
char buffer[128];
read(fd[0], buffer, sizeof(buffer));
std::cout << "Child received: " << buffer << std::endl;
close(fd[0]);
} else {
// 父进程:写入数据
close(fd[0]);
const char* msg = "Hello via pipe";
write(fd[1], msg, strlen(msg)+1);
close(fd[1]);
wait(NULL); // 等待子进程结束
}
return 0; 