## 標題佇列：先進先出

對資料進行分類（儲存的時候分類） 操作：

1. 建立或者獲取訊息佇列
1. 寫入或者讀取資料
2. 刪除訊息佇列

## 標題建立或者獲取訊息佇列：
#include <sys/types.h>
#include <sys/ipc.h>
#include <sys/msg.h>
int msgget(key_t key, int msgflg);
命令方式檢視訊息佇列：
ipcs -q
功能：
建立或者獲取訊息佇列
引數：
key ： 參考共享記憶體
msgflg： IPC_CREAT|0666
返回值：
成功返回訊息佇列id號
失敗返回-1 並設定error
*
標題寫入或者讀取資料：

## *寫入：
#include <sys/types.h>
#include <sys/ipc.h>
#include <sys/msg.h>
int msgsnd(int msqid, const void *msgp, size_t msgsz, int msgflg);
功能：
往訊息佇列中寫入資料

- 引數：

msqid ：
msgp ： //結構體自已定義
struct msgbuf {
long mtype; /* message type, must be > 0 */
char mtext[1]; /* message data */ 可以 為所欲為
};

- msgsz ： 資料的大小（除去型別） sizeof(struct msgbuf)-sizeof(long)

- msgflg : 0 可阻塞 IPC_NOWAIT不阻塞

返回值：
成功返回0
失敗返回-1 並設定error

## 讀
#include <sys/types.h>
#include <sys/ipc.h>
#include <sys/msg.h>
ssize_t msgrcv(int msqid, void *msgp, size_t msgsz, long msgtyp,int msgflg);
功能：
從訊息佇列中讀取資料
引數：

- msqid ：//參考共享記憶體

- msgp ： struct msgbuf { //結構體自已定義跟寫的一摸一樣
long mtype; /* message type, must be > 0 */
char mtext[1]; /* message data */ //可以 為所欲為 };

- msgsz：資料的大小（除去型別）
sizeof(struct msgbuf)-sizeof(long)

msgtyp：

- 讀取的型別
=0, 整個佇列的第一條資料.
>0, msgtyp型別的第一條資料
<0, 比 |msgtyp| 小的(等於) 最小型別的第一條資料

- msgflg： 0 可阻塞 IPC_NOWAIT不阻塞

- 返回值： 成功返回 資料的位元組數（mtext） 失敗返回-1 並設定error

## 例子
讀的程式碼 msgget_w.c

#include <stdio.h>
#include <sys/types.h>
#include <sys/ipc.h>
#include <stdlib.h>
#include <sys/msg.h>
#include <string.h>

struct msgbuf {
long mtype; /* message type, must be > 0 */ //8
char mtext[100]; /* message data */ //可以 為所欲為 100
};
int main()
{
key_t key =ftok("xx.c",5);
if(key <0){
perror("ftok error");
}
printf("key:%#x\n",key);
//建立或者獲取
int msqid = msgget(key,IPC_CREAT|0666);
if(msqid < 0){
perror("msgget error");
exit(-1);
}
printf("msqid:%d\n",msqid);

///寫入資料
struct msgbuf sm;
sm.mtype = 3;
strcpy(sm.mtext,"yyyyyyy");
int ret =msgsnd(msqid,&sm,sizeof(struct msgbuf)-sizeof(long),0);
if(ret < 0){
perror("msgsnd error");
exit(-1);
}
return 0;
}

 讀 msgget_r.c

#include <stdio.h>
#include <sys/types.h>
#include <sys/ipc.h>
#include <stdlib.h>
#include <sys/msg.h>
#include <string.h>

struct msgbuf {
long mtype; /* message type, must be > 0 */ //8
char mtext[100]; /* message data */ //可以 為所欲為 100
};

int main()
{
key_t key =ftok("xx.c",5);
if(key <0){
perror("ftok error");
}
printf("key:%#x\n",key);

//建立或者獲取訊息佇列
int msqid = msgget(key,IPC_CREAT|0666);
if(msqid<0){
perror("msgget error");
exit(-1);
}
printf("msqid:%d\n",msqid);

///讀取資料
struct msgbuf sm;
int ret = msgrcv(msqid,&sm,sizeof(struct msgbuf)-sizeof(long),-4,0);
if(ret<0){
perror("msgrcv error");
exit(-1);
}
printf("%s\n",sm.mtext);
return 0;
}

2022-05-15 13:50:00