基于linux下的高并发服务器开发（第二章）- 2.10 进程间通信简介

**基于Linux下的高并发服务器开发**

**第二章 进程间通信简介**

在高并发服务器开发中，进程间通信（Inter-Process Communication, IPC）是非常重要的概念。它允许不同进程之间共享数据、同步执行等功能，从而提高系统的整体性能和可靠性。在Linux下，IPC有多种实现方式，我们将在本章中介绍其中的一些常见方法。

###2.10.1 进程间通信的类型进程间通信可以分为以下几种类型：

* **共享内存**：允许不同进程访问同一块内存区域。
* **管道**：提供一个单向数据流，允许父进程和子进程之间传递信息。
* **信号**：用于通知进程某个事件的发生。
* **套接字**：允许不同进程或不同机器之间进行通信。

###2.10.2 共享内存共享内存是最基本的一种IPC方式。它允许多个进程访问同一块内存区域，通过共享内存，可以实现进程间的数据交换和同步。在Linux下，共享内存可以使用`shmget()`、`shmat()`和`shmdt()`函数来实现。

**示例代码**

c#include <stdio.h>
#include <stdlib.h>
#include <sys/shm.h>

int main() {
 // 创建共享内存 int shmid = shmget(IPC_PRIVATE,1024, IPC_CREAT |0644);
 if (shmid == -1) {
 perror("shmget");
 exit(1);
 }

 // 附加到进程空间中 void *ptr = shmat(shmid, NULL,0);
 if (ptr == (void *)-1) {
 perror("shmat");
 exit(1);
 }

 // 写数据到共享内存 char *data = ptr;
 strcpy(data, "Hello, World!");

 // 等待其他进程读取数据 sleep(5);

 // 删除共享内存 shmdt(ptr);
 shmctl(shmid, IPC_RMID, NULL);

 return0;
}

c#include <stdio.h>
#include <stdlib.h>
#include <unistd.h>

int main() {
 // 创建管道 int fd[2];
 if (pipe(fd) == -1) {
 perror("pipe");
 exit(1);
 }

 // 写数据到管道 char *data = "Hello, World!";
 write(fd[1], data, strlen(data));

 // 等待其他进程读取数据 sleep(5);

 //读取数据从管道 char buffer[1024];
 read(fd[0], buffer, sizeof(buffer));
 printf("%s
", buffer);

 return0;
}

c#include <stdio.h>
#include <stdlib.h>
#include <signal.h>

void signal_handler(int signum) {
 printf("Received signal %d
", signum);
}

int main() {
 // 注册信号处理函数 signal(SIGINT, signal_handler);

 // 等待信号发生 sleep(5);

 return0;
}

c#include <stdio.h>
#include <stdlib.h>
#include <sys/socket.h>

int main() {
 // 创建套接字 int sock = socket(AF_INET, SOCK_STREAM,0);
 if (sock == -1) {
 perror("socket");
 exit(1);
 }

 // 连接到远程机器 struct sockaddr_in addr;
 addr.sin_family = AF_INET;
 addr.sin_port = htons(8080);
 inet_pton(AF_INET, "127.0.0.1", &addr.sin_addr);
 connect(sock, (struct sockaddr *)&addr, sizeof(addr));

 // 发送数据到远程机器 char *data = "Hello, World!";
 send(sock, data, strlen(data),0);

 return0;
}