消息队列发送数据时,会分成一个一个独立的数据单元,也就是消息体,每个消息体都是固定大小的存储块,在字节流上不连续。
//类型 mtype 和正文 mtext 没有强制规定,只要消息的发送方和接收方约定好即可。 struct msg_buffer { long mtype; char mtext[1024]; }; #include <stdio.h> #include <stdlib.h> #include <sys/msg.h> int main() { int messagequeueid; key_t key; // 指定一个文件,ftok 会根据这个文件的 inode,生成一个近乎唯一的 key。 // 只要文件不删除,再调用 ftok,会得到同样的 key。 if((key = ftok("/home/cindy/test", 1024)) < 0) { perror("ftok error"); exit(1); } printf("Message Queue key: %d.\n", key); // 创建一个消息队列,参数 key 是消息队列的唯一标识 if ((messagequeueid = msgget(key, IPC_CREAT|0777)) == -1) { perror("msgget error"); exit(1); } printf("Message queue id: %d.\n", messagequeueid); } # ./a.out Message Queue key: 92536. Message queue id: 32768.
System V IPC 体系有一个统一的命令行工具:ipcmk,ipcs 和 ipcrm 用于创建、查看和删除 IPC 对象。
# ipcs -q ------ Message Queues -------- key msqid owner perms used-bytes messages 0x00016978 32768 root 777 0 0