系统编程练习题----使用消息队列实现两个进程之间的通信

目录

• 题目
  
• 思路
  
• 代码展示
  
  
  
  • 进程A
    
  • 进程B
    
  
  
• 结果展示
  

题目

要求进程A创建一条消息队列之后向进程B发送SIGUSR1信号，进程B收到该信号之后打开消息队列并写入一段信息作为消息写入到消息队列中，要求进程B在写入消息之后，发SIGUSR2信号给进程A，进程A收到该信号则从消息队列中读取消息并输出消息正文的内容。
思路

• 通过进程A创建的消息队列，实现进程A与进程B之间的PID交换
  
• 通过kill指令完成进程A与进程B之间的信号交互，并通过状态机实现步骤的进行
  
• 进程A收到进程B的信号后，从消息队列中读出消息，并完成显示
  

代码展示

进程A

1. /*******************************************************************
2. *
3. *        file name:        process_A.c
4. *        author         :  790557054@qq.com
5. *        date         :  2024/05/27
6. *        function :  该案例是掌握进程通信方式，主要是学习信号和消息队列的使用
7. *         note         :  None
8. *   version  :
9. *
10. *        CopyRight (c)  2023-2024   790557054@qq.com   All Right Reseverd
11. *
12. * *****************************************************************/
13. /****************************头文件**************************************/
15. #include <stdio.h>
16. #include <sys/types.h>
17. #include <sys/ipc.h>
18. #include <errno.h>
19. #include <string.h>
20. #include <signal.h>
21. #include <sys/msg.h>
22. #include <stdlib.h>
23. #include <unistd.h>
25. /****************************结构体**************************************/
26. struct msgbuf
27. {
28.         long mtype;       /* message type, must be > 0 */
29.         int mtext;    /* message data */
30. };
32. /****************************全局变量**************************************/
33. volatile int  flag;  //作为状态机条件
35. /********************************************************************
36. *
37. *        name         :        msg_get
38. *        function :  改函数用于获取进程B发送的信号
39. *        pqram :  
40. *                                @signum  : 捕捉到的信号类型
41. *                               
42. *        retval         :  none
43. *        author         :  790557054@qq.com
44. *        date         :  2024/05/27
45. *         note         :  none
46. *   version  :
47. *        
48. * *****************************************************************/
49. void msg_get(int signum)
50. {
51.         if(signum == SIGUSR1)
52.         {
53.                 //改变标志量，从消息队列中读取进程B的pid
54.                 flag = 1;
55.         }
56.         else if(signum == SIGUSR2)
57.         {
58.                 //改变标志量，从消息队列中读取进程B发送的消息
59.                 flag = 0;
60.         }
61. }
64. int main(int argc, char const *argv[])
65. {
66.         //捕捉进程B发送的信号，再从消息队列中获取进程B的pid
67.         signal(SIGUSR1, msg_get);
68.         //捕捉进程B发送的信号，再从消息队列中获取进程B发送的消息
69.         signal(SIGUSR2, msg_get);
73.         /****创建一条消息队列****/
74.         //1) 获取消息队列唯一键值(key)
75.         key_t key = ftok(".", 0xffffff01);
76.         //2) 定义一个变量用于存储消息队列id,创建一条消息队列
77.         int msg_id = msgget(key, IPC_CREAT | 0644);
78.         if(msg_id == -1)
79.         {
80.                 fprintf(stderr, "msgget error , errno: %d, %s\n", errno, strerror(errno));
81.                 exit(-1);
82.         }
84.         /****发送SIGUSR1信号给进程B****/
85.         // 通过消息队列完成A,B进程的pid交换
86.         //1. 将进程A的pid写入消息队列中
87.         struct msgbuf msg_pid;
88.         msg_pid.mtype = 1;
89.         msg_pid.mtext = getpid();
92.         msgsnd(msg_id, &msg_pid, 4, 0);
94.         //2. 捕捉进程B发送的SIGUSR1信号
95.         while(flag == 0);
96.         // 3. 从消息队列中读取进程B的pid
97.         struct msgbuf msg_pid_B;
98.         msgrcv(msg_id, &msg_pid_B, 4, 1, IPC_NOWAIT);
100.         //4. 发送SIGUSR1信号给进程b
101.         kill(msg_pid_B.mtext, SIGUSR1);
103.         /****接收到进程B的信号后，从消息队列中读出消息并输出****/
104.         while(flag);
106.         struct msgbuf msg_num;
107.         msgrcv(msg_id, &msg_num, 4, 2, IPC_NOWAIT);
109.         printf("The information received from process B is %d\n", msg_num.mtext);
111.         return 0;
112. }

复制代码

进程B

1. /*******************************************************************
2. *
3. *        file name:        process_B.c
4. *        author         :  790557054@qq.com
5. *        date         :  2024/05/27
6. *        function :  该案例是掌握进程通信方式，主要是学习信号和消息队列的使用
7. *         note         :  None
8. *   version  :
9. *
10. *        CopyRight (c)  2023-2024   790557054@qq.com   All Right Reseverd
11. *
12. * *****************************************************************/
13. /****************************头文件**************************************/
15. #include <stdio.h>
16. #include <sys/types.h>
17. #include <sys/ipc.h>
18. #include <errno.h>
19. #include <string.h>
20. #include <signal.h>
21. #include <sys/msg.h>
22. #include <stdlib.h>
23. #include <unistd.h>
25. /****************************结构体**************************************/
26. struct msgbuf
27. {
28.         long mtype;       /* message type, must be > 0 */
29.         int mtext;    /* message data */
30. };
32. /****************************全局变量**************************************/
33. volatile int  flag = 1;  //作为状态机条件
35. /********************************************************************
36. *
37. *        name         :        msg_get
38. *        function :  改函数用于获取进程A发送的信号
39. *        pqram :  
40. *                                @signum  : 捕捉到的信号类型
41. *                               
42. *        retval         :  none
43. *        author         :  790557054@qq.com
44. *        date         :  2024/05/27
45. *         note         :  none
46. *   version  :
47. *        
48. * *****************************************************************/
49. void msg_get(int signum)
50. {
51.         if(signum == SIGUSR1)
52.         {
53.                 //改变标志量，从消息队列中读取进程A的pid
54.                 flag = 0;
55.         }
56. }
59. int main(int argc, char const *argv[])
60. {
61.         //捕捉进程A发送的信号，再从消息队列中获取进程B的pid
62.         signal(SIGUSR1, msg_get);
65.         /****打开一条消息队列****/
66.         //1) 获取消息队列唯一键值(key)
67.         key_t key = ftok(".", 0xffffff01);
68.         //2) 定义一个变量用于存储消息队列id,创建一条消息队列
69.         int msg_id = msgget(key, IPC_CREAT | 0644);
70.         if(msg_id == -1)
71.         {
72.                 fprintf(stderr, "msgget error , errno: %d, %s\n", errno, strerror(errno));
73.                 exit(-1);
74.         }
76.         struct msgbuf msg_pid_a;
77.         /****从消息队列中读取进程A的pid，并将进程B的pid写入消息队列中***/
78.         msgrcv(msg_id, &msg_pid_a, 4, 1, IPC_NOWAIT);
80.         //将进程B的pid写入消息队列
81.         struct msgbuf msg_pid_b;
82.         msg_pid_b.mtype = 1;
83.         msg_pid_b.mtext = getpid();
85.         msgsnd(msg_id, &msg_pid_b, 4, 0);
86.         /****发送SIGUSR1信号给进程A****/
87.         kill(msg_pid_a.mtext, SIGUSR1);
89.         /****等待接收进程A的SIGUSR1信号****/
90.         while(flag == 1);
92.         /****接收到进程A的信号后，将数据写入消息队列中***/
93.         struct msgbuf msg_num;
94.         msg_num.mtype = 2;
95.         msg_num.mtext = 66666;
97.         msgsnd(msg_id, &msg_num, 4, 0);
99.         /****发送SIGUSR2信号给进程A****/
100.         kill(msg_pid_a.mtext, SIGUSR2);
102.         return 0;
103. }

复制代码

结果展示

来源：程序园用户自行投稿发布，如果侵权，请联系站长删除
免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！