消息队列的创建与使用
进程a发送一条消息,进程b读取消息。
a.c代码:
b.c代码:
1.a进程创建向消息队列,并向消息队列中发送消息
运行a程序之前,当前系统中消息队列的数量为0:
运行一次a程序,消息队列被创建:
可以看到向这个消息队列中添加了一个消息,这个消息时一个32个字节的字符数组。由a.c的代码可以知道,进程a发送了一条类型为1,内容为"hello"的消息到消息队列中,如下图所示:
再运行一次a.c,就会再向消息队列中发送一次消息,运行结果如下:
此时消息队列的情况如下图所示:
每运行一次向消息队列发送消息的程序,就会像消息队列发送一次消息。
2.b进程接收消息队列中的消息
运行b程序之前,先查看消息队列的信息,运行之后再查看消息队列的信息:
可以看到消息队列中2个消息变成了1个消息,这是因为进程b把队列中类型为1的第一个消息接收走了。如下图所示:
假设现在让b进程接收类型为3的消息,修改b.c的代码如下:
运行b进程就会发生阻塞,因为消息队列中没有类型为3的消息:
然后修改a.c的代码如下:
这时运行a.c程序,并查看消息队列信息:
此时消息队列的情况如下图所示:
这个时候运行b.c程序就不会阻塞,可以成功接收类型为3的消息,接收完之后,消息队列中只剩下一个类型为1的消息:
消息队列的情况如下图所示:
再次修改b.c代码,让b程序接收类型为0的消息,这时每次运行b程序可以从消息队列中从队头开始依次往后的每一个消息:
先运行一次a程序,向消息队列中发送一个类型为3的消息,如下图所示:
然后运行b程序:
可以看到b进程把消息队列中的消息从队头开始依次接收,直到消息队列中没有消息,再执行b程序时发送阻塞。