当前位置：首页 > news >正文

【IO】进程间通信（IPC)练习

news 2025/9/5 17:08:01

1>将课堂代码自己敲熟练

2>使用消息队列实现两个程序的相互通信

htr.c

#include <myhead.h>
//2.自定义消息类型结构体
struct msgbuf
{long mtype;char mtext[1024];
};
//宏定义一个消息的正文大小
#define SIZE (sizeof(struct msgbuf)-sizeof(long))
int main(int argc, const char *argv[])
{//3.创建一个key值key_t key=ftok("/",'k');if(key==-1){perror("ftok error");return -1;}//4.用key创建消息队列int msqid=msgget(key,IPC_CREAT);if(msqid==-1){perror("msgget error");return -1;}printf("msqid = %d\n",msqid);struct msgbuf buf;//1.创建父子进程pid_t pid=fork();if(pid>0){while(1){/*printf("发送信息给绿机类型：");scanf("%ld",&buf.mtype);getchar();*/buf.mtype=1;printf("消息正文：");fgets(buf.mtext,SIZE,stdin);buf.mtext[strlen(buf.mtext)-1]=0;//退出判断if(strcmp(buf.mtext,"quit")==0){break;}msgsnd(msqid,&buf,SIZE,0);}}else if(pid==0){while(1){msgrcv(msqid,&buf,SIZE,2,0);printf("接收信息为：%s\n",buf.mtext);}}return 0;
}

hts.c

#include <myhead.h>
//2.自定义消息类型结构体
struct msgbuf
{long mtype;char mtext[1024];
};//宏定义一个消息的正文大小
#define SIZE (sizeof(struct msgbuf)-sizeof(long))
int main(int argc, const char *argv[])
{//3.创建一个key值key_t key=ftok("/",'k');if(key==-1){perror("ftok error");return -1;}//4.用key创建消息队列int msqid=msgget(key,IPC_CREAT);if(msqid==-1){perror("msgget error");return -1;}printf("msqid = %d\n",msqid);struct msgbuf buf;//1.创建父子进程pid_t pid=fork();if(pid>0){while(1){msgrcv(msqid,&buf,SIZE,1,0);printf("接收信息为：%s\n",buf.mtext);}}else if(pid==0){while(1){/*printf("发送信息给红机类型：");scanf("%ld",&buf.mtype);getchar();*/buf.mtype=2;printf("消息正文：");fgets(buf.mtext,SIZE,stdin);buf.mtext[strlen(buf.mtext)-1]=0;//退出判断if(strcmp(buf.mtext,"quit")==0){break;}msgsnd(msqid,&buf,SIZE,0);}}return 0;
}

3> 使用信号实现非阻塞方式回收僵尸进程练习五遍

(重复内容纯手打）

#include <myhead.h>
void handlar(int signum)
{if(signum==SIGCHLD){while(waitpid(-1,NULL,WNOHANG)>0);}
}int main(int argc, const char *argv[])
{if(signal(SIGCHLD,handlar)==SIG_ERR){perror("signal error");return -1;}for(int i=0;i<10;i++){if(fork()==0){exit(EXIT_SUCCESS);}}return 0;
}/*#include <myhead.h>//3.回收
void handlar(int signum)
{if(signum==SIGCHLD)while(waitpid(-1,NULL,WNOHANG)>0);
}int main(int argc, const char *argv[]){//2.消息绑定if(signal(SIGCHLD,handlar)==SIG_ERR){perror("signal error");return -1;}//1.僵尸进程产生for(int i=0;i<10;i++){if(fork()==0){exit(EXIT_SUCCESS);	}}return 0;}
*/
/*
#include <myhead.h>
void handlar(int signum)
{if(signum==SIGCHLD)while(waitpid(-1,NULL,WNOHANG)>0);
}
int main(int argc, const char *argv[])
{if(signal(SIGCHLD,handlar)==SIG_ERR){perror("signal error");return -1;}for(int i=0;i<9;i++)if(fork()==0)exit(EXIT_SUCCESS);return 0;
}
*/
/*
#include <myhead.h>
void handlar(int signum)
{if(signum==SIGCHLD)while(waitpid(-1,NULL,WNOHANG)>0);
}
int main(int argc, const char *argv[])
{if(signal(SIGCHLD,handlar)==SIG_ERR){perror("signal error");return -1;}for(int i=0;i<10;i++)if(fork()==0)exit(EXIT_SUCCESS);return 0;
}
*/
/*
#include <myhead.h>
void handlar(int signum)
{if(signum==SIGCHLD)while(waitpid(-1,NULL,WNOHANG)>0);
}
int main(int argc, const char *argv[])
{if(signal(SIGCHLD,handlar)==SIG_ERR){ perror("signal error"); return -1;}for(int i=0;i<10;i++)if(fork()==0)exit(EXIT_SUCCESS);return 0;
}
*/

4>思维导图