Linux消息队列编程示例
一、概念
消息队列就是一个消息的链表。可以把消息看作一个记录，具有特定的格式以及特定的优先级。对消息队列有写权限的进程可以向中按照一定的规则添加新消息；有读权限的进程则可以读走消息。读走就没有了。消息队列是随内核持续的。 只有内核重启或人工删除时，该消息才会被删除。在系统范围内，消息队列与键值唯一对应。
二、步骤及思路
1、取得键值2、打开、创建消息队列3、发送消息4、接收消息
下面具体看看：
1、取得键值
代码如下:
头文件为<sys/ipc.h>。返回文件名对应的键值，失败返回 -1。proj是项目名，随便写，不为0就行。 fname就是你指定的文件名（已经存在的文件名）。需要有-t 的权限，或用root权限执行，通常设为/tmp或设为" . "。这里我感觉不用这个函数也行，因为key值可以自己指定，例如： #define KEY_MSG 0x1012、打开、创建消息队列
代码如下:
头文件为<sys/msg.h>。key由ftok获得。
msgflg有：
IPC_CREAT 创建新的消息队列，应配有文件权限0666。IPC_EXCL 与IPC_CREAT一同使用，表示如果要创建的消息队列已经存在，则返回错误。
IPC_NOWAIT 读写消息不阻塞。 当没有与key相对应的消息队列并且msgflg中包含了IPC_CREAT标志 或 key的参数为IPC_PRIVATE 时，创建一个新的消息队列。3、发送消息
代码如下:
向消息队列发送一条消息。msqid为消息队列的id，msgp为存放消息的结构体。msgsz是消息的长度，和数组的大小不一样哦。msgflg为消息标志，通常为0，也可以为IPC_NOWAIT。出错返回 -1。消息格式
代码如下:
4、接收消息
代码如下:
从msqid代表的消息队列中读取一个msgtyp类型的消息，并把消息存储在msgp指定的msgbuf结构中。读取后队列中的消息将会删除。size为结构体中数据的大小，不要计算msgtyp。出错返回 -1。三、举例创建一消息队列，子进程发数据，父进程收数据。实现向队列中存放数据与读取数据。
代码如下:
<p>struct haha{ long mtype; char data[max];};</p>
<p>int main(int argc,char *argv[]){ int pid; if(argc!=2){ printf(\”Usage: msg [Message]\\n\”); return -1; } key_t key; if((key=ftok(\”/tmp\”,\’g\’))<0){ //这里文件夹必须存在，有t属性并且上级目录也要有t属性 printf(\”Getting key error! \\n\”); return -1; } int mgsid; if((mgsid=msgget(key,IPC_CREAT|0666))==-1){ //key值随便写一个数也能用 printf(\”mgs queue create error\\n\”); return -1; } pid=fork(); if(pid <0){ printf(\”fork create error!\\n\”); _exit(1); } if(pid == 0){ printf(\”welcome in child process\\n Sending the message……\\n\”); sleep(1); struct haha hehe; hehe.mtype=getppid(); strcpy(hehe.data,argv[1]); if(msgsnd(mgsid,&hehe,sizeof(hehe.data),0)<0){ //此处注意长度 printf(\”Sending error!!!\\n\”); _exit(1); }else { printf(\”Sending complete!\\n\”); _exit(0); } }else{ wait(NULL); printf(\”welcome in parents process\\n Receiving the message……\\n\”); sleep(1); struct haha gaga; if(msgrcv(mgsid,&gaga,max,getpid(),0)<0){ printf(\”Receiving error!!!\\n\”); _exit(1); }else { printf(\”Receiving complete!\\n\”); printf(\”The message is %s \\n\”,gaga.data); } } return 0;}
2. 分享目的仅供大家学习和交流，请不要用于商业用途！
3. 如果你也有好源码或者教程，可以到用户中心发布投稿，分享有金币奖励和额外收入！
4. 本站提供的源码、模板、插件等等其他资源，都不包含技术服务 请大家谅解！
5. 如有链接无法下载、失效或广告，请联系站长，可领回失去的金币，并额外有奖！
6. 如遇到加密压缩包，默认解压密码为"www.zyfx8.cn",如遇到无法解压的请联系管理员！
本站部分文章、资源来自互联网，版权归原作者及网站所有，如果侵犯了您的权利，请及时联系我站删除。免责声明
资源分享吧 » Linux消息队列编程示例
常见问题FAQ
- 免费下载或者VIP会员专享资源能否直接商用？
- 本站所有资源版权均属于原作者所有，这里所提供资源均只能用于参考学习用，请勿直接商用。若由于商用引起版权纠纷，一切责任均由使用者承担。更多说明请参考 VIP介绍。
- 织梦模板使用说明
- 你下载的织梦模板并不包括DedeCMS使用授权，根据DedeCMS授权协议，除个人非盈利站点外，均需购买DedeCMS商业使用授权。购买地址： http://www.desdev.cn/service-dedecms.html
