系统相关
首页 > 系统相关> > Linux消息队列

Linux消息队列

作者:互联网

提示:文章写完后,目录可以自动生成,如何生成可参考右边的帮助文档

文章目录


前言

提示:这里可以添加本文要记录的大概内容:
例如:随着人工智能的不断发展,机器学习这门技术也越来越重要,很多人都开启了学习机器学习,本文就介绍了机器学习的基础内容。


提示:以下是本篇文章正文内容,下面案例可供参考

一、Linux消息队列是什么?

示例:消息队列的本质是消息的链表,存放在内核中。一个消息队列由一个标识符(即队列ID)来标识。
接收进程可以独立地接收含有不同类型的数据结构。

二、使用步骤

1.引入库

int msgget(key_t key, int msgflg); 
创建消息队列 , 返回值为该队列号
int msgsnd(int msqid, const void *msgp, size_t msgsz, int msgflg);
发送消息
ssize_t msgrcv(int msqid, void *msgp, size_t msgsz, long msgtyp,int msgflg);
接受信息,msgtyp需要指明接受的数据type
key_t ftok(const char *pathname, int proj_id);
为队列随机附加key,pathename为路径,id号可随意(1-255)
int msgctl(int msqid, int cmd, struct msqid_ds *buf);//可用于消除内内核中的队列

代码如下(示例):

//发送及接受数据程序
#include<stdio.h>
#include <sys/types.h>
#include <sys/ipc.h>
#include <sys/msg.h>
#include<string.h>
 struct msgbuf {
		long mtype;       /* message type, must be > 0 */
        char mtext[128];    /* message data */
 };
int main()
{
    
    struct msgbuf snddata={888,"hello rcv,this is snd"};
	struct msgbuf readdata;
	key_t key;
	key = ftok(".",2);
	int msgid = msgget(key,IPC_CREAT|0777);
	printf("the key is %x\n",key);
	if(msgid == -1)
	{
		printf("creat fail\n");
	}
	else
	{
			msgsnd(msgid,&snddata,strlen(snddata.mtext),0);
			msgrcv(msgid,&readdata,sizeof(readdata.mtext),988,0);
			printf("the data come form read:%s\n",readdata.mtext);
	}
	msgctl(msgid,IPC_RMID,NULL);//销毁msgid为标识符的消息队列
		return 0;
}

//接受及发送数据程序
#include<stdio.h>
#include <sys/types.h>
#include <sys/ipc.h>
#include <sys/msg.h>
#include<string.h>
 struct msgbuf {
		long mtype;       /* message type, must be > 0 */
        char mtext[128];    /* message data */
 };
int main()
{
    
	struct msgbuf snddata={988,"the data come from rcv"};
	struct msgbuf readdata;
	key_t key;
	key=ftok(".",2);
	int msgid = msgget(key,IPC_CREAT|0777);
	printf("the key is %x\n",key);
	if(msgid ==-1)
    {
		printf("creat fail\n");
    }
	else
	{
			msgrcv(msgid,&readdata,sizeof(readdata.mtext),888,0);
			printf("the data come snd:%s ",readdata.mtext);
			msgsnd(msgid,&snddata,strlen(snddata.mtext),0);
	}
	msgctl(msgid,IPC_RMID,NULL);//销毁msgid为标识符的消息队列
		return 0;
}


2.相关

ls -i  打印索引结点
消息队列一旦创建,仲裁权便移交给Linux内核,除非销毁,否则存在
数据一旦写入,读出后数据研究存在


总结

消息队列虽然解决了管道中读写端的控制,但容量受到系统限制,且要注意第一次读的时候,要考虑上一次没有读完数据的问题。

标签:队列,msgid,int,消息,key,Linux,include,mtext
来源: https://blog.csdn.net/weixin_46364330/article/details/112556200