linux网络编程之POSIX消息队列和系列函数

一、在前面介绍了system v 消息队列的相关知识,现在来稍微看看posix 消息队列。

其实消息队列就是一个可 以让进程间交换数据的场所,而两个标准的消息队列最大的不同可能只是api 函数的不同,如system v 的系列函数是 msgxxx,而posix 是mq_xxx。posix 消息队列也有一些对消息长度等的限制,man 7 mq_overview:

simba@ubuntu:~/Documents/code/linux_programming/UNP/posix$ cat /proc/sys/fs/mqueue/msg_max

10

simba@ubuntu:~/Documents/code/linux_programming/UNP/posix$ cat /proc/sys/fs/mqueue/msgsize_max

8192

simba@ubuntu:~/Documents/code/linux_programming/UNP/posix$ cat /proc/sys/fs/mqueue/queues_max

256

即一个消息队列最多能有10条消息,每条消息的最大长度为8192字节,一个系统最多能有256个消息队列。

还有一点是,在Linux上,posix 消息队列是以虚拟文件系统实现的,必须将其挂载到某个目录才能看见,如

          # mkdir /dev/mqueue

          # mount -t mqueue none /dev/mqueue

通过cat 命令查看消息队列的状态,假设mymq 是创建的一条消息队列的名字

          $ cat /dev/mqueue/mymq

          QSIZE:129     NOTIFY:2    SIGNO:0    NOTIFY_PID:8260

QSIZE:消息队列所有消息的数据长度

NOTIFY_PID:某个进程使用mq_notify 注册了消息到达异步通知事件,即此进程的pid

NOTIFY:通知方式: 0 is SIGEV_SIGNAL; 1 is SIGEV_NONE; and 2 is SIGEV_THREAD.

SIGNO:当以信号方式通知的时候,表示信号的编 号.

二、系列函数,编译时候加上 -lrt 选项,即连接librt 库 (实时库)

     #include <fcntl.h>           /* For O_* constants */

     #include <sys/stat.h>        /* For mode constants */

     #include <mqueue.h>

功能:用来创建和访问一个消息队列

原型

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

mqd_t mq_open(const char *name, int oflag, mode_t mode, struct mq_attr *attr);

参数

name: 某个消息队列的名字,必须以/打头,并且后续不能有其它/ ,形如/somename长度不能超过NAME_MAX(255)

oflag:与open函数类似,可以是O_RDONLY、O_WRONLY、O_RDWR,还可以按位或上O_CREAT、O_EXCL、O_NONBLOCK;

mode:如果oflag指定了O_CREAT,需要设置mode。

返回值:成功返回消息队列文件描述符;失败返回-1

功能: 关闭消息队列

原型

mqd_t mq_close(mqd_t mqdes);

参数

mqdes : 消息队列描述符

返回值:成功返回0;失败 返回-1

功能:删除消息队列

时间: 2024-09-08 16:14:50

linux网络编程之POSIX消息队列和系列函数的相关文章

linux网络编程之POSIX共享内存和系列函数

在前面介绍了system v 共享内存的相关知识,现在来稍微看看posix 共享内存 和系列函数. 共享内存简单来说 就是一块真正的物理内存区域,可以使用一些函数将这块区域映射到进程的地址空间进行读写,而posix 共享内存与system v 共享内存不同的是它是用虚拟文件系统(tmpfs)实现的,已经挂载在/dev/shm 下面.man 7 shm_overview 下面 来看系列函数,编译时候加上 -lrt 选项,即连接librt 库 (实时库) 功能:用来创建或打开一个共享内存对象 原型

linux网络编程之posix 线程(三)

posix 信号量与互斥锁 示例生产者--消费者问题 一.posix 信号量 信号量的概念参见这里(http://www.bianceng.cn/OS/Linux/201308/37243.htm).前面也讲过system v 信号量,现在来说说posix 信号量. system v 信号量只能用于进程间同步,而posix 信号量除了可以进程间同步,还可以线程间同步.system v 信号量每次PV操作可以是N,但Posix 信号量每次PV只能是1.除此之外,posix 信号量还有命名和匿名之分

linux网络编程之posix 线程(一)

pthread 系列函数 和 简单多线程服务器端程序 一.posix 线程概述 我们知道,进程在各自独立的地址空间中运行,进程之间共享数据需要用进程间通信机制,有些情况需要在一个进程中同时执行多个控制流程,这时候线程就派上了用场,比如实现一个图形界面的下载软件,一方面需要和用户交互,等待和处理用户的鼠标键盘事件,另一方面又需要同时下载多个文件,等待和处理从多个网络主机发来的数据,这些任务都需要一个"等待-处理"的循环,可以用多线程实现,一个线程专门负责与用户交互,另外几个线程每个线程负

linux网络编程之posix 线程(四)

posix 条件变量与互斥锁 示例生产者--消费者问题 一.posix 条件变量 一种线程间同步的情形:线程A需要等某个条件成立才能继续往下执行,现在这个条件不成立,线程A就阻塞等待,而线程B在执行过程中使这个条件成立了,就唤醒线程A继续执行. 在pthread库中通过条件变量(Condition Variable)来阻塞等待一个条件,或者唤醒等待这个条件的线程.Condition Variable用pthread_cond_t类型的变量表示,和Mutex的初始化和销毁类似,pthread_co

linux网络编程之posix 线程(二)

线程的属性和 线程特定数据 Thread-specific Data 一.posix 线程属性 POSIX 线程库定义了线程属性对象 pthread_attr_t ,它封装了线程的创建者可以访问和修改的线程属性.主要包括如下属性: 1. 作用域(scope) 2. 栈尺寸(stack size) 3. 栈地址(stack address) 4. 优先级(priority) 5. 分离的状态(detached state) 6. 调度策略和参数(scheduling policy and para

linux 网络编程之TIME_WAIT状态

                                                         Linux 网络编程之TIME_WAIT状态                                                               刚刚开始看TCP socket的4次握手终止流程图的时候,对于最后的TIME_WAIT状态不是很理解.现在在回过头来研究,发现TIME_WAIT状态是一个很微妙状态.之所以设计TIME_WAIT状态的原因有2个原因:

Linux网络编程之UDP Socket程序示例_C 语言

在网络传输协议中,TCP协议提供的是一种可靠的,复杂的,面向连接的数据流(SOCK_STREAM)传输服务,它通过三段式握手过程建立连接.TCP有一种"重传确认"机制,即接收端收到数据后要发出一个肯定确认的信号,发送端如果收到接收端肯定确认的信号,就会继续发送其他的数据,如果没有,它就会重新发送. 相对而言,UDP协议则是一种无连接的,不可靠的数据报(SOCK_DGRAM)传输服务.使用UDP套接口不用建立连接,服务端在调用socket()生成一个套接字并调用bind()绑定端口后就可

linux网络编程之System V信号量(一) 封装一个信号量集操作函数的工具

与消息队列和共享内存一样,信号量集也有自己的数据结构: struct semid_ds { struct ipc_perm sem_perm;  /* Ownership and permissions */ time_t    sem_otime; /* Last semop time */ time_t    sem_ctime; /* Last change time */ unsigned short  sem_nsems; /* No. of semaphores in set */

linux网络编程之System V 共享内存和系列函数

跟消息队列一样,共享内存也有自己的数据结构,如下: struct shmid_ds { struct ipc_perm shm_perm;    /* Ownership and permissions */ size_t     shm_segsz;   /* Size of segment (bytes) */ time_t     shm_atime;   /* Last attach time */ time_t     shm_dtime;   /* Last detach time