如何用C语言实现采用共享内存的进程间通信

Python019

如何用C语言实现采用共享内存的进程间通信,第1张

共享内存的函数有以下几个:

(1)int shmget(key_t key, int size, int shmflg),开辟或使用一块共享内存。

(2)void *shmat(int shmid, const void *shmaddr, int shmflg), 将参数shmid所指向的共享内存与当前进程连接。

当使用某共享内存时,需要先使用shmat,达成连接。

(3)int shmdt(const void *shmaddr),将先前用shmat连接的共享内存与当前进程解除连接。参数shmaddr为shmat返回的共享内存的地址。

在完成对共享内存的使用后,需要使用shmdt解除连接。

(4)int shmctl(int shmid, int cmd, struct shmid_ds *buf),控制内存的操作。当cmd为IPC_RMID时,删除shmid所指的共享内存。

这些函数的表头文件为<sys/ipc.h>和<sys/shm.h>

下面给出一个使用共享内存实现进程间通信的例子:进程A开辟一块新的共享内存,进程B修改这个共享内存,进程C打印输出这个共享内存的内容,进程D删除这个共享内存。

进程BCD运行的命令格式为:命令 共享内存ID,如./output 123432。

进程A代码如下:

int main()

{

int shmid

shmid = shmget(IPC_PRIVATE, SIZE, IPC_CREAT | 0600)

if (shmid <0)

{

perror("shmget error")

exit(1)

}

printf("create shared memory OK. shmid=%d/n", shmid)

return 0

}

进程B代码如下:

int main(int argc, char *argv[])

{

int shmid

char *shmaddr

if (argc != 2)

{

perror("argc error/n")

exit(1)

}

shmid = atoi(argv[1])

shmaddr = (char *)shmat(shmid, NULL, 0)

if ((int )shmaddr == -1)

{

perror("shmat error./n")

exit(1)

}

strcpy(shmaddr, "hello, world!")

shmdt(shmaddr)

return 0

}

进程C代码如下:

int main(int argc, char *argv[])

{

int shmid

char *shmaddr

if (argc != 2)

{

printf("argc error/n")

exit(1)

}

shmid = atoi(argv[1])

shmaddr = (char *)shmat(shmid, NULL, 0)

if ((int )shmaddr == -1)

{

perror("shmat error./n")

exit(1)

}

printf("%s/n", shmaddr)

shmdt(shmaddr)

return 0

}

进程D代码如下:

int main(int argc, char *argv[])

{

int shmid

if (argc != 2)

{

perror("argc error/n")

exit(1)

}

shmid = atoi(argv[1])

shmctl(shmid, IPC_RMID, NULL)

return 0

}

#include <stdio.h>

#include <stdlib.h>

#include <errno.h>

#include <string.h>

#define N 10

#define MAX 100

int child_read_pipe(int fd)

{

char buf[N]

int n = 0

while(1)

{

n = read(fd,buf,sizeof(buf))

buf[n] = '\0'

printf("Read %d bytes : %s.\n",n,buf)

if(strncmp(buf,"quit",4) == 0)

break

}

return 0

}

int father_write_pipe(int fd)

{

char buf[MAX] = {0}

while(1)

{

printf(">")

fgets(buf,sizeof(buf),stdin)

buf[strlen(buf)-1] = '\0'

write(fd,buf,strlen(buf))

usleep(500)

if(strncmp(buf,"quit",4) == 0)

break

}

return 0

}

int main()

{

int pid

int fd[2]

if(pipe(fd) <0)

{

perror("Fail to pipe")

exit(EXIT_FAILURE)

}

if((pid = fork()) <0)

{

perror("Fail to fork")

exit(EXIT_FAILURE)

}else if(pid == 0){

close(fd[1])

child_read_pipe(fd[0])

}else{

close(fd[0])

father_write_pipe(fd[1])

}

exit(EXIT_SUCCESS)

}