使用共享内存实现进程与进程通信
要求：循环发送（可获取键盘输入，也可内置消息，间隔1s以上），循环接受，不落下任何消息，不输出空消息，不输出重复消息。
#include <stdio.h>
#include <sys/types.h>
#include <unistd.h>
#include <sys/wait.h>
#include <sys/ipc.h>
#include <sys/shm.h>
#include <string.h>
#include <strings.h>
int main(int argc, char const *argv[])
{
key_t key = ftok("./", 1);
int shmid = shmget(key, 256, IPC_CREAT | 0666);
printf("%d\n", shmid);
pid_t pid;
int i = 0;
for (i = 0; i < 2; i++)
{
pid = fork();
if (pid < 0)
{
perror("fork");
return -1;
}
else if (pid == 0)
{
break;
}
}
if (i == 2)
{
pid_t son_pid;
while (1)
{
son_pid = waitpid(-1, NULL, WNOHANG);
if (son_pid < 0)
{
break;
}
}
}
else if (i == 1)
{
void *str = shmat(shmid, NULL, 0);
char buf[64] = "";
#if 1
//读共享内存（空不读，重复不读）
while (1)
{
if (strcmp((char *)str, "") == 0)
{
continue;
}
else if (strcmp((char *)str, buf) == 0)
{
continue;
}
else
{
printf("%s\n", (char *)str);
strcpy(buf, (char *)str);
if (strstr((char *)str, "9"))
{
shmctl(shmid, IPC_RMID, NULL);
break;
}
}
}
#endif
}
else
{
//每隔1s写共享内存
void *str = shmat(shmid, NULL, 0);
char buf[64] = "";
for (int n = 0; n < 10; n++)
{
sleep(1);
bzero((char *)str, 256);
bzero(buf, sizeof(buf));
sprintf(buf, "第%d个数据", n);
strcpy((char *)str, buf);
}
}
return 0;
}
