Linux Msg详解：掌握进程间通信的利器 在Linux操作系统中，进程间通信（IPC，Inter-Process Communication）是实现多任务处理和多进程协作的关键机制之一

    Linux提供了多种IPC机制，如管道（pipe）、命名管道（FIFO）、消息队列（message queue）、信号（signal）、信号量（semaphore）、共享内存（shared memory）以及套接字（socket）等

    其中，消息队列以其独特的优势，在多进程通信中扮演着重要角色

    本文将深入探讨Linux消息队列（msg）的原理、使用方法和实际应用，帮助读者掌握这一强大的IPC工具

     一、消息队列概述 消息队列是一种允许一个或多个进程向队列中添加消息，以及从队列中读取消息的IPC机制

    消息队列不仅支持同步通信，还支持异步通信，使得进程间的通信更加灵活和高效

    与管道和命名管道相比，消息队列具有以下几个显著优势： 1.消息类型：消息队列允许发送方为消息指定类型，接收方可以基于消息类型选择性地接收消息，这增加了通信的灵活性和控制力

     2.优先级：消息队列支持消息优先级，使得高优先级的消息能够优先被处理，这对于实时系统尤为重要

     3.持久性：某些实现下的消息队列可以持久化存储消息，即使发送方或接收方进程退出，消息也不会丢失

     4.容量控制：消息队列可以设置最大长度，当队列满时，发送方可以选择等待队列有空位或立即返回错误，这有助于防止系统资源过度占用

     二、消息队列的API 在Linux中，消息队列的操作主要通过一组系统调用接口实现，包括`msgget`、`msgsnd`、`msgrcv`和`msgctl`

     1.msgget：创建或获取一个消息队列标识符

     c int msgget(key_t key, int msgflg); -`key`：用于唯一标识消息队列的键值

     -`msgflg`：控制消息队列的创建和访问权限，通常包括IPC_CREAT（创建消息队列）、IPC_EXCL（与IPC_CREAT一起使用，确保消息队列不存在时才创建）以及权限标志（如0666）

     2.msgsnd：发送消息到消息队列

     c int msgsnd(int msqid, const voidmsgp, size_t msgsz, int msgflg); -`msqid`：消息队列标识符

     -`msgp`：指向消息缓冲区的指针

     -`msgsz`：消息的大小（字节数）

     -`msgflg`：发送消息的标志，如0（阻塞发送）或IPC_NOWAIT（非阻塞发送，若队列满则立即返回）

     3.msgrcv：从消息队列接收消息

     c ssize_t msgrcv(int msqid, voidmsgp, size_t msgsz, long msgtyp, int msgflg); -`msqid`：消息队列标识符

     -`msgp`：指向接收消息缓冲区的指针

     -`msgsz`：缓冲区的大小

     -`msgtyp`：指定接收的消息类型，0表示接收任何类型的消息，大于0表示接收指定类型的消息，小于0表示接收类型小于或等于其绝对值的最低优先级消息

     -`msgflg`：接收消息的标志，如0（阻塞接收）或IPC_NOWAIT（非阻塞接收，若队列空则立即返回）

     4.msgctl：控制消息队列

     c int msgctl(int msqid, int cmd, struct msqid_ds buf); -`msqid`：消息队列标识符

     -`cmd`：控制命令，如IPC_RMID（删除消息队列）、IPC_SET（设置消息队列属性）、IPC_STAT（获取消息队列状态）

     -`buf`：指向`msqid_ds`结构的指针，用于传递或接收消息队列的状态信息

     三、消息队列的使用示例 下面是一个简单的示例程序，展示了如何使用消息队列在两个进程之间进行通信

     发送进程（sender.c）： include include include include include defineQUEUE_KEY 1234 defineMAX_TEXT 512 struct message_buffer{ longmessage_type; chartext【MAX_TEXT】; }; int main() { int running = 1; structmessage_buffer some_data; int msgid; charbuffer【MAX_TEXT】; // 创建消息队列 msgid = msgget(QUEUE_KEY, 0666 |IPC_CREAT); if(msgid == -{ fprintf(stderr, msgget failedn); exit(EXIT_FAILURE); } while(running) { printf(Enter some text: ); fgets(buffer, MAX_TEXT, stdin); some_data.message_type = 1; // 设置消息类型 strncpy(some_data.text, buffer, MAX_TEXT); // 发送消息 if(msgsnd(msgid,(void) &some_data, MAX_TEXT, 0) == -1) { fprintf(stderr, msgsnd failedn); exit(EXIT_FAILURE); } printf(You wrote: %s, some_data.text); } // 删除消息队列 if(msgctl(msgid,IPC_RMID, == -{ fprintf(stderr, msgctl(IPC_RMID) failedn); exit(EXIT_FAILURE); } return 0; } 接收进程（receiver.c）： include include include include include defineQUEUE_KEY 1234 defineMAX_TEXT 512 struct message_buffer{ longmessage_type; char