• 使用命令?ipcs -q? 查看對應的消息隊列

代碼

• 文件接收者

#include <sys/types.h> #include <stdio.h> #include <unistd.h> #include <string> #include <signal.h> #include <wait.h> #include <sys/msg.h> #include <cstring>#define MAX_TEXT 512 //消息隊列緩沖區的大小struct my_msg_st{long int my_msg_type;char some_text[BUFSIZ]; };int main() {int running = 1;int msgid;struct my_msg_st some_data;long int msg_to_receive = 2;msgid = msgget((key_t)1234,0666|IPC_CREAT);if (msgid == -1){fprintf(stderr,"msgget failed with error:%d\n",errno);exit(1);}while (running){ // printf("Enter some text:"); // some_data.my_msg_type = 1;if (msgrcv(msgid,(void *)&some_data,BUFSIZ,msg_to_receive,0) == -1){fprintf(stderr,"msgrcv failed with error:%d\n",errno);exit(1);}printf("You wrote:%s",some_data.some_text);if (strncmp(some_data.some_text,"end",3)==0){running = 0;}}if (msgctl(msgid,IPC_RMID,0)==-1){fprintf(stderr,"msgctl(IPC_RMID failed\n");exit(1);}return 0; }

• 文件發送者

#include <sys/types.h> #include <stdio.h> #include <unistd.h> #include <string> #include <signal.h> #include <wait.h> #include <sys/msg.h> #include <cstring>#define MAX_TEXT 512 //消息隊列緩沖區的大小struct my_msg_st{long int my_msg_type;char some_text[BUFSIZ]; };int main() {int running = 1;int msgid;struct my_msg_st some_data; // long int msg_to_receive = 2;char buffer[BUFSIZ];msgid = msgget((key_t)1234,0666|IPC_CREAT);if (msgid == -1){fprintf(stderr,"msgget failed with error:%d\n",errno);exit(1);}while (running){printf("Enter some text:");some_data.my_msg_type = 1;fgets(buffer,BUFSIZ,stdin);some_data.my_msg_type = 2;strcpy(some_data.some_text,buffer);if (msgsnd(msgid,(void *)&some_data,MAX_TEXT,0) == -1){fprintf(stderr,"msgsnd failed!\n");exit(1);}if (strncmp(buffer,"end",3)==0){running = 0;}}return 0; }

參考鏈接

• Linux進程間通信（七）：消息隊列 msgget()、msgsend()、msgrcv()、msgctl()

創作挑戰賽新人創作獎勵來咯，堅持創作打卡瓜分現金大獎

總結

以上是生活随笔為你收集整理的Linux进程之间通信 消息队列的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。