目錄

?

?

打開或創建消息隊列

消息隊列的控制

發送消息

舉個栗子

---

?

打開或創建消息隊列

#include <sys/msg.h> int msgget(key_t key, int flag);//返回：成功返回內核中消息隊列的標識ID，出錯返回-1

參數：

key：用戶指定的消息隊列的鍵值；

flag：IPC_CREAT、IPC_EXCL等權限組合；

?

若創建消息隊列，key可指定鍵值，也可將之設置為IPC_PRIVATE。若打開進行查詢，則key不能為0必須是一個非零的值否則是查詢不到的。

?

消息隊列的控制

#include <sys/msg.h> int msgctl(int msgid, int cmd, struct msqid_ds *buf); //返回：成功返回0，出錯返回-1

參數：

msgid：消息隊列ID；

buf：消息隊列屬性指針；

cmd：

? ? ?1.IPC_STAT：獲取消息的屬性，取出隊列msqid_ds結構，并將其存放到uf指向的結構體中；

? ? ?2. IPC_SET：設置屬性；

? ? ?3. IPC_RMID：刪除隊列。

?

發送消息

#include <sys/msg.h> int msgsnd(int msgqid, const void *ptr, size_t nbytes, int flag); //返回值：成功0，出錯-1ptr:struct mymsg{long mytype; //消息類型char mtext[512]; //發送的數據 };

在Linux中，消息的最大長度是4056字節，其中mytype是4字節；

flag：0為阻塞，IPC_NOWAIT為非阻塞；

?

舉個栗子

源碼如下：

#include <string.h> #include <stdio.h> #include <stdlib.h> #include <sys/msg.h>typedef struct{long type; //消息類型int start; //消息數據本身 包括 start 和 endint end; }MSG;int main(int argc, char *argv[]){if(argc < 2){printf("usage: %s key\n", argv[0]);exit(1);}key_t key = atoi(argv[1]);printf("key: %d\n", key);//創建消息隊列int msq_id;if((msq_id = msgget(key, IPC_CREAT | IPC_EXCL | 0777)) < 0){perror("msgget error");}printf("msq id: %d\n", msq_id);//定義要發送的消息MSG m1 = {4, 4, 400};MSG m2 = {2, 2, 200};MSG m3 = {1, 1, 100};//發送消息到消息隊列if(msgsnd(msq_id, &m1, sizeof(MSG) - sizeof(long), IPC_NOWAIT) < 0){perror("msgsnd error");}if(msgsnd(msq_id, &m2, sizeof(MSG) - sizeof(long), IPC_NOWAIT) < 0){perror("msgsnd error");}if(msgsnd(msq_id, &m3, sizeof(MSG) - sizeof(long), IPC_NOWAIT) < 0){perror("msgsnd error");}//發送消息后獲取消息隊列中的消息總數struct msqid_ds ds;if(msgctl(msq_id, IPC_STAT, &ds) < 0){perror("msgctl error");}printf("msg total: %ld\n", ds.msg_qnum);exit(0); }

運行截圖如下：

查看ipc

刪除他！

?

總結

以上是生活随笔為你收集整理的Linux学习笔记-消息队列的打开、创建、控制的全部內容，希望文章能夠幫你解決所遇到的問題。

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