织梦装修设计网站模板,青海高端网站建设价格,seo技术教学视频,模板网站建设教程视频Linux下的进程通信手段基本上是从Unix平台上的进程通信手段继承而来的。 而对Unix发展做出重大贡献的两大主力ATT的贝尔实验室 以及 BSD#xff08;加州大学伯克利分校的伯克利软件发布中心#xff09;#xff0c; 他们在进程间通信方面的侧重点有所不同#xff1b; 前…Linux下的进程通信手段基本上是从Unix平台上的进程通信手段继承而来的。 而对Unix发展做出重大贡献的两大主力ATT的贝尔实验室 以及 BSD加州大学伯克利分校的伯克利软件发布中心 他们在进程间通信方面的侧重点有所不同 前者对Unix早期的进程间通信手段进行了系统的改进和扩充 形成了“system-V IPC”通信进程局限在单个计算机内同一个设备的不同进程间通讯 而后者则跳过了该限制形成了基于套接字socket的进程间通信机制多用于不同设备的进程间通讯。 Linux则把两者继承了下来所以说Linux才是最成功的既有“system-V IPC”又支持“socket”。
消息队列、共享内存 和 信号量 被统称为 system-V IPCV 是罗马数字5 是 Unix 的ATT 分支的其中一个版本一般习惯称呼他们为 IPC对象这些对象的操作接口都比较类似 在系统中他们都使用一种叫做 key 的键值来唯一标识而且他们都是“持续性”资源——即他们被创建之后 不会因为进程的退出而消失而会持续地存在除非调用特殊的函数或者命令删除他们。
Linux的IPC对象包括消息队列、共享内存和信号量在内核内部使用链表维护 不同的对象使用 IPC标识符 来标识如消息队列标识符 msqid、共享内存标识符 shmid信号量标识符 semid。
对于用户来说内核提供了简洁的接口不同的进程通过 IPC关键字key 即可访问具体的对象。
通过如下命令可以查看系统当前的IPC对象没有使用的情况下可能为空 1. 消息队列的基本概念
消息队列提供了一种从一个进程向另一个进程发送一个数据块的方法。 每个数据块都被认为含有一个类型接收进程可以独立地接收含有不同类型的数据结构。 我们可以通过发送消息来避免命名管道的同步和阻塞问题。 2. 消息队列与信号管道的对比
消息队列与信号的对比 信号承载的信息量少而消息队列可以承载大量自定义的数据。
消息队列与管道的对比 消息队列跟命名管道有不少的相同之处它与命名管道一样消息队列进行通信的进程可以是不相关的进程 同时它们都是通过发送和接收的方式来传递数据的。在命名管道中发送数据用write()接收数据用read() 则在消息队列中发送数据用msgsnd()接收数据用msgrcv()消息队列对每个数据都有一个最大长度的限制。 消息队列也可以独立于发送和接收进程而存在在进程终止时消息队列及其内容并不会被删除。 管道只能承载无格式字节流消息队列提供有格式的字节流可以减少了开发人员的工作量。 具体解释如下 管道是一种进程间通信IPC机制允许一个进程将数据写入管道另一个进程从管道读取数据。管道只能承载无格式的字节流这意味着管道中传输的数据是一个连续的字节序列没有内在的结构或格式信息。开发人员需要自己定义和解析数据的格式这通常会增加额外的编程工作。 无格式字节流的特征 连续字节序列管道中的数据只是简单的字节流没有内在的格式。需要自定义协议开发人员需要设计数据协议确保写入和读取的数据能够被正确解析。例如定义消息的起始和结束标记或者使用固定长度的消息。复杂性对于复杂的通信场景处理数据解析和错误检测的代码会变得复杂。 消息队列也是一种IPC机制但与管道不同的是消息队列提供了有格式的字节流。消息队列将数据组织成独立的消息每条消息都有自己的格式和边界。操作系统或消息队列实现会自动处理消息的边界和格式使得开发人员无需关心数据的分割和解析问题。 有格式字节流的特征 独立消息每条消息都是独立的实体有明确的边界和格式。自动处理消息队列系统会自动管理消息的边界确保发送和接收的是完整的消息。简化开发开发人员可以直接发送和接收完整的消息无需处理字节流的分割和解析减少了开发工作量。 消息队列是面向记录的其中的消息具有特定的格式以及特定的优先级接收程序可以通过消息类型有选择地接收数据 而不是像命名管道中那样只能默认地接收。 消息队列可以实现消息的随机查询消息不一定要以先进先出的顺序接收也可以按消息的类型接收。
消息队列的实现包括创建或打开消息队列、发送消息、接收消息和控制消息队列这4 种操作。 3. 消息队列函数说明
Linux内核提供了一系列函数来使用消息队列 其中创建或打开消息队列使用的函数是msgget()这里创建的消息队列的数量会受到系统可支持的消息队列数量的限制 发送消息使用的函数是msgsnd()函数它把消息发送到已打开的消息队列末尾; 接收消息使用的函数是msgrcv()它把消息从消息队列中取走与FIFO 不同的是这里可以指定取走某一条消息; 最后控制消息队列使用的函数是msgctl()它可以完成多项功能。
3.1. msgget()获取函数
收发消息前需要具体的消息队列对象msgget()函数的作用是创建或获取一个消息队列对象 并返回消息队列标识符。函数原型如下
int msgget(key_t key, int msgflg);
若执行成功返回队列ID失败返回-1。 它的两个输入参数说明如下 key消息队列的关键字值多个进程可以通过它访问同一个消息队列。 例如收发进程都使用同一个键值即可使用同一个消息队列进行通讯。 其中有个特殊值IPC_PRIVATE它用于创建当前进程的私有消息队列。 msgflg表示创建的消息队列的模式标志参数主要有IPC_CREATIPC_EXCL和权限mode 如果是 IPC_CREAT 为真表示如果内核中不存在关键字与key相等的消息队列则新建一个消息队列 如果存在这样的消息队列返回此消息队列的标识符。 而如果为 IPC_CREAT | IPC_EXCL 表示如果内核中不存在键值与key相等的消息队列则新建一个消息队列 如果存在这样的消息队列则报错。 mode指IPC对象存取权限它使用Linux文件的数字权限表示方式如06000666等。 这些参数是可以通过“”运算符联合起来的因为它始终是int类型的参数。如msgflag使用参数 IPC_CREAT | 0666 时表示 创建或返回已经存在的消息队列的标识符且该消息队列的存取权限为0666 即消息的所有者所属组用户其他用户均可对该消息进行读写。 注意 选项 msgflg 是一个位掩码因此 IPC_CREAT、IPC_EXCL 和权限 mode 可以用位或的方式叠加起来 比如: msgget(key, IPC_CREAT | 0666); 表示如果 key 对应的消息队列不存在就创建 且权限指定为 0666若已存在则直接获取消息队列ID此处的0666使用的是Linux文件权限的数字表示方式。 权限只有读和写执行权限是无效的例如 0777 跟 0666 是等价的。 当 key 被指定为 IPC_PRIVATE 时系统会自动产生一个未用的 key 来对应一个新的消息队列对象 这个消息队列一般用于进程内部间的通信。 该函数可能返回以下错误代码 EACCES指定的消息队列已存在但调用进程没有权限访问它 EEXISTkey指定的消息队列已存在而msgflg中同时指定IPC_CREAT和IPC_EXCL标志 ENOENTkey指定的消息队列不存在同时msgflg中没有指定IPC_CREAT标志 ENOMEM需要建立消息队列但内存不足 ENOSPC需要建立消息队列但已达到系统的限制 4. 发送消息与接收消息
4.1. msgsnd()发送函数
这个函数的主要作用就是将消息写入到消息队列俗称发送一个消息。函数原型如下
int msgsnd(int msqid, const void *msgp, size_t msgsz, int msgflg);
参数说明 msqid消息队列标识符。 msgp发送给队列的消息。msgp可以是任何类型的结构体但第一个字段必须为long类型 即表明此发送消息的类型msgrcv()函数则根据此接收消息。msgp定义的参照格式如下
/*msgp定义的参照格式*/
struct s_msg{long type; /* 必须大于0,消息类型 */char mtext[]; /* 消息正文可以是其他任何类型 */
} msgp; msgsz要发送消息的大小不包含消息类型占用的4个字节即mtext的长度。 msgflg如果为0则表示当消息队列满时msgsnd()函数将会阻塞直到消息能写进消息队列 如果为IPC_NOWAIT则表示当消息队列已满的时候msgsnd()函数不等待立即返回 如果为IPC_NOERROR若发送的消息大于size字节则把该消息截断截断部分将被丢弃且不通知发送进程。 返回值如果成功则返回0如果失败则返回-1并且错误原因存于error中。错误代码 EAGAIN参数msgflg设为IPC_NOWAIT而消息队列已满。 EIDRM标识符为msqid的消息队列已被删除。 EACCESS无权限写入消息队列。 EFAULT参数msgp指向无效的内存地址。 EINTR队列已满而处于等待情况下被信号中断。 EINVAL无效的参数msqid、msgsz或参数消息类型type小于0。
msgsnd()为阻塞函数当消息队列容量满或消息个数满会阻塞。若消息队列已被删除则返回EIDRM错误 若被信号中断返回E_INTR错误。
如果设置IPC_NOWAIT消息队列满或个数满时会返回-1并且置EAGAIN错误。
msgsnd()解除阻塞的条件有以下三个条件 消息队列中有容纳该消息的空间。 msqid代表的消息队列被删除。 调用msgsnd函数的进程被信号中断。
4.2. msgrcv()接收函数
msgrcv()函数是从标识符为msqid的消息队列读取消息并将消息存储到msgp中 读取后把此消息从消息队列中删除也就是俗话说的接收消息。函数原型
ssize_t msgrcv(int msqid, void *msgp, size_t msgsz, long msgtyp, int msgflg);
参数说明 msqid消息队列标识符。 msgp存放消息的结构体结构体类型要与msgsnd()函数发送的类型相同。 msgsz要接收消息的大小不包含消息类型占用的4个字节。 msgtyp有多个可选的值如果为0则表示接收第一个消息如果大于0则表示接收类型等于msgtyp的第一个消息 而如果小于0则表示接收类型等于或者小于msgtyp绝对值的第一个消息。 msgflg用于设置接收的处理方式取值情况如下 0: 阻塞式接收消息没有该类型的消息msgrcv函数一直阻塞等待 IPC_NOWAIT若在消息队列中并没有相应类型的消息可以接收则函数立即返回此时错误码为ENOMSG IPC_EXCEPT与msgtype配合使用返回队列中第一个类型不为msgtype的消息 IPC_NOERROR如果队列中满足条件的消息内容大于所请求的size字节则把该消息截断截断部分将被丢弃 返回值msgrcv()函数如果接收消息成功则返回实际读取到的消息数据长度否则返回-1错误原因存于error中。错误代码 E2BIG消息数据长度大于msgsz而msgflag没有设置IPC_NOERROR EIDRM标识符为msqid的消息队列已被删除 EACCESS无权限读取该消息队列 EFAULT参数msgp指向无效的内存地址 ENOMSG参数msgflg设为IPC_NOWAIT而消息队列中无消息可读 EINTR等待读取队列内的消息情况下被信号中断
msgrcv()函数解除阻塞的条件也有三个 消息队列中有了满足条件的消息。 msqid代表的消息队列被删除。 调用msgrcv()函数的进程被信号中断。
4.3. msgctl()操作消息队列
消息队列是可以被用户操作的比如设置或者获取消息队列的相关属性那么可以通过msgctl()函数去处理它。函数原型
int msgctl(int msqid, int cmd, struct msqid_ds *buf);
参数说明 msqid消息队列标识符。 cmd 用于设置使用什么操作命令它的取值有多个 IPC_STAT 获取该 MSG 的信息获取到的信息会储存在结构体 msqid_ds类型的buf中。 IPC_SET 设置消息队列的属性要设置的属性需先存储在结构体msqid_ds类型的buf中 可设置的属性包括msg_perm.uid、msg_perm.gid、msg_perm.mode以及msg_qbytes储存在结构体msqid_ds中。 IPC_RMID 立即删除该 MSG并且唤醒所有阻塞在该 MSG上的进程同时忽略第三个参数。 IPC_INFO 获得关于当前系统中 MSG 的限制值信息。 MSG_INFO 获得关于当前系统中 MSG 的相关资源消耗信息。 MSG_STAT 同 IPC_STAT但 msgid为该消息队列在内核中记录所有消息队列信息的数组的下标 因此通过迭代所有的下标可以获得系统中所有消息队列的相关信息。 buf相关信息结构体缓冲区。 返回值 成功0 出错-1错误原因存于error中错误代码 EACCESS参数cmd为IPC_STAT却无权限读取该消息队列。 EFAULT参数buf指向无效的内存地址。 EIDRM标识符为msqid的消息队列已被删除。 EINVAL无效的参数cmd或msqid。 EPERM参数cmd为IPC_SET或IPC_RMID却无足够的权限执行。
5. 消息队列示例
接下来通过示例来讲解消息队列的使用使用方法一般是:
发送者: 获取消息队列的 ID 将数据放入一个附带有标识的特殊的结构体发送给消息队列。
接收者: 获取消息队列的 ID 将指定标识的消息读出。
当发送者和接收者都不再使用消息队列时及时删除它以释放系统资源。
本次实验主要是两个进程无血缘关系的进程通过消息队列进行消息的传递 一个进程发送消息一个进程接收消息并将其打印出来。
5.1. 发送进程
#include sys/types.h
#include sys/ipc.h
#include sys/msg.h
#include stdio.h
#include stdlib.h
#include unistd.h
#include string.h#define BUFFER_SIZE 512struct message
{long msg_type;char msg_text[BUFFER_SIZE];
};
int main()
{int qid;struct message msg;/*创建消息队列*/if ((qid msgget((key_t)1234, IPC_CREAT|0666)) -1){perror(msgget\n);exit(1);}printf(Open queue %d\n,qid);while(1){printf(Enter some message to the queue:);if ((fgets(msg.msg_text, BUFFER_SIZE, stdin)) NULL){printf(\nGet message end.\n);exit(1);}msg.msg_type getpid();/*添加消息到消息队列*/if ((msgsnd(qid, msg, strlen(msg.msg_text), 0)) 0){perror(\nSend message error.\n);exit(1);}else{printf(Send message.\n);}if (strncmp(msg.msg_text, quit, 4) 0){printf(\nQuit get message.\n);break;}}exit(0);
}
本代码重点说明如下 第22行调用msgget()函数创建/获取了一个key值为1234的消息队列该队列的属性“0666”表示任何人都可读写 创建/获取到的队列ID存储在变量qid中。 第47行调用msgsndb()函数把进程号以及前面用户输入的字符串通过msg结构体添加到前面得到的qid队列中。 第51行若用户发送的消息为quit那么退出循环结束进程。
5.2. 接收进程
接收进程示例如下
#include sys/types.h
#include sys/ipc.h
#include sys/msg.h
#include stdio.h
#include stdlib.h
#include unistd.h
#include string.h#define BUFFER_SIZE 512struct message
{long msg_type;char msg_text[BUFFER_SIZE];
};int main()
{int qid;struct message msg;/*创建消息队列*/if ((qid msgget((key_t)1234, IPC_CREAT|0666)) -1){perror(msgget);exit(1);}printf(Open queue %d\n, qid);do{/*读取消息队列*/memset(msg.msg_text, 0, BUFFER_SIZE);if (msgrcv(qid, (void*)msg, BUFFER_SIZE, 0, 0) 0){perror(msgrcv);exit(1);}printf(The message from process %ld : %s, msg.msg_type, msg.msg_text);} while(strncmp(msg.msg_text, quit, 4));/*从系统内核中删除消息队列 */if ((msgctl(qid, IPC_RMID, NULL)) 0){perror(msgctl);exit(1);}else{printf(Delete msg qid: %d.\n, qid);}exit(0);} 第23行调用msgget()函数创建/获取队列qid。可以注意到此处跟发送进程是完全一样的无论哪个进程先运行 若key值为1234的队列不存在则创建把以实验时两个进程并没有先后启动顺序的要求。 第36行在循环中调用msgrcv()函数接收qid队列的msg结构体消息此处使用阻塞方式接收 若队列中没有消息会停留在本行代码等待。 第47行若前面接收到用户的消息为quit会退出循环在本行代码调用msgctl()删除消息队列并退出本进程。
5.3. 编译及测试
示例代码分别位于配套代码仓库/system_programing/msg/的msg_send及msg_recv目录下 将两个进程编译出来分别运行即可实验现象如下
5.3.1. 发送进程
在发送消息进程运行的时候会提示让你输入要发送的消息随便什么消息都可以的使用回车完成消息的输入。 输入quit或使用CtrlD、CtrlC可结束进程。
# 以下操作在 system_programing/msg/msg_send 代码目录进行
# 编译X86版本程序发送进程
make
# 运行X86版本程序发送进程
./build_x86/msg_send_demo# 输入消息测试
Open queue 98345
Enter some message to the queue:embedfire
Send message.
Enter some message to the queue:test
Send message.
Enter some message to the queue:hello world
Send message.
# 发送quit消息并结束进程
Enter some message to the queue:quit
Send message.Quit get message.
5.3.2.查看消息队列
可以通过 ipcs -q 命令来查看系统中存在的消息队列若以上队列没有关闭它的查看结果如下
# 查询系统当前存在的队列
ipcs -q# 以下为输出
--------- 消息队列 -----------
键 msqid 拥有者 权限 已用字节数 消息
0x000004d2 98345 flyleaf 666 0 0# 可查看到key键值 0x04d2(1234)qid 98345 与进程中创建的一致。
5.3.3. 接收进程
打开一个新终端编译及运行接收消息进程当你从发送消息进程输入消息时按下回车键发送 接收消息进程会打印出你输入的消息若无消息则接收进程会阻塞等待接收到quit消息会退出进程。
# 以下操作在 system_programing/msg/msg_recv 代码目录进行
# 编译X86版本程序发送进程
make
# 运行X86版本程序发送进程
./build_x86/msg_recv_demo# 接收到的消息
Open queue 98345
The message from process 21023 : embedfire
The message from process 21023 : test
The message from process 21023 : hello world
The message from process 21023 : quit
Delete msg qid: 98345. 小提示在本例子中若发送进程不是通过quit消息退出如CtrlC或CtrlD则不会触发接收进程主动删除消息队列 在这种情况下可通过 ipcs -q 命令查看到该消息队列依然存在通过 ipcrm -q [消息队列qid] 即可删除。
