晚上在FC4下調(diào)試出了第一個linux程序，成功地運行，有點成就感，雖然這個程序是抄過來.
本程序的功能是利用系統(tǒng)V(Sys V)消息隊列來實現(xiàn)進程間的通信(IPC).
簡單地介紹程序:
用到的一個數(shù)據(jù)結(jié)構(gòu)-------消息，用一個結(jié)構(gòu)體來表示:
struct msgbuf
{
long
mtype;
//
消息的類型
char
mtext[
1
];
//
消息的內(nèi)容，并不是表示只存一個字符
}
;
幾個API:
key_t ftok (char*pathname, char proj)；
它返回與路徑pathname相對應(yīng)的一個鍵值。該函數(shù)不直接對消息隊列操作，但在調(diào)用msgget()來獲得消息隊列描述字前，往往要調(diào)用該函數(shù)。典型用法 key=ftok('.', 'a');
int msgget(key_t key, int msgflg)
參數(shù)key是一個鍵值，由ftok獲得；msgflg參數(shù)是一些標志位。該調(diào)用返回與健值key相對應(yīng)的消息隊列描述字。
在以下兩種情況下，該調(diào)用將創(chuàng)建一個新的消息隊列：
- 如果沒有消息隊列與健值key相對應(yīng)，并且msgflg中包含了IPC_CREAT標志位；
- key參數(shù)為IPC_PRIVATE；
參數(shù)msgflg可以為以下：IPC_CREAT、IPC_EXCL、IPC_NOWAIT或三者的或結(jié)果。
調(diào)用返回：成功返回消息隊列描述字，否則返回-1。
int msgrcv(int msqid, struct msgbuf *msgp, int msgsz, long msgtyp, int msgflg);
該系統(tǒng)調(diào)用從msgid代表的消息隊列中讀取一個消息，并把消息存儲在msgp指向的msgbuf結(jié)構(gòu)中。
msqid為消息隊列描述字；消息返回后存儲在msgp指向的地址，msgsz指定msgbuf的mtext成員的長度（即消息內(nèi)容的長度），msgtyp為請求讀取的消息類型；讀消息標志msgflg可以為以下幾個常值的或：
- IPC_NOWAIT 如果沒有滿足條件的消息，調(diào)用立即返回，此時，errno=ENOMSG
- IPC_EXCEPT 與msgtyp>0配合使用，返回隊列中第一個類型不為msgtyp的消息
- IPC_NOERROR 如果隊列中滿足條件的消息內(nèi)容大于所請求的msgsz字節(jié)，則把該消息截斷，截斷部分將丟失。
msgrcv手冊中詳細給出了消息類型取不同值時(>0; <0; =0)，調(diào)用將返回消息隊列中的哪個消息。
msgrcv()解除阻塞的條件有三個：
- 消息隊列中有了滿足條件的消息；
- msqid代表的消息隊列被刪除；
- 調(diào)用msgrcv（）的進程被信號中斷；
調(diào)用返回：成功返回讀出消息的實際字節(jié)數(shù)，否則返回-1。
int msgsnd(int msqid, struct msgbuf *msgp, int msgsz, int msgflg);
向msgid代表的消息隊列發(fā)送一個消息，即將發(fā)送的消息存儲在msgp指向的msgbuf結(jié)構(gòu)中，消息的大小由msgze指定。
對發(fā)送消息來說，有意義的msgflg標志為IPC_NOWAIT，指明在消息隊列沒有足夠空間容納要發(fā)送的消息時，msgsnd是否等待。造成msgsnd()等待的條件有兩種：
- 當前消息的大小與當前消息隊列中的字節(jié)數(shù)之和超過了消息隊列的總?cè)萘浚?
- 當前消息隊列的消息數(shù)（單位"個"）不小于消息隊列的總?cè)萘浚▎挝?字節(jié)數(shù)"），此時，雖然消息隊列中的消息數(shù)目很多，但基本上都只有一個字節(jié)。
msgsnd()解除阻塞的條件有三個：
- 不滿足上述兩個條件，即消息隊列中有容納該消息的空間；
- msqid代表的消息隊列被刪除；
- 調(diào)用msgsnd（）的進程被信號中斷；
調(diào)用返回：成功返回0，否則返回-1。
int msgctl(int msqid, int cmd, struct msqid_ds *buf);
該系統(tǒng)調(diào)用對由msqid標識的消息隊列執(zhí)行cmd操作，共有三種cmd操作：IPC_STAT、IPC_SET 、IPC_RMID。
- IPC_STAT：該命令用來獲取消息隊列信息，返回的信息存貯在buf指向的msqid結(jié)構(gòu)中；
- IPC_SET：該命令用來設(shè)置消息隊列的屬性，要設(shè)置的屬性存儲在buf指向的msqid結(jié)構(gòu)中；可設(shè)置屬性包括：msg_perm.uid、msg_perm.gid、msg_perm.mode以及msg_qbytes，同時，也影響msg_ctime成員。
- IPC_RMID：刪除msqid標識的消息隊列；
調(diào)用返回：成功返回0，否則返回-1。
#include
<
stdio.h
>
#include
<
stdlib.h
>
#include
<
ctype.h
>
#include
<
sys
/
ipc.h
>
#include
<
sys
/
types.h
>
#include
<
sys
/
msg.h
>
#define
MAX_SEND_SIZE 80
struct
mymsgbuf
{
long
mtype;
char
mtext[MAX_SEND_SIZE];
}
;
void
send_message(
int
qid,
struct
mymsgbuf
*
qbuf,
long
type,
char
*
text);
void
read_message(
int
qid,
struct
mymsgbuf
*
qbuf,
long
type);
void
remove_queue(
int
qid);
void
change_queue_mode(
int
qid,
char
*
mode);
void
usage(
void
);
int
main(
int
argc,
char
*
argv[])
{
key_t key;
int
msgqueue_id;
struct
mymsgbuf qbuf;
if
(
1
==
argc)
usage();
key
=
ftok(
"
.
"
,
'
m
'
);
if
((msgqueue_id
=
msgget(key,IPC_CREAT
|
0660
))
==-
1
)
{
perror(
"
msgget
"
);
exit(
1
);
}
switch
(tolower(argv[
1
][
0
]))
{
case
'
s
'
:send_message(msgqueue_id,(
struct
mymsgbuf
*
)
&
qbuf,
atol(argv[
2
]),argv[
3
]);
break
;
case
'
r
'
:read_message(msgqueue_id,
&
qbuf,atol(argv[
2
]));
break
;
case
'
d
'
:remove_queue(msgqueue_id);
break
;
case
'
m
'
:change_queue_mode(msgqueue_id,argv[
2
]);
break
;
default
:usage();
}
return
0
;
}
void
send_message(
int
qid,
struct
mymsgbuf
*
qbuf,
long
type,
char
*
text)
{
printf(
"
send a message \n
"
);
qbuf
->
mtype
=
type;
strcpy(qbuf
->
mtext,text);
if
((msgsnd(qid,(
struct
msgbuf
*
)qbuf,strlen(qbuf
->
mtext)
+
1
,
0
))
==-
1
)
{
perror(
"
msgsnd
"
);
exit(
1
);
}
}
void
read_message(
int
qid,
struct
mymsgbuf
*
qbuf,
long
type)
{
printf(
"
reading a message.\n
"
);
qbuf
->
mtype
=
type;
msgrcv(qid,(
struct
msgbuf
*
)qbuf,MAX_SEND_SIZE,type,
0
);
printf(
"
Type: %1d Text: %s\n
"
,qbuf
->
mtype,qbuf
->
mtext);
}
void
remove_queue(
int
qid)
{
msgctl(qid,IPC_RMID,
0
);
}
void
change_queue_mode(
int
qid,
char
*
mode)
{
struct
msqid_ds myqueue_ds;
msgctl(qid,IPC_STAT,
&
myqueue_ds);
sscanf(mode,
"
%ho
"
,
&
myqueue_ds.msg_perm.mode);
msgctl(qid,IPC_SET,
&
myqueue_ds);
}
void
usage(
void
)
{
fprintf(stderr,
"
msgtool -A utility for tinkering with msg queue\n
"
);
fprintf(stderr,
"
\nUSAGE:msgtool (s)end <type> <messagetext>\n
"
);
fprintf(stderr,
"
(r)ecv<type>\n
"
);
fprintf(stderr,
"
(d)elete\n
"
);
fprintf(stderr,
"
(m)ode<octal mode>\n
"
);
exit(
1
);
}
以上程序編譯能通過，只是出現(xiàn)了兩個warning
warning:內(nèi)建函數(shù)strcpy不兼容的隱式聲明
warning:內(nèi)建函數(shù)strlen不兼容的隱式聲明
不知是什么原因？是不是gcc版本問題?
還有在寫Makefile后，make時出現(xiàn)一個錯誤提示:
commands commence before first target
解決方法：去掉target的空格(tab鍵)
程序來是http://tldp.org/LDP/lpg/node45.html#SECTION00742640000000000000
API解釋來自http://www.52wg.org/computer/chengxu/200511/computer_98386.html