国产毛片a精品毛-国产毛片黄片-国产毛片久久国产-国产毛片久久精品-青娱乐极品在线-青娱乐精品

電子工程網(wǎng)

標題: 【武漢華嵌】Linux進程間通信之消息隊列 [打印本頁]

作者: crcrwxy    時間: 2011-11-1 15:00
標題: 【武漢華嵌】Linux進程間通信之消息隊列
作者:武漢華嵌技術部

在linux下有兩種消息隊列,一種是POSIX的消息隊列,另外一種是System V消息隊列。在這里只講System V隊列的使用。System V消息隊列使用消息隊列標識符標識,在某個進程往一個隊列中寫入一個消息之前,不求另外某個進程正在等待該隊列上一個消息的到達。
對于系統(tǒng)中每個消息隊列,內(nèi)核維護一個定義在頭文件中的信息結(jié)構。該結(jié)構如下:
struct msqid_ds{
struct ipc_perm     msg_perm;   /* read_write perms: Section 3.3 */
struct msg         *msg_first;   /* ptr to first message on queue */
struct msg         *msg_last;   /* ptr to last message on queue */
msglen_t          msg_cbytes;  /* current # bytes on queue */


}

消息隊列由內(nèi)核進行維護,我們可以將內(nèi)核中某個選定的消息隊列畫為一個消息鏈表,如下圖所示:
file:///C:/DOCUME~1/jack/LOCALS~1/Temp/msohtml1/01/clip_image001.png
以下都是操作消息隊列的API函數(shù),在這里將對其一一講解。
#include
int msgget(key_t key, into flag);
該函數(shù)在執(zhí)行正常返回時,返回的是一個整數(shù)標識符,其他三個函數(shù)就用它來指代該隊列。該標識符是基于指定的key產(chǎn)生的,而key即可以是ftok的返回值,也可以是常值IPC_PRIVATE。
oflag可以是讀寫權限的值的組合,它還可以與IPC_CREAT或IPC_CREAT|IPC_EXCL按位或。
當創(chuàng)建一個新消息隊列時,msqid_ds結(jié)構的一些成員被初始化。

#include
int msgsnd(int msqid, const void *ptr, size_t length, int flag);
該函數(shù)的第一參數(shù)msqid是由msgget的返回值提供。Ptr是一個結(jié)構指針,該結(jié)構可以如下定義:
struct my_msg{
long types;
char text[MAX_LENGTH];
}
該結(jié)構中的types是這個消息的類型,text這個數(shù)組就是發(fā)送的消息的正文部份。msgsnd的length參數(shù)以字節(jié)為單位指定待發(fā)送消息的長度。如果待發(fā)送消息的結(jié)構如上定義,則length的取值是sizeof(struct my_msg) – sizeof(long)。第四個參數(shù)flag即可以是0,也可以是IPC_NOWAIT。當flag是0時,使得msgsnd調(diào)用阻塞,如果是IPC_NOWAIT,使得msgsnd調(diào)用非阻塞。
  • 使用msgrcv函數(shù)從某個消息隊列中讀出一個消息。
#include
ssize_t smgrcv(int msqid, void *ptr, size_t length, long type, int flag);
其中ptr參數(shù)指定所接收消息的存放位置,和msgsnd一個,該指針指向緊挨在真正的消息數(shù)據(jù)之前返回的長整數(shù)類型字段。Length指定了由ptr指向的緩沖區(qū)中數(shù)據(jù)部分的大小,這是該函數(shù)能返回的最大數(shù)據(jù)量,該長度不包含消息類型占的字節(jié)數(shù)。type指定希望從消息隊列中讀出什么類型的消息,type以下的幾種取值有不同的效果,如下:
⑴、type為0時,則返回隊列中的第一個消息,也就是最早的那個消息。
⑵、type為大于0時,則返回其類型值為type的第一個消息。
⑶、type為小于0時,則返回其類型值小于或等于type參數(shù)的絕對值的消息中類型最小的第一個消息。flag的可能取值同msgsnd一樣,代表著同樣的意思。只不過msgrcv多了一個選擇,那就是MSG_NOERROR,如果設置了該位,當所接收消息的真正數(shù)據(jù)部分大于length參數(shù)時,msgrcv只截短數(shù)據(jù)部分,面不返回錯誤。該函數(shù)成功返回時,msgrcv返回的是所接收消息中數(shù)據(jù)的字節(jié)數(shù)。它不包括消息類型所占有字節(jié)數(shù)。
  • 使用msgctl對消息隊列進行控制。
#include
int msgctl(int msqid, int cmd, struct msqid_ds *buff);
該函數(shù)提供了三個控制命令,分別如下:
IPC_RMID     從系統(tǒng)中刪除由msqid指定的消息隊列,對于該命令,msgctl第三個參
數(shù)被忽略。
IPC_SET       給所指定的消息隊列設置其msqid_ds結(jié)構的幾個成員。
IPC_STAT      給調(diào)用者返回與所指定消息隊列對應的當前msqid_ds結(jié)構。



總結(jié):
  • 消息隊列是由內(nèi)核維護的,也就是說消息隊列是隨內(nèi)核持續(xù)性的。在進程結(jié)束的時候,消息隊列并消失,只有在顯示的刪除消息隊列或者在內(nèi)核自檢的時候,消息隊列才會刪除。


以下是使用消息隊列例子:
  • 發(fā)送進程:
#include
#include
#include
#include
#include
#include

#define MAX_MSG_LENGTH 1024
//自己定義的消息格式
typedef struct msgbuf
{
long types;
char texts[MAX_MSG_LENGTH];
}SYS_MSG;

int main()
{
int msgid;
key_t key;
int retval;
SYS_MSG mybuf;

if((key = ftok("/", 4)) < 0)
{
           perror("ftok");
}

if((msgid = msgget(key, IPC_CREAT|0777)) < 0)
{
           perror("msgget");
}

mybuf.types = 1;
strcpy(mybuf.texts, "hello world");
if((msgsnd(msgid, &mybuf, MAX_MSG_LENGTH, 0)))  //發(fā)送消息類型為1的消息。
{
           perror("msgsnd");
}

mybuf.types = 2;
strcpy(mybuf.texts, "how are you");
if((msgsnd(msgid, &mybuf, MAX_MSG_LENGTH, 0)))  //發(fā)送消息類型為2的消息。
{
           perror("msgsnd");
}

mybuf.types = 3;
strcpy(mybuf.texts, "i'm fine");
if((msgsnd(msgid, &mybuf, MAX_MSG_LENGTH, 0)))  //發(fā)送消息類型為3的消息。
{
           perror("msgsnd");
}

return 0;
}
  • 接收進程:
#include
#include
#include
#include
#include
#include
#include

#define MAX_MSG_LENGTH 5
typedef struct msgbuf
{
long types;
char texts[MAX_MSG_LENGTH];
}SYS_MSG;

int main()
{
int msgid;
key_t key;
int retval;
SYS_MSG mybuf;

if((key = ftok("/", 4)) < 0)
{
           perror("ftok");
}

if((msgid = msgget(key, IPC_CREAT|0777)) < 0)
{
           perror("msgget");
}

while(1)
{
           //輸入想接收的消息類型
           scanf("%ld", &mybuf.types);
           memset(mybuf.texts, 0, MAX_MSG_LENGTH);

           if(0 == mybuf.types)
           {
                    break;
           }

           //接收消息類型為上面輸入的消息類型
           if(( msgrcv(msgid, &mybuf, MAX_MSG_LENGTH, mybuf.types, MSG_NOERROR)) < 0)
           {
                    perror("msgrcv");
           }

           printf("msgrcv : %s\n", mybuf.texts);
}

if(( msgctl(msgid, IPC_RMID, NULL)) < 0)   //從內(nèi)核中刪除消息隊列
{
           perror("msgctl");
}

return 0;
}

更多技術文章敬請關注:武漢華嵌-嵌入式培訓專家,國內(nèi)領先的嵌入式服務機構,
http://www.embedhq.org
作者: crcrwxy    時間: 2013-4-8 14:36
武漢華嵌嵌入式培訓
咨詢QQ:1216677636   
       QQ:572658958
咨詢電話:027-87780211




歡迎光臨 電子工程網(wǎng) (http://m.qingdxww.cn/) Powered by Discuz! X3.4
主站蜘蛛池模板: 日本a视频在线观看| 69国产精品成人无码视频| 国产精品嫩草影院在线观看免费| 日日日夜夜在线视频| 台湾美女古装一级毛片| 四虎www| 日本高清在线视频www色下载| 色婷婷婷丁香亚洲综合不卡| 真人一级一级特黄高清毛片| 美女张开腿让男人桶爽无弹窗| 亚洲国产精品免费线观看视频| 一级黄一片| 天天草天天射| 亚洲欧洲淘宝天堂日本| 国产在线不卡| 亚洲AV永久无码精品澳门| 日韩高清在线日韩大片观看网址 | 日韩欧美亚洲一区二区综合| 欧美在线1| 四虎www成人影院观看| georgielyall装修工| 手机在线亚洲日韩国产| 亚洲无线码一区在线观看| 亚洲艹| 在线亚洲综合| 秋霞最新高清无码鲁丝片| 特片网我不卡| 亚欧美综合| 中国毛片基地| 刘梓晨啪啪啪| 欧洲亚洲视频| 香蕉草莓榴莲向日葵| 亚洲精品国产第1页| 和美女啪啪啪动态图| 亚洲欧美日韩高清| 日韩欧美在线综合| 亚洲国产视频网| 国产爱豆果冻传媒在线观看| 亚洲视频黄| 日本japanese丰满高清成人视| 天天摸日日碰天天看免费|