posix線程程式設計

八、Posix消息隊列

2011-09-14 19:07:09| 分類： Unix網絡程式設計 |舉報 |字号 訂閱

消息隊列

一、函數

mq_open

頭檔案

mqueue.h；

原型

mqd_t mq_open(const char name, int oflag, …);

函數功能

建立消息隊列；

參數

name ：消息隊列的名字，根據消息隊列的規則，為了更好的可移植性，該名字必須以‘／’開頭，建立一個消息隊列的時候無須路徑，給出名字就好，其存放位置可有自己指定(建立前後都可以)。

oflag：O_RDONLY（隻讀） O_WRONLY（隻寫） O_RDWR（可讀可寫） O_CREAT（建立） O_EXCL （當消息已存在時，傳回EEXIST錯誤到errno中）O_NONBLOCK（設定非阻塞）

mode：在oflag中指定O_CREAT時，此參數是需要的。表示建立消息隊列的權限，S_IRUSR,S_IWUSR,S_IXUSR,S_IRGRP,S_IWGRP,S_IXGRP,S_IROTH,S_IWOTH,S_IXOTH相或組成或者寫成0777(表示rwxrwxrwx)等用八進制表示也可以。

attr：在oflag中指定O_CREAT時，此參數是需要的。存放消息隊列的屬性。其中mq_flags為0，表示阻塞，為O_NONBLOCK為非阻塞。

(這裡可以填寫哪些參數具體看：二、Posix IPC)

傳回值

若建立成功則傳回消息隊列的描述符，否則傳回－1。

mq_close函數

頭檔案

mqueue.h

原型

int mq_close(mqd_t mqdes);

函數功能

關閉已打開的消息隊列，關閉後調用程序不可以再使用該描述符，但其消息隊列并沒有被删除。一個程序終止時，它的所有打開着的消息隊列都關閉，就像調用了mq_close一樣。

參數

mqdes 消息隊列的描述符，即消息隊列建立成功後的傳回值。

傳回值

成功傳回0，失敗傳回-1。

mq_unlink

頭檔案

mqueue.h

原型

int mq_unlink(const char *name);

函數功能

從系統中删除名為name的消息隊列，但删除的隻是我們可以在系統中看見的檔案的名字，但檔案本身并沒有被從磁盤上删除，除非該名稱是檔案的最後一個連結，并且該檔案已關閉，才會将該檔案真正從磁盤上删除。即如果某前該詳細隊列的檔案還在其他程序中打開，那麼不會将其從磁盤上删除，又或者這是最後一個連結，但它還為關閉，即未執行ma_close操作，或打開它的程序為結束就執行mq_unlink，它也不會從磁盤上删除。

參數

name消息隊列的名稱，以‘／’開始。

傳回值

成功傳回0，出錯傳回－1。

mq_getattr

頭檔案

mqueue.h

原型

int mq_getattr(mqd_t mqdes, struct mq_attr *attr);

函數功能

擷取mqdes指的消息隊列的屬性，存放到attr結構體中。

struct mq_attr

{

long int mq_flags;

long int mq_maxmsg;

long int mq_msgsize;

long int mq_curmsgs;

long int __pad[4];

};

參數

mqdes為消息隊列描述符，attr為上面解釋的存放消息隊列屬性的結構體。

傳回值

成功傳回0，失敗傳回－1。

mq_setattr

頭檔案

mqueue.h

原型

int mq_setattr(mqd_t mqdes, const struct mq_attr *attr,

struct mq_attr *oattr);

函數功能

設定消息隊列的屬性，但是隻使用attr結構體中的mq_flags屬性，以設定(O_NONBLOCK)或清除(0)非阻塞标志。該結構體的另外三個屬性被忽略，每個隊列的最大消息數和每個消息的最大位元組數都隻能在建立時設定，目前隊列中的消息數是随傳送消息和讀取消息的操作改變的，隻能讀取不能設定。如果oattr非空，那麼指定隊列的先前屬性(4個)全将傳回到由該指針指向的結構體中。

參數

mqdes 消息隊列的屬性

attr 函數功能解釋中

oattr 函數功能解釋中

傳回值

成功傳回0，失敗傳回－1。

mq_send

頭檔案

mqueue.h

原型

int mq_send(mqd_t mqdes, const char *ptr, size_t len,

unsigned int prio);

函數功能

給描述符mqdes指向的消息隊列發送消息，大小為len，内容存放在ptr中，prio為優先級。

參數

mqdes為要發送消息的消息隊列描述符;

ptr為要發送的資料;

len為消息的長度;

prio為消息的優先級;

傳回值

成功傳回0，失敗傳回－1。

mq_receive

頭檔案

mqueue.h

原型

ssize_t mq_receive(mqd_t mqdes, char *ptr, size_t len,

unsigned int *proip);

函數功能

從描述符mqdes指向的消息隊列中讀取消息存放ptr中。

參數

mqdes為要從中讀取消息的消息隊列的描述符;

ptr為存放接受到的消息的指針;

len為接受的最大長度;

該值不能小于能加到該消息對列上的最大大小，如果len小于該值，就立即傳回EMSGSIZE錯誤。

傳回值

成功傳回讀取消息的内容的位元組數，出錯傳回－1。

mq_notify

頭檔案

mqueue.h;

signal.h;

原型

int mq_notify(mqd_t mqdes, const struct sigevent *notification);

函數功能

為指定隊列建立或删除異步事件通知。

參數

在

include

include

include

include

include

include

include

include

include

include

include

include

include

include