Linux消息隊列

所謂消息隊列就是指一個消息鏈表。

int msgget(key_t, int flag)：創建和打開隊列

int msgsnd(int msqid, struct msgbuf *msgp, size_t msgsz, int flag):發送消息，msgid是消息隊列的id，msgp是消息內容所在的緩沖區，msgsz是消息的大小，msgflg是標志。

int msgrcv(int msqid, struct msgbuf *msgp, size_t msgsz, long msgtyp, int flag):接受消息，msgtyp是期望接收的消息類型。

int msgctl(int msqid, int cmd, struct msqid_ds *buf):控制

1. #include <sys/types.h>
2. #include <sys/ipc.h>
3. #include <sys/msg.h>
4. #include <stdio.h>
5. #include <stdlib.h>
6. #include <unistd.h>
7. #include <string.h>
8. #define BUFSZ 512
9. struct message{ //消息結構體
10. long msg_type;
11. char msg_text[BUFSZ];
12. };
14. int main()
15. {
16. int qid;
17. key_t key;
18. int len;
19. struct message msg;
21. if((key=ftok(".",'a'))==-1) //ftok獲得一個key
22. {
23. perror("ftok");
24. exit(1);
25. }
26. if((qid=msgget(key,IPC_CREAT|0666))==-1){ //創建一個消息隊列
27. perror("msgget");
28. exit(1);
29. }
30. printf("opened queue %d\n",qid);
31. puts("Please enter the message to queue:");
32. if((fgets(msg.msg_text,BUFSZ,stdin))==NULL) // 從標准輸入獲取輸入
33. {
34. puts("no message");
35. exit(1);
36. }
37. msg.msg_type = getpid();
38. len = strlen(msg.msg_text);
39. if((msgsnd(qid,&msg,len,0))<0){ //發送消息
40. perror("message posted");
41. exit(1);
42. }
43. if(msgrcv(qid,&msg,BUFSZ,0,0)<0){ //接收消息
44. perror("msgrcv");
45. exit(1);
46. }
47. printf("message is:%s\n",(&msg)->msg_text);
48. if((msgctl(qid,IPC_RMID,NULL))<0){ //刪除消息
49. perror("msgctl");
50. exit(1);
51. }
52. exit(0);
53. }