『 Linux 』简要介绍System V IPC 消息队列 && 信号量 ...

祗疼妳一个 · 2024-7-26 04:31:48

消息队列

System V 消息队列是操纵体系所提供的一种进程间通信的方式;
能够使多个进程或线程以队列的方式将数据传入至操纵体系内核所提供的一个消息队列中从而举行进程间通信;
消息队列是一种面向信息而不是面向字节流的一种通信方式;
消息队列的主要特性为:

异步通信
发送者将消息发送至消息队列后可以立刻返回,而接受者可以在任何时间从队列中读取消息;
允许发送者和接受者在时间上举行"解耦合"从而提高体系的机动性和响应性;
队列管理
消息队列在内核中实现,消息按照发送顺序生存在队列中,吸收者可以按照顺序读取这些消息队列;
消息格式
消息被阻止具有头部和数据的结构;
头部一样平常包含消息的类型长度等信息,而数据部门包含现实的消息内容;
访问控制
System V消息队列具有访问控制机制,可通过权限设置控制可访问队列的进程;

进程间通信的方式必须是让差别的进程能够看到同一份资源;
资源的存在情势一样平常可以为:

文件缓冲区
类比于管道;
内存块
类比于共享内存;
队列
此处的队列与用户自界说天生的队列差别,该消息队列由操纵体系内核举行形貌与管理;

消息队列允许差别进程间举行双向通信,即数据流是双向的;

允许差别的进程向内核发送带类型的数据块;
该处的类型用于向差别进程标明哪段消息是由哪个进程发送至哪个进程的;

System V IPC所订定的一些列进程间通信所使用的接口都通过System V标准化界说;
其对应的接口具有相似性,可以闻一知十;
在下令行中查看消息队列使用ipcs -q msqid,删除消息队列则使用ipcrm -q msqid;

System V 消息队列接口介绍

获取/创建一个消息队列
获取/创建一个消息队列通常使用msgget()体系调用接口;
1. NAME
2. msgget - get a System V message queue identifier
4. SYNOPSIS
5. #include <sys/types.h>
6. #include <sys/ipc.h>
7. #include <sys/msg.h>
9. int msgget(key_t key, int msgflg);
11. RETURN VALUE
12. If successful, the return value will be the message queue identifier (a nonnegative integer), otherwise -1 with errno indicating the error.
14. DESCRIPTION
15. The msgget() system call returns the System V message queue identifier associated with the value of the key argument. A new message queue is created if key has the
16. value IPC_PRIVATE or key isn't IPC_PRIVATE, no message queue with the given key key exists, and IPC_CREAT is specified in msgflg.
18. If msgflg specifies both IPC_CREAT and IPC_EXCL and a message queue already exists for key, then msgget() fails with errno set to EEXIST. (This is analogous to the
19. effect of the combination O_CREAT | O_EXCL for open(2).)
复制代码
返回值为int类型,与System V共享内存相同,当该体系调用接口调用成功时将返回一个msqid用于对消息队列的具体操纵;
调用失败时返回-1并设置errno;
调用参数如下:
- key_t key
  与共享内存相同,传入一个key值使多个进程可通过该key值看到同一份资源(消息队列);
  该参数可用户自定或是通过调用体系调用接口ftok()举行传入(ftok()体系调用接口不赘述);
- int msgflg
  该参数用于创建/获取消息队列的具体选项;
  选项分别为O_CREAT,O_EXCL;
  其中单独使用O_CREAT为:创建一个消息队列,若对应key的消息队列存在则返回该消息队列的msqid;
  O_CREAT,O_EXCL同时使用位:创建一个消息队列,若对应key的消息队列存在则返回错误,用来保证所创建的消息队列是全新的;
  O_EXCL不单独使用(无作用);
消息队列的释放/操纵
消息队列的释放/操纵使用体系调用接口msgctl();
1. NAME
2. msgctl - System V message control operations
4. SYNOPSIS
5. #include <sys/types.h>
6. #include <sys/ipc.h>
7. #include <sys/msg.h>
9. int msgctl(int msqid, int cmd, struct msqid_ds *buf);
10. RETURN VALUE
11. On success, IPC_STAT, IPC_SET, and IPC_RMID return 0. A successful IPC_INFO or MSG_INFO operation returns the index of the highest used entry in the kernel's internal
12. array recording information about all message queues. (This information can be used with repeated MSG_STAT operations to obtain information about all queues on the
13. system.) A successful MSG_STAT operation returns the identifier of the queue whose index was given in msqid.
15. On error, -1 is returned with errno indicating the error.
复制代码
调用参数如下:
- int msqid
  该参数为需要具体释放(操纵)消息队列的msqid;
- int cmd
  该参数为向该体系调用接口传入一个需要对该消息队列具体操纵的选项;
  1. IPC_STAT
  2. Copy information from the kernel data structure associated with msqid into the msqid_ds structure pointed to by buf. The caller must have read permission on the
  3. message queue.
  5. IPC_SET
  6. Write the values of some members of the msqid_ds structure pointed to by buf to the kernel data structure associated with this message queue, updating also its
  7. msg_ctime member. The following members of the structure are updated: msg_qbytes, msg_perm.uid, msg_perm.gid, and (the least significant 9 bits of)
  8. msg_perm.mode. The effective UID of the calling process must match the owner (msg_perm.uid) or creator (msg_perm.cuid) of the message queue, or the caller must
  9. be privileged. Appropriate privilege (Linux: the CAP_IPC_RESOURCE capability) is required to raise the msg_qbytes value beyond the system parameter MSGMNB.
  11. IPC_RMID
  12. Immediately remove the message queue, awakening all waiting reader and writer processes (with an error return and errno set to EIDRM). The calling process must
  13. have appropriate privileges or its effective user ID must be either that of the creator or owner of the message queue.
  15. IPC_INFO (Linux-specific)
  16. Returns information about system-wide message queue limits and parameters in the structure pointed to by buf. This structure is of type msginfo (thus, a cast is
  17. required), defined in <sys/msg.h> if the _GNU_SOURCE feature test macro is defined:
  19. MSG_INFO (Linux-specific)
  20. Returns a msginfo structure containing the same information as for IPC_INFO, except that the following fields are returned with information about system
  21. resources consumed by message queues: the msgpool field returns the number of message queues that currently exist on the system; the msgmap field returns the
  22. total number of messages in all queues on the system; and the msgtql field returns the total number of bytes in all messages in all queues on the system.
  24. MSG_STAT (Linux-specific)
  25. Returns a msqid_ds structure as for IPC_STAT. However, the msqid argument is not a queue identifier, but instead an index into the kernel's internal array that
  26. maintains information about all message queues on the system.
  复制代码
  其中释放消息队列时所使用的选项为IPC_RMID;
- struct msqid_ds *buf
  该参数为向该体系调用接口传入该消息队列的内核数据结构,并共同第二个参数对属性举行处置惩罚;
  其中对应的结构属性为:
  1. msgctl() performs the control operation specified by cmd on the System V message queue with identifier msqid.
  3. The msqid_ds data structure is defined in <sys/msg.h> as follows:
  5. struct msqid_ds {
  6. struct ipc_perm msg_perm; /* Ownership and permissions */
  7. time_t msg_stime; /* Time of last msgsnd(2) */
  8. time_t msg_rtime; /* Time of last msgrcv(2) */
  9. time_t msg_ctime; /* Time of last change */
  10. unsigned long __msg_cbytes; /* Current number of bytes in
  11. queue (nonstandard) */
  12. msgqnum_t msg_qnum; /* Current number of messages
  13. in queue */
  14. msglen_t msg_qbytes; /* Maximum number of bytes
  15. allowed in queue */
  16. pid_t msg_lspid; /* PID of last msgsnd(2) */
  17. pid_t msg_lrpid; /* PID of last msgrcv(2) */
  18. };
  20. The ipc_perm structure is defined as follows (the highlighted fields are settable using IPC_SET):
  22. struct ipc_perm {
  23. key_t __key; /* Key supplied to msgget(2) */
  24. uid_t uid; /* Effective UID of owner */
  25. gid_t gid; /* Effective GID of owner */
  26. uid_t cuid; /* Effective UID of creator */
  27. gid_t cgid; /* Effective GID of creator */
  28. unsigned short mode; /* Permissions */
  29. unsigned short __seq; /* Sequence number */
  30. };
  复制代码
  释放消息队列所接纳的IPC_RMID选项不涉及属性,即释放时传入nullptr即可;
向消息队列发送数据
调用体系调用接口msgsnd()向消息队列发送数据;
1. NAME
2. msgrcv, msgsnd - System V message queue operations
4. SYNOPSIS
5. #include <sys/types.h>
6. #include <sys/ipc.h>
7. #include <sys/msg.h>
9. int msgsnd(int msqid, const void *msgp, size_t msgsz, int msgflg);
11. RETURN VALUE
12. On failure both functions return -1 with errno indicating the error, otherwise msgsnd() returns 0 and msgrcv() returns the number of bytes actually copied into the
13. mtext array.
复制代码
调用成功时返回0,调用失败时返回-1;
其对应参数为:
- int msqid
  需要发送的消息队列的msqid;
- const void *msgp
  所发送数据的数据块位置;
  在使用消息队列发送消息时用户需要自界说一个结构体,其类型为struct msgbuf;
  1. struct msgbuf {
  2. // 数据块的类型必须存在且不能为0
  3. long mtype; /* message type, must be > 0 */
  4. // 数据消息的内容可以数组的形式传递
  5. char mtext[1]; /* message data */
  6. };
  复制代码
- size_t msgsz
  所发送数据的数据块大小;
- int msgflg
  设置发送的方式,一样平常为壅闭发送与非壅闭发送;
  1. IPC_NOWAIT
  2. Return immediately if no message of the requested type is in the queue. The system call fails with errno set to ENOMSG.
  4. MSG_EXCEPT
  5. Used with msgtyp greater than 0 to read the first message in the queue with message type that differs from msgtyp.
  7. MSG_NOERROR
  8. To truncate the message text if longer than msgsz bytes.
  复制代码
从消息队列中读取数据
调用体系调用接口msgrcv()从消息队列中读取数据;
2. NAME
3. msgrcv, msgsnd - System V message queue operations
5. SYNOPSIS
6. #include <sys/types.h>
7. #include <sys/ipc.h>
8. #include <sys/msg.h>
10. ssize_t msgrcv(int msqid, void *msgp, size_t msgsz, long msgtyp,
11. int msgflg);
12. RETURN VALUE
13. On failure both functions return -1 with errno indicating the error, otherwise msgsnd() returns 0 and msgrcv() returns the number of bytes actually copied into the
14. mtext array.
复制代码
调用成功返回0,失败返回-1;
调用参数:
- int msqid
  读取的消息队列的msqid;
- void* msgp
  消息队列的缓冲区(同上以struct msgbuf的情势存在);
- size_t msgsz
  需要读取的大小;
- long msgtyp
  所读数据的类型;
- int msgflg
  所读数据的方式(壅闭,非壅闭等);

System V IPC 在内核数据结构中的管理

组织方式
System V IPC进程间通信的所有通信方式都将被操纵体系内核管理,以模块的情势组织在一起;
在这些进程间通信方式中肯定存在属于一个struct_XXX_ds的数据结构;
这些数据结构中的第一个成员普遍为sturct ipc_perm XXX _perm的数据结构;
操纵体系内核将通过管理数组的方式将多个sturct ipc_perm XXX _perm结构体举行管理;
由于sturct ipc_perm XXX _perm数据结构为struct_XXX_ds数据结构的首位即首地址,可通过强制类型转换的方式将对应的地址转换为struct_XXX_ds类型的地址从而访问到struct_XXX_ds结构中的其他属性;
当需要访问一个通信方式时将访问该数组的下标;
而该数组的下标即为xxxid,比方共享内存的shmid,消息队列的msqid等等;
而在产生XXXid时需要使用key,若key相同时则可能会导致两个差别种类的进程间通信方式对应的下标可能冲突;
这个数组是一个线性且具有轮转机制的数组;
类型的强转
在举行类型强转时操纵体系将率先通过数组下标访问到struct ipc_perm XXX_perm结构体,在该结构体中现实直接或间接存放了该进程通信方式的类型;
当内核识别到该类型时可通过识别将其强转为对应类型的地址从而对struct_XXX_ds结构体变量举行访问;
举动类比
对于强转并绑定的举动本质上是一种多态的举动;
而其中对应的struct ipc_perm XXX_perm结构体即可当作基类,struct_XXX_ds当作派生类;

临界资源

数据差别等问题
当一个共享资源同时被多个实行流共享时,其可能出现两个差别的实行流同时分别向该共享资源中举行读和写;
当写端未完全将数据写入完成时读端就已经将已经写入的资源举行读取;
从而导致数据错乱即为数据差别等的问题;
一样平常这种情况存在于不存在同步互斥机制的共享资源中,如共享内存;
在使用下令行运行一些程序并向程序举行打印时可能会发生错乱的问题,而错乱的问题本质上就是数据差别等的问题即多个进程可能同时向下令行显示器打印信息,标明了在某些下令行显示器中其可能是一种不存在同步互斥掩护机制的资源,需要用户自行上锁;
可通过加锁的方式为其提供互斥属性;
临界资源
临界资源指任何时刻只允许一个实行流访问的共享资源,一样平常该共享资源为用户或操纵体系内核所维护的一段内存空间,如管道;
临界区
临界区指用户层当中访问并操纵临界资源的代码被称为临界区(部门代码);
1. #include <stdio.h>
2. #include <stdlib.h>
3. #include <unistd.h>
4. #include <fcntl.h>
5. #include <sys/stat.h>
6. #include <sys/wait.h>
8. #define FIFO_NAME "/tmp/my_fifo"
10. // 函数用于读取和更新共享数据
11. void increment() {
12. int fifo_fd;
13. for (int i = 0; i < 100000; ++i) {
14. // 1. 进入共享区：打开FIFO
15. fifo_fd = open(FIFO_NAME, O_RDWR);
16. if (fifo_fd < 0) {
17. perror("open");
18. exit(1);
19. }
21. // 2. 进入共享区：读取当前值
22. int value;
23. read(fifo_fd, &value, sizeof(value));
25. // 3. 修改共享数据
26. value++;
28. // 4. 进入共享区：将修改后的值写回FIFO
29. lseek(fifo_fd, 0, SEEK_SET);
30. write(fifo_fd, &value, sizeof(value));
32. // 5. 离开共享区：关闭FIFO
33. close(fifo_fd);
34. }
35. }
37. int main() {
38. // 创建FIFO
39. if (mkfifo(FIFO_NAME, 0666) == -1) {
40. perror("mkfifo");
41. exit(1);
42. }
44. // 初始化共享数据
45. int fifo_fd = open(FIFO_NAME, O_WRONLY);
46. if (fifo_fd < 0) {
47. perror("open");
48. exit(1);
49. }
50. int initial_value = 0;
51. write(fifo_fd, &initial_value, sizeof(initial_value));
52. close(fifo_fd);
54. // 创建子进程
55. pid_t pid = fork();
56. if (pid < 0) {
57. perror("fork");
58. exit(1);
59. }
61. if (pid == 0) {
62. // 子进程
63. increment();
64. exit(0);
65. } else {
66. // 父进程
67. increment();
69. // 等待子进程完成
70. wait(NULL);
72. // 读取最终结果
73. fifo_fd = open(FIFO_NAME, O_RDONLY);
74. int final_value;
75. read(fifo_fd, &final_value, sizeof(final_value));
76. printf("Final value: %d\n", final_value);
77. close(fifo_fd);
79. // 删除FIFO
80. unlink(FIFO_NAME);
81. }
83. return 0;
84. }
复制代码

System V 信号量

信号量又被称为信号灯,本质上信号量可以类比为一种计数器,用来形貌临界资源中的资源数目;
一个资源可能会被分为n份,如果存在n+个实行流对资源举行访问操纵时肯定存在两个或以上的实行流同时访问一份资源从而可能造成数据差别等的问题;

信号量则可以通过对临界资源的计数从而限定访问资源的实行流;
即引入一个计数器cnt,当计数器cnt--时即体现申请一份资源;
此处申请不代表已经使用而是代表预定,而是代表在申请成功后具有访问该资源的权限,申请计数器资源本质上是对资源的预定机制;
当计数器cnt<=0时体现资源被申请完了,如果还有实行流想申请对应资源将返回错误;
计数器可保证进入共享资源的实行流的数目;
当实行流想要访问对应的资源时需要先申请计数器资源而不是直接访问;

二元信号量
当一个资源不需要被分成n份而是以一个整体举行访问时需要的计数器值为1;
形貌该资源的计数器(信号量)即被称为二元信号量 ;
二元信号量的值只有0与1,当信号量为0时体现不可访问,1则为可以访问;
本质二元信号量就是一个锁;
信号量的原子性
信号量本身是一种共享资源,当多个实行流需要访问同一个共享资源时需要申请信号量计数器,而信号量计数器本身是一种共享资源需要被掩护;
掩护信号量本身的是其具有的原子性;
原子性的特点如下:
- 不可分割
  原子操纵是不可分割的,要么完全实行完毕,要么完全不实行,不存在中间状态(即不存在正在举行);
- 排他性
  原子操纵在实行期间不会被其他操纵打断;
  这通常通过硬件指令或同步机制来实现;
- 同等性
  原子性保证了在操纵实行过程中数据的同等性,不会出现部门更新的情况从而避免数据差别等;
信号量的申请与释放操纵分为 P操纵与 V操纵:
- P操纵(wait)
  当实行流需要访问资源时实行P操纵:
  如果信号量大于0,则-1并继承实行;
  如果信号量值为0则进入期待状态直到信号量>0;
- V操纵(signal)
  当实行流释放资源时实行V操纵:
  增加信号量的值;
  如果有其他实行流在期待信号量则叫醒其中一个;
而信号量的申请与释放操纵本身就是原子的,属于两态的,并不会在中途被其他实行流所给打断;

System V 信号量的接口介绍

创建信号量
调用体系调用接口semget()来创建/获取信号量;
1. NAME
2. semget - get a System V semaphore set identifier
4. SYNOPSIS
5. #include <sys/types.h>
6. #include <sys/ipc.h>
7. #include <sys/sem.h>
9. int semget(key_t key, int nsems, int semflg);
11. RETURN VALUE
12. If successful, the return value will be the semaphore set identifier (a nonnegative integer), otherwise -1 is returned, with errno indicating the error.
复制代码
参数与返回值:
- key_t key
  传入一个key值,该key值可以使差别的进程看到同一个信号量;
- int nsems
  传入所需信号量的数目;
- int semflg
  体现选项,选项同样是O_CREAT与O_EXCL,此处不赘述;
- 返回值
  其返回值与共享内存,消息队列的返回值类似;
  调用成功时返回对应key的信号量idsemid,调用失败时返回-1;
信号量的删除与属性操纵
调用体系调用接口semctl()对信号量举行操纵与删除;
1. NAME
2. semctl - System V semaphore control operations
4. SYNOPSIS
5. #include <sys/types.h>
6. #include <sys/ipc.h>
7. #include <sys/sem.h>
9. int semctl(int semid, int semnum, int cmd, ...);
11. DESCRIPTION
12. semctl() performs the control operation specified by cmd on the System V semaphore set identified by semid, or on the semnum-th semaphore of that set. (The semaphores
13. in a set are numbered starting at 0.)
15. RETURN VALUE
16. On failure semctl() returns -1 with errno indicating the error.
18. Otherwise the system call returns a nonnegative value depending on cmd as follows:
20. GETNCNT the value of semncnt.
22. GETPID the value of sempid.
24. GETVAL the value of semval.
26. GETZCNT the value of semzcnt.
28. IPC_INFO the index of the highest used entry in the kernel's internal array recording information about all semaphore sets. (This information can be used with
29. repeated SEM_STAT operations to obtain information about all semaphore sets on the system.)
31. SEM_INFO As for IPC_INFO.
33. SEM_STAT the identifier of the semaphore set whose index was given in semid.
35. All other cmd values return 0 on success.
复制代码
删除信号量与共享内存/消息队列相同传入IPC_RMID即可;
其他不举行赘述;
对信号量举行基本操纵
通常调用体系调用接口semop()对信号量举行基本操纵;
1. NAME
2. semop, semtimedop - System V semaphore operations
4. SYNOPSIS
5. #include <sys/types.h>
6. #include <sys/ipc.h>
7. #include <sys/sem.h>
9. int semop(int semid, struct sembuf *sops, unsigned nsops);
11. RETURN VALUE
12. If successful semop() and semtimedop() return 0; otherwise they return -1 with errno indicating the error.
复制代码
- int semid
  该参数为信号量集的标识符;
- struct sembuf* sops
  指向slembuf结构体数组的指针,每个sembuf结构体指定一个信号量操纵;
  其中sembuf结构体的界说为:
  1. struct sembuf {
  2. unsigned short sem_num; // 信号量集中的信号量编号
  3. short sem_op; // 要执行的操作
  4. short sem_flg; // 操作标志
  5. };
  复制代码
- unsigned nsops
  sops数组中的操纵数;

信号量不用做数据传输但仍属于通信的一种方式是由于:
通信不仅仅是通信数据,互相协同也是通信方式的一种;
而在举行协同时需要使得差别的实行流看到同一个信号量,信号量本身不是传输数据而是传输一个"信号"使得限定其他实行流;

免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！更多信息从访问主页：qidao123.com:ToB企服之家，中国第一个企服评测及商务社交产业平台。

		自动登录	找回密码
密码			立即注册

『 Linux 』简要介绍System V IPC 消息队列 && 信号量 ...

本帖子中包含更多资源

0 个回复

快速回复

楼主热帖

标签云

浏览过的版块