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

Linux 基本语句_13_消息队列

news 2025/9/12 0:03:20

概念：

不同进程能通过消息队列来进行通信，不同进程也能获取或发送特定类型的消息，即选择性的收发消息。

一般一个程序采取子进程发消息，父进程收消息的模式

常用函数功能：

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;
}