IPC通信:Posix消息队列

IPC通信:Posix消息队列

 消息队列可以认为是一个链表。进程(线程)可以往里写消息,也可以从里面取出消息。一个进程可以往某个消息队列里写消息,然后终止,另一个进程随时可以从消息队列里取走这些消息。这里也说明了,消息队列具有随内核的持续性,也就是系统不重启,消息队列永久存在。

创建(并打开)、关闭、删除一个消息队列

  #include <stdio.h>
#include <stdlib.h>
#include <mqueue.h> //头文件
#include <sys/types.h>
#include <sys/stat.h>
#include <unistd.h>
#include <fcntl.h>
#include <errno.h> #define MQ_NAME ("/tmp")
#define MQ_FLAG (O_RDWR | O_CREAT | O_EXCL) // 创建MQ的flag
#define FILE_MODE (S_IRUSR | S_IWUSR | S_IRGRP | S_IROTH) // 设定创建MQ的权限 int main() {
mqd_t posixmq;
int rc = ; /*
21 函数说明:函数创建或打开一个消息队列
22 返回值:成功返回消息队列描述符,失败返回-1,错误原因存于errno中
23 */
posixmq = mq_open(MQ_NAME, MQ_FLAG, FILE_MODE, NULL); if(- == posixmq)
{
perror("创建MQ失败");
exit();
} /*
33 函数说明:关闭一个打开的消息队列,表示本进程不再对该消息队列读写
34 返回值:成功返回0,失败返回-1,错误原因存于errno中
35 */
rc = mq_close(posixmq);
if( != rc)
{
perror("关闭失败");
exit();
} /*
44 函数说明:删除一个消息队列,好比删除一个文件,其他进程再也无法访问
45 返回值:成功返回0,失败返回-1,错误原因存于errno中
46 */
rc = mq_unlink(MQ_NAME);
if( != rc)
{
perror("删除失败");
exit();
} return ;
} 编译并执行: root@linux:/mnt/hgfs/C_libary# gcc -o crtmq crtmq.c
/tmp/ccZ9cTxo.o: In function `main':
crtmq.c:(.text+0x31): undefined reference to `mq_open'
crtmq.c:(.text+0x60): undefined reference to `mq_close'
crtmq.c:(.text+0x8f): undefined reference to `mq_unlink'
collect2: ld returned exit status
因为mq_XXX()函数不是标准库函数,链接时需要指定;库-lrt;
root@linux:/mnt/hgfs/C_libary# gcc -o crtmq crtmq.c -lrt root@linux:/mnt/hgfs/C_libary# ./crtmq
最后程序并没有删除消息队列(消息队列有随内核持续性),如再次执行该程序则会给出错误信息:
root@linux:/mnt/hgfs/C_libary# ./crtmq
创建MQ失败: File exit() 编译这个程序需要注意几点: 、消息队列的名字最好使用“/”打头,并且只有一个“/”的名字。否则可能出现移植性问题;(还需保证在根目录有写权限,为了方便我在root权限下测试)
、创建成功的消息队列不一定能看到,使用一些方法也可以看到,本文不做介绍;   消息队列的名字有如此规定,引用《UNIX网络编程 卷2》的相关描述: mq_open,sem_open,shm_open这三个函数的第一个参数是
一个IPC名字,它可能是某个文件系统中的一个真正存在的路径名,也可能不是。Posix.1是这样描述Posix IPC名字的。
)它必须符合已有的路径名规则(最多由PATH_MAX个字节构成,包括结尾的空字节)
)如果它以斜杠开头,那么对这些函数的不同调用将访问同一个队列,否则效果取决于实现(也就是效果没有标准化)
)名字中的额外的斜杠符的解释由实现定义(同样是没有标准化) 因此,为便于移植起见,Posix IPC名字必须以一个斜杠打头,并且不能再包含任何其他斜杠符。 IPC通信:Posix消息队列读,写 创建消息队列的程序: #include <stdio.h>
#include <stdlib.h>
#include <mqueue.h> //头文件
#include <sys/types.h>
#include <sys/stat.h>
#include <unistd.h>
#include <fcntl.h>
#include <errno.h> #define MQ_NAME ("/tmp")
#define MQ_FLAG (O_RDWR | O_CREAT | O_EXCL) // 创建MQ的flag
#define FILE_MODE (S_IRUSR | S_IWUSR | S_IRGRP | S_IROTH) // 设定创建MQ的权限 int main() {
mqd_t posixmq;
int rc = ; /*
21 函数说明:函数创建或打开一个消息队列
22 返回值:成功返回消息队列描述符,失败返回-1,错误原因存于errno中
23 */
posixmq = mq_open(MQ_NAME, MQ_FLAG, FILE_MODE, NULL); if(- == posixmq)
{
perror("创建MQ失败");
exit();
} /*
33 函数说明:关闭一个打开的消息队列,表示本进程不再对该消息队列读写
34 返回值:成功返回0,失败返回-1,错误原因存于errno中
35 */
rc = mq_close(posixmq);
if( != rc)
{
perror("关闭失败");
exit();
} #if 0
/*
45 函数说明:删除一个消息队列,好比删除一个文件,其他进程再也无法访问
46 返回值:成功返回0,失败返回-1,错误原因存于errno中
47 */
rc = mq_unlink(MQ_NAME);
if( != rc)
{
perror("删除失败");
exit();
} return ;
#endif
} 编译并执行: root@linux:/mnt/hgfs/C_libary# gcc -o crtmq crtmq.c -lrt
root@linux:/mnt/hgfs/C_libary# ./crtmq
程序并没有删除消息队列(消息队列有随内核持续性),如再次执行该程序则会给出错误信息:
root@linux:/mnt/hgfs/C_libary# ./crtmq
创建MQ失败: File exit()
向消息队列写消息的程序: 消息队列的读写主要使用下面两个函数:
/*头文件*/
#include <mqueue.h> /*返回:若成功则为消息中字节数,若出错则为-1 */
int mq_send(mqd_t mqdes, const char *msg_ptr, size_t msg_len, unsigned msg_prio); /*返回:若成功则为0, 若出错则为-1*/
ssize_t mq_receive(mqd_t mqdes, char *msg_ptr, size_t msg_len, unsigned *msg_prio); /*消息队列属性结构体*/
struct mq_attr {
long mq_flags; /* Flags: 0 or O_NONBLOCK */
long mq_maxmsg; /* Max. # of messages on queue */
long mq_msgsize; /* Max. message size (bytes) */
long mq_curmsgs; /* # of messages currently in queue */
}; #include <stdio.h>
#include <stdlib.h>
#include <mqueue.h>
#include <sys/types.h>
#include <sys/stat.h>
#include <unistd.h>
#include <fcntl.h>
#include <errno.h> /*向消息队列发送消息,消息队列名及发送的信息通过参数传递*/
int main(int argc, char *argv[])
{
mqd_t mqd;
char *ptr;
size_t len;
unsigned int prio;
int rc; if(argc != )
{
printf("Usage: sendmq <name> <bytes> <priority>\n");
exit();
} len = atoi(argv[]);
prio = atoi(argv[]); //只写模式找开消息队列
mqd = mq_open(argv[], O_WRONLY);
if(- == mqd)
{
perror("打开消息队列失败");
exit();
} // 动态申请一块内存
ptr = (char *) calloc(len, sizeof(char));
if(NULL == ptr)
{
perror("申请内存失败");
mq_close(mqd);
exit();
} /*向消息队列写入消息,如消息队列满则阻塞,直到消息队列有空闲时再写入*/
rc = mq_send(mqd, ptr, len, prio);
if(rc < )
{
perror("写入消息队列失败");
mq_close(mqd);
exit();
} // 释放内存
free(ptr);
return ;
} 编译并执行: root@linux:/mnt/hgfs/C_libary# gcc -o sendmq sendmq.c -lrt
root@linux:/mnt/hgfs/C_libary# ./sendmq /tmp
root@linux:/mnt/hgfs/C_libary# ./sendmq /tmp
root@linux:/mnt/hgfs/C_libary# ./sendmq /tmp
root@linux:/mnt/hgfs/C_libary# ./sendmq /tmp
  上面先后向消息队列“/tmp”写入了四条消息,因为先前创建的消息队列只允许存放3条消息,本次第四次写入时程序会阻塞。直到有另外进程从消息队列取走消息后本次写入才成功返回。 读消息队列: #include <stdio.h>
#include <stdlib.h>
#include <mqueue.h>
#include <sys/types.h>
#include <sys/stat.h>
#include <unistd.h>
#include <fcntl.h>
#include <errno.h> /*读取某消息队列,消息队列名通过参数传递*/
int main(int argc, char *argv[])
{
mqd_t mqd;
struct mq_attr attr;
char *ptr;
unsigned int prio;
size_t n;
int rc; if(argc != )
{
printf("Usage: readmq <name>\n");
exit();
} /*只读模式打开消息队列*/
mqd = mq_open(argv[], O_RDONLY);
if(mqd < )
{
perror("打开消息队列失败");
exit();
} // 取得消息队列属性,根据mq_msgsize动态申请内存
rc = mq_getattr(mqd, &attr);
if(rc < )
{
perror("取得消息队列属性失败");
exit();
} /*动态申请保证能存放单条消息的内存*/
ptr = calloc(attr.mq_msgsize, sizeof(char));
if(NULL == ptr)
{
printf("动态申请内存失败\n");
mq_close(mqd);
exit();
} /*接收一条消息*/
n = mq_receive(mqd, ptr, attr.mq_msgsize, &prio);
if(n < )
{
perror("读取失败");
mq_close(mqd);
free(ptr);
exit();
} printf("读取 %ld 字节\n 优先级为 %u\n", (long)n, prio);
return ;
} 编译并执行: root@linux:/mnt/hgfs/C_libary# vi readmq.c
root@linux:/mnt/hgfs/C_libary# vi readmq.c
root@linux:/mnt/hgfs/C_libary# gcc -o readmq readmq.c -lrt
root@linux:/mnt/hgfs/C_libary# ./readmq /tmp
读取 字节
优先级为
root@linux:/mnt/hgfs/C_libary# ./readmq /tmp
读取 字节
优先级为
root@linux:/mnt/hgfs/C_libary# ./readmq /tmp
读取 字节
优先级为
root@linux:/mnt/hgfs/C_libary# ./readmq /tmp
读取 字节
优先级为
root@linux:/mnt/hgfs/C_libary# ./readmq /tmp   程序执行五次,第一次执行完,先前阻塞在写处的程序成功返回。第五次执行,因为消息队列已经为空,程序阻塞。直到另外的进程向消息队列写入一条消息。另外,还可以看出Posix消息队列每次读出的都是消息队列中优先级最高的消息。 IPC通信:Posix消息队列的属性设置 Posix消息队列的属性使用如下结构存放:
struct mq_attr
{
long mq_flags; /*阻塞标志位,0为非阻塞(O_NONBLOCK)*/
long mq_maxmsg; /*队列所允许的最大消息条数*/
long mq_msgsize; /*每条消息的最大字节数*/
long mq_curmsgs; /*队列当前的消息条数*/
};
队列可以在创建时由mq_open()函数的第四个参数指定mq_maxmsg,mq_msgsize。 如创建时没有指定则使用默认值,一旦创建,则不可再改变。
队列可以在创建后由mq_setattr()函数设置mq_flags #include <mqueue.h> /*取得消息队列属性,放到mqstat地fh*/
int mq_getattr(mqd_t mqdes, struct mq_attr *mqstat); /*设置消息队列属性,设置值由mqstat提供,原先值写入omqstat*/
int mq_setattr(mqd_t mqdes, const struct mq_attr *mqstat, struct mq_attr *omqstat); 均返回:若成功则为0,若出错为- 程序获取和设置消息队列的默认属性:
#include <stdio.h>
#include <stdlib.h>
#include <mqueue.h>
#include <sys/types.h>
#include <sys/stat.h>
#include <unistd.h>
#include <fcntl.h>
#include <errno.h> #define MQ_NAME ("/tmp")
#define MQ_FLAG (O_RDWR | O_CREAT | O_EXCL) // 创建MQ的flag
#define FILE_MODE (S_IRUSR | S_IWUSR | S_IRGRP | S_IROTH) // 设定创建MQ的权限 int main()
{
mqd_t posixmq;
int rc = ; struct mq_attr mqattr; // 创建默认属性的消息队列
posixmq = mq_open(MQ_NAME, MQ_FLAG, FILE_MODE, NULL);
if(- == posixmq)
{
perror("创建MQ失败");
exit();
} // 获取消息队列的默认属性
rc = mq_getattr(posixmq, &mqattr);
if(- == rc)
{
perror("获取消息队列属性失败");
exit();
} printf("队列阻塞标志位:%ld\n", mqattr.mq_flags);
printf("队列允许最大消息数:%ld\n", mqattr.mq_maxmsg);
printf("队列消息最大字节数:%ld\n", mqattr.mq_msgsize);
printf("队列当前消息条数:%ld\n", mqattr.mq_curmsgs); rc = mq_close(posixmq);
if( != rc)
{
perror("关闭失败");
exit();
} rc = mq_unlink(MQ_NAME);
if( != rc)
{
perror("删除失败");
exit();
}
return ;
} 编译并执行:
root@linux:/mnt/hgfs/C_libary# gcc -o attrmq attrmq.c -lrt
root@linux:/mnt/hgfs/C_libary# ./attrmq
队列阻塞标志位:
队列允许最大消息数:
队列消息最大字节数:
队列当前消息条数:
root@linux:/mnt/hgfs/C_libary# 设置消息队列的属性: #include <stdio.h>
#include <stdlib.h>
#include <mqueue.h>
#include <sys/types.h>
#include <sys/stat.h>
#include <unistd.h>
#include <fcntl.h>
#include <errno.h> #define MQ_NAME ("/tmp")
#define MQ_FLAG (O_RDWR | O_CREAT | O_EXCL) // 创建MQ的flag
#define FILE_MODE (S_IRUSR | S_IWUSR | S_IRGRP | S_IROTH) // 设定创建MQ的权限 int main()
{
mqd_t posixmq;
int rc = ; struct mq_attr mqattr; // 创建默认属性的消息队列
mqattr.mq_maxmsg = ; // 注意不能超过系统最大限制
mqattr.mq_msgsize = ;
//posixmq = mq_open(MQ_NAME, MQ_FLAG, FILE_MODE, NULL);
posixmq = mq_open(MQ_NAME, MQ_FLAG, FILE_MODE, &mqattr); if(- == posixmq)
{
perror("创建MQ失败");
exit();
} mqattr.mq_flags = ;
mq_setattr(posixmq, &mqattr, NULL);// mq_setattr()只关注mq_flags,adw // 获取消息队列的属性
rc = mq_getattr(posixmq, &mqattr);
if(- == rc)
{
perror("获取消息队列属性失败");
exit();
} printf("队列阻塞标志位:%ld\n", mqattr.mq_flags);
printf("队列允许最大消息数:%ld\n", mqattr.mq_maxmsg);
printf("队列消息最大字节数:%ld\n", mqattr.mq_msgsize);
printf("队列当前消息条数:%ld\n", mqattr.mq_curmsgs); rc = mq_close(posixmq);
if( != rc)
{
perror("关闭失败");
exit();
} rc = mq_unlink(MQ_NAME);
if( != rc)
{
perror("删除失败");
exit();
} return ;
}
复制代码
编译运行: 复制代码
root@linux:/mnt/hgfs/C_libary# gcc -o setattrmq setattrmq.c -lrt
root@linux:/mnt/hgfs/C_libary# ./setattrmq
队列阻塞标志位:
队列允许最大消息数:
队列消息最大字节数:
队列当前消息条数:
本文转自:http://blog.csdn.net/liuhongxiangm/article/details/8716232
上一篇:Django 学习 (第四部)


下一篇:UNIX IPC: POSIX 消息队列