1037.html

著名的linux英雄站点的文档打包

mknod("/tmp/MYFIFO",S_IFIFO|0666,0);<br>
<br>
另外，mknod()中的第三个参数只有在创建一个设备文件时才能用到。它包括设备文件的<br>
主设备号和从设备号。<br>
}<br>
}<br>
<br>
<br>
<br>
<br>
<br>
<br>
[目录]<br>
<br>
--------------------------------------------------------------------------------<br>
<br>
<br>
操作FIFO<br>
<br>
FIFO上的I/O操作和正常管道上的I/O操作基本一样，只有一个主要的不同。系统调用open用来在物理上打开一个管道。在半双工的管道中，这是不必要的。因为管道在系统内核中，而不是在一个物理的文件系统中。在我们的例子中，我们将像使用一个文件流一样使用管道，也就是使用fopen()打开管道，使用fclose()关闭它。<br>
请看下面的简单的服务程序进程：<br>
#include&lt;stdio.h&gt;<br>
#include&lt;stdlib.h&gt;<br>
#include&lt;sys/stat.h&gt;<br>
#include&lt;unistd.h&gt;<br>
#include&lt;linux/stat.h&gt;<br>
#defineFIFO_FILE"MYFIFO"<br>
intmain(void)<br>
{<br>
FILE*fp;<br>
charreadbuf[80];<br>
/*CreatetheFIFOifitdoesnotexist*/<br>
umask(0);<br>
mknod(FIFO_FILE,S_IFIFO|0666,0);<br>
while(1)<br>
{<br>
fp=fopen(FIFO_FILE,"r");<br>
fgets(readbuf,80,fp);<br>
printf("Receivedstring:%s
",readbuf);<br>
fclose(fp);<br>
return(0);<br>
因为FIFO管道缺省时有阻塞的函数，所以你可以在后台运行此程序：<br>
$fifoserver&<br>
再来看一下下面的简单的客户端程序：<br>
#include&lt;stdio.h&gt;<br>
#include&lt;stdlib.h&gt;<br>
#defineFIFO_FILE"MYFIFO"<br>
intmain(int argc,char* argv[])<br>
{<br>
FILE*fp;<br>
if(argc!=2){<br>
printf("USAGE:fifoclient[string]
");<br>
exit(1);<br>
}<br>
if((fp=fopen(FIFO_FILE,"w"))==NULL){<br>
perror("fopen");<br>
exit(1);<br>
}<br>
fputs(argv[1],fp);<br>
fclose(fp);<br>
return(0);<br>
}<br>
<br>
<br>
[目录]<br>
<br>
--------------------------------------------------------------------------------<br>
<br>
<br>
阻塞FIFO<br>
<br>
一般情况下，FIFO管道上将会有阻塞的情况发生。也就是说，如果一个FIFO管道打开供读取的话，它将一直阻塞，直到其他的进程打开管道写入信息。这种过程反过来也一样。如果你不需要阻塞函数的话，你可以在系统调用open()中设置O_NONBLOCK标志，这样可以取消缺省的阻塞函数。<br>
<br>
<br>
<br>
[目录]<br>
<br>
--------------------------------------------------------------------------------<br>
<br>
<br>
消息队列<br>
<br>
在UNIX的SystemV版本，AT&T引进了三种新形式的IPC功能（消息队列、信号量、以及共享内存）。但BSD版本的UNIX使用套接口作为主要的IPC形式。linux系统同时支持这两个版本。<br>
<br>
[目录]<br>
<br>
--------------------------------------------------------------------------------<br>
<br>
<br>
msgget()<br>
<br>
系统调用msgget()<br>
如果希望创建一个新的消息队列，或者希望存取一个已经存在的消息队列，你可以使用系统调用msgget()。<br>
<br>
系统调用：msgget();<br>
原型：intmsgget(key_t key,int msgflg);<br>
返回值：如果成功，返回消息队列标识符<br>
如果失败，则返回-1：errno=EACCESS(权限不允许)<br>
EEXIST(队列已经存在，无法创建)<br>
EIDRM(队列标志为删除)<br>
ENOENT(队列不存在)<br>
ENOMEM(创建队列时内存不够)<br>
ENOSPC(超出最大队列限制)<br>
<br>
系统调用msgget()中的第一个参数是关键字值（通常是由ftok()返回的）。然后此关键字值将会和其他已经存在于系统内核中的关键字值比较。这时，打开和存取操作是和参数msgflg中的内容相关的。<br>
IPC_CREAT如果内核中没有此队列，则创建它。<br>
IPC_EXCL当和IPC_CREAT一起使用时，如果队列已经存在，则失败。<br>
<br>
如果单独使用IPC_CREAT，则msgget()要么返回一个新创建的消息队列的标识符，要么返回具有相同关键字值的队列的标识符。如果IPC_EXCL和IPC_CREAT一起使用，则msgget()要么创建一个新的消息队列，要么如果队列已经存在则返回一个失败值-1。IPC_EXCL单独使用是没有用处的。<br>
下面看一个打开和创建一个消息队列的例子：<br>
intopen_queue(key_t keyval)<br>
{<br>
intqid;<br>
if((qid=msgget(keyval,IPC_CREAT|0660))==-1)<br>
{<br>
return(-1);<br>
}<br>
return(qid);<br>
}<br>
<br>
<br>
<br>
<br>
[目录]<br>
<br>
--------------------------------------------------------------------------------<br>
<br>
<br>
msgsnd()<br>
<br>
系统调用msgsnd()<br>
一旦我们得到了队列标识符，我们就可以在队列上执行我们希望的操作了。如果想要往队列中发送一条消息，你可以使用系统调用msgsnd（）：<br>
<br>
系统调用：msgsnd();<br>
原型：intmsgsnd(int msqid,struct msgbuf*msgp,int msgsz,int msgflg);<br>
返回值：如果成功，0。<br>
如果失败，-1：errno=EAGAIN(队列已满，并且使用了IPC_NOWAIT)<br>
EACCES(没有写的权限)<br>
EFAULT(msgp地址无效)<br>
EIDRM（消息队列已经删除)<br>
EINTR(当等待写操作时，收到一个信号)<br>
EINVAL(无效的消息队列标识符，非正数的消息类型，或<br>
者无效的消息长度)<br>
ENOMEM(没有足够的内存复制消息缓冲区)<br>
<br>
系统调用msgsnd()的第一个参数是消息队列标识符，它是由系统调用msgget返回的。第二个参数是msgp，是指向消息缓冲区的指针。参数msgsz中包含的是消息的字节大小，但不包括消息类型的长度（4个字节）。<br>
参数msgflg可以设置为0（此时为忽略此参数），或者使用IPC_NOWAIT。<br>
<br>
如果消息队列已满，那么此消息则不会写入到消息队列中，控制将返回到调用进程中。如果没有指明，调用进程将会挂起，直到消息可以写入到队列中。<br>
下面是一个发送消息的程序：<br>
<br>
intsend_message(int qid,struct mymsgbuf *qbuf)<br>
{<br>
intresult,length;<br>
/*The length is essentially the size of the structure minus sizeof(mtype)*/<br>
length=sizeof(structmymsgbuf)-sizeof(long);<br>
if((result=msgsnd(qid,qbuf,length,0))==-1)<br>
{<br>
return(-1);<br>
}<br>
return(result);<br>
}<br>
<br>
这个小程序试图将存储在缓冲区qbuf中的消息发送到消息队列qid中。下面的程序是结合了上面两个程序的一个完整程序：<br>
<br>
#include&lt;stdio.h&gt;<br>
#include&lt;stdlib.h&gt;<br>
#include&lt;linux/ipc.h&gt;<br>
#include&lt;linux/msg.h&gt;<br>
main()<br>
{<br>
intqid;<br>
key_t msgkey;<br>
struct mymsgbuf{<br>
longmtype;/*Message type*/<br>
intrequest;/*Work request number*/<br>
doublesalary;/*Employee's salary*/<br>
}msg;<br>
/*Generateour IPC key value*/<br>
msgkey=ftok(".",'m');<br>
/*Open/createthequeue*/<br>
if((qid=open_queue(msgkey))==-1){<br>
perror("open_queue");<br>
exit(1);<br>
}<br>
/*Load up the message with a r bitrary test data*/<br>
msg.mtype=1;/*Messagetypemustbeapositivenumber!*/<br>
msg.request=1;/*Dataelement#1*/<br>
msg.salary=1000.00;/*Data element #2(my yearly salary!)*/<br>
/*Bombsaway!*/<br>
if((send_message(qid,&msg))==-1){<br>
perror("send_message");<br>
exit(1);<br>
}<br>
}<br>
在创建和打开消息队列以后，我们将测试数据装入到消息缓冲区中。最后调用send_messag把消息发送到消息队列中。现在在消息队列中有了一条消息，我们可以使用ipcs命令来查看队列的状态。下面讨论如何从队列中获取消息。可以使用系统调用msgrcv()：<br>
<br>
<br>
<br>
[目录]<br>
<br>
--------------------------------------------------------------------------------<br>
<br>
<br>
msgrcv()<br>
<br>
系统调用：msgrcv();<br>
原型：intmsgrcv(intmsqid,structmsgbuf*msgp,intmsgsz,longmtype,intmsgflg);<br>
返回值：如果成功，则返回复制到消息缓冲区的字节数。<br>
如果失败，则返回-1：errno=E2BIG(消息的长度大于msgsz,没有MSG_NOERROR)<br>
EACCES(没有读的权限)<br>
EFAULT(msgp指向的地址是无效的)<br>
EIDRM(队列已经被删除)<br>
EINTR(被信号中断)<br>
EINVAL(msgqid无效,或者msgsz小于0)<br>
ENOMSG(使用IPC_NOWAIT,同时队列中的消息无法满足要求)<br>
很明显，第一个参数用来指定将要读取消息的队列。第二个参数代表要存储消息的消息缓冲区的地址。第三个参数是消息缓冲区的长度，不包括mtype的长度，它可以按照如下的方法计算：<br>
msgsz=sizeof(structmymsgbuf)-sizeof(long);<br>
第四个参数是要从消息队列中读取的消息的类型。如果此参数的值为0，那么队列中最长时间的一条消息将返回，而不论其类型是什么。<br>
如果调用中使用了IPC_NOWAIT作为标志，那么当没有数据可以使用时，调用将把ENOMSG返回到调用进程中。否则，调用进程将会挂起，直到队列中的一条消息满足msgrcv()的参数要求。如果当客户端等待一条消息的时候队列为空，将会返回EIDRM。如果进程在等待消息的过程中捕捉到一个信号，则返回EINTR。<br>
下面就是一个从队列中读取消息的程序：<br>
<br>
intread_message(int qid,long type,struct mymsgbuf*qbuf)<br>
{<br>
intresult,length;<br>
/*The length is essentially the size of the structure minus sizeof(mtype)*/<br>
length=sizeof(structmymsgbuf)-sizeof(long);<br>
if((result=msgrcv(qid,qbuf,length,type,0))==-1)<br>
{<br>
return(-1);<br>
}<br>
return(result);<br>
}<br>
在成功地读取了一条消息以后，队列中的这条消息的入口将被删除。<br>
参数msgflg中的MSG_NOERROR位提供一种额外的用途。如果消息的实际长度大于msgsz，同时使用了MSG_NOERROR，那么消息将会被截断，只有与msgsz长度相等的消息返回。一般情况下，系统调用msgrcv()会返回-1，而这条消息将会继续保存在队列中。我们可以利用这个特点编制一个程序，利用这个程序可以查看消息队列的情况，看看符合我们条件的消息是否已经到来：<br>
<br>
intpeek_message(int qid,long type)<br>
{<br>
intresult,length;<br>
if((result=msgrcv(qid,NULL,0,type,IPC_NOWAIT))==-1)<br>
{<br>
if(errno==E2BIG)<br>
return(TRUE);<br>
}<br>
return(FALSE);<br>
}<br>
在上面的程序中，我们忽略了缓冲区的地址和长度。这样，系统调用将会失败。尽管如此，我们可以检查返回的E2BIG值，它说明符合条件的消息确实存在。<br>
<br>
<br>
<br>
[目录]<br>
<br>
--------------------------------------------------------------------------------<br>
<br>
<br>
msgctl()<br>
<br>
系统调用msgctl()<br>
下面我们继续讨论如何使用一个给定的消息队列的内部数据结构。我们可以使用系统调用msgctl ( )来控制对消息队列的操作。<br>
<br>
系统调用： msgctl( ) ;<br>
调用原型： int msgctl ( int msgqid, int cmd, struct msqid_ds *buf );<br>
返回值： 0 ，如果成功。<br>
- 1，如果失败：errno = EACCES (没有读的权限同时cmd 是IPC_STAT )<br>
EFAULT (buf 指向的地址无效)<br>
EIDRM (在读取中队列被删除)<br>
EINVAL (msgqid无效, 或者msgsz 小于0 )<br>
EPERM (IPC_SET或者IPC_RMID 命令被使用，但调用程序没有写的权限)<br>
下面我们看一下可以使用的几个命令：<br>
IPC_STAT<br>
读取消息队列的数据结构msqid_ds，并将其存储在b u f指定的地址中。<br>
IPC_SET<br>
设置消息队列的数据结构msqid_ds中的ipc_perm元素的值。这个值取自buf参数。<br>
IPC_RMID<br>
从系统内核中移走消息队列。<br>
我们在前面讨论过了消息队列的数据结构(msqid_ds)。系统内核中为系统中的每一个消息队列保存一个此数据结构的实例。通过使用IPC_STAT命令，我们可以得到一个此数据结构的副本。下面的程序就是实现此函数的过程：<br>
<br>
int get_queue_ds( int qid, struct msgqid_ds *qbuf )<br>
{<br>
if( msgctl( qid, IPC_STAT, qbuf) == -1)<br>
{<br>
return(-1);<br>
}<br>
return(0);<br>
}<br>
<br>
如果不能复制内部缓冲区，调用进程将返回-1。如果调用成功，则返回0。缓冲区中应该包括消息队列中的数据结构。<br>
消息队列中的数据结构中唯一可以改动的元素就是ipc_perm。它包括队列的存取权限和关于队列创建者和拥有者的信息。你可以改变用户的id、用户的组id以及消息队列的存取权限。<br>
下面是一个修改队列存取模式的程序：<br>
<br>