生活随笔
收集整理的這篇文章主要介紹了
Linux进程之间通信 消息队列
小編覺得挺不錯的,現在分享給大家,幫大家做個參考.
代碼
#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进程之间通信 消息队列的全部內容，希望文章能夠幫你解決所遇到的問題。
如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。
