上海医疗网站备案,无锡企业网站改版,如何加快门户网站建设,微信小程序入驻概念#xff1a;
不同进程能通过消息队列来进行通信#xff0c;不同进程也能获取或发送特定类型的消息#xff0c;即选择性的收发消息。
一般一个程序采取子进程发消息#xff0c;父进程收消息的模式
常用函数功能#xff1a;
fork(); // 创建子进程
struct msgbuf{ …概念
不同进程能通过消息队列来进行通信不同进程也能获取或发送特定类型的消息即选择性的收发消息。
一般一个程序采取子进程发消息父进程收消息的模式
常用函数功能
fork(); // 创建子进程
struct msgbuf{ // 数据协议long mtype; // 数据类型由用户自己定义char buf[N]; // 数据部分
};key ftok(“.”, ‘a’) // 创建键值 第一个参数是路径名通常是一个已经存在的文件或目录的路径名。在这个例子中.表示当前目录也就是代码所在的目录。 第二个参数是一个由用户自定义的字符用于生成键值。在这里它是字符 ‘a’。 这个键值的作用即标识一个消息队列通过键值识别具体的某条消息队列 代码
SndTp1RcvTp2.c
#include stdio.h
#include sys/types.h
#include sys/ipc.h
#include sys/msg.h
#include string.h
#include errno.h
#include signal.h#define N 128
#define SIZE sizeof(struct msgbuf) - sizeof(long)
#define TYPE1 100
#define TYPE2 200struct msgbuf{long mtype;char buf[N];
};int main(){key_t key;if((key ftok(., a)) 0){ // 创建键值 perror(ftok error);return -1;}int msqid;struct msgbuf msg_snd, msg_rcv; // 发送端接收端if((msqid msgget(key, IPC_CREAT|IPC_EXCL|0664)) 0){ // 创建消息队列 存在则报错 出现错误返回-1 if(errno ! EEXIST){ // 若消息不存在 perror(msgget error);return -1; }else{ // 则消息队列存在 直接打开 msqid msgget(key, 0664); } } pid_t pid;pid fork(); // 创建子进程if(pid 0){perror(fork error);return -1;} else if(pid 0){ // 若是子进程 while(1){msg_snd.mtype TYPE1; // 标识信息的符号fgets(msg_snd.buf, N, stdin); // 标准输入 读取用户输入msg_snd.buf[strlen(msg_snd.buf) - 1] \0; // 方便读取msgsnd(msqid, msg_snd, SIZE, 0); // 消息无法发送则阻塞直到可发送为止 if(strncmp(msg_snd.buf, quit, 4) 0){ // 查看用户输入若为quit 则结束父进程 子进程自我结束 kill(getppid(), SIGKILL);break;} } }else{ // 父进程 while(1){msgrcv(msqid, msg_rcv, SIZE, TYPE2, 0); // 只接收 TYPE2 直到等到有符合条件的消息为止 if(strncmp(msg_rcv.buf, quit, 4) 0){kill(pid, SIGKILL);msgctl(msqid, IPC_RMID, NULL); // 删除消息队列 break;}printf(msg_b:%s\n, msg_rcv.buf);}} return 0;
}SndTp2RcvTp1.c
#include stdio.h
#include sys/types.h
#include sys/ipc.h
#include sys/msg.h
#include string.h
#include errno.h
#include signal.h#define N 128
#define SIZE sizeof(struct msgbuf) - sizeof(long)
#define TYPE1 100
#define TYPE2 200struct msgbuf{long mtype;char buf[N];
};int main(){key_t key;if((key ftok(., a)) 0){ // 创建键值 perror(ftok error);return -1;}int msqid;struct msgbuf msg_snd, msg_rcv; // 发送端接收端if((msqid msgget(key, IPC_CREAT|IPC_EXCL|0664)) 0){ // 创建消息队列 存在则报错 出现错误返回-1 if(errno ! EEXIST){ // 若消息不存在 perror(msgget error);return -1; }else{ // 则消息队列存在 直接打开 msqid msgget(key, 0664); } } pid_t pid;pid fork(); // 创建子进程if(pid 0){perror(fork error);return -1;} else if(pid 0){ // 若是子进程 发送方 while(1){msg_snd.mtype TYPE2; // 标识信息的符号fgets(msg_snd.buf, N, stdin); // 标准输入 读取用户输入msg_snd.buf[strlen(msg_snd.buf) - 1] \0; // 方便读取msgsnd(msqid, msg_snd, SIZE, 0); // 消息无法发送则阻塞直到可发送为止 if(strncmp(msg_snd.buf, quit, 4) 0){ // 查看用户输入若为quit 则结束父进程 子进程自我结束 kill(getppid(), SIGKILL);break;} } }else{ // 父进程 接受方 while(1){msgrcv(msqid, msg_rcv, SIZE, TYPE1, 0); // 只接收 TYPE1 直到等到有符合条件的消息为止 if(strncmp(msg_rcv.buf, quit, 4) 0){kill(pid, SIGKILL);msgctl(msqid, IPC_RMID, NULL); // 删除消息队列 break; }printf(msg_a:%s\n, msg_rcv.buf);}}return 0;
}俩个程序各开一个子进程父进程。子进程负责发送信息父进程负责接收信息最终能实现在不同终端通讯发送quit终止通讯
效果
