消息队列

消息队列传送数据

#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <sys/types.h>
#include <sys/ipc.h>
#include <sys/msg.h>
struct msgbuf//消息队列的结构体定义
{
    long mtype;
    char mtext[100];
};
int main()
{   
    struct msgbuf buf;//消息队列结构体声明变量
    buf.mtype=1;//消息类型 写入和读取的消息类型一样才能读取
    key_t key=ftok(".",'a');//key函数返回钥匙
    if(key<0)
    {
        printf("key");
        exit(-1);
    }
    int id=msgget(key,0664|IPC_CREAT);//消息队列ID,由msgget函数返回,key为钥匙,0664为8进制权限|

    if(id<0)
    {
        printf("id");
        exit(-1);
    }
    char bu[100]={0};//存储需要传过去的数据
    while(1)//循环传过去数据
    {
        fgets(bu,100,stdin);//将标准入(键盘)的写入bu
        strcpy(buf.mtext,bu); //将bu的字符复制给buf.mtext
        int size=sizeof(buf)-sizeof(buf.mtype);//计算正文的大小也就是buf.mtext的大小

        int msgsn=msgsnd(id,&buf,size,0);//msgsnd函数向消息队列写入数据,id为消息队列ID,&buf为数据结构变量地址,size为正文大小,0为发送完函数才返回
        if(msgsn<0)
        {
            printf("msgsnd");
            exit(-1);
        }
    }
    return 0;
}

消息队列

使用流程:

创建或者打开消息队列-- msgget()

发送消息-- msgsnd()

接收消息-- msgrcv()

删除消息队列-- msgctl()

消息队列接收数据

#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <sys/types.h>
#include <sys/ipc.h>
#include <sys/msg.h>
struct msgbuf //消息队列的结构体定义
{
    long mtype; 
    char mtext[100];
};
int main()
{   
    struct msgbuf buf;//消息队列结构体声明变量
//    buf.mtype=1;//消息类型  读取不需要赋值,只需要在msgrcv函数上表明需要传的类型  类型为整型
    key_t key=ftok(".",'a');//key函数返回钥匙
    if(key<0)
    {
        printf("key");
        exit(-1);
    }
    int id=msgget(key,0664|IPC_CREAT);//消息队列ID,由msgget函数返回,key为钥匙,0664为8进制权限|
    if(id<0)
    {
        printf("id");
        exit(-1);
    }
    char bu[100]={0};//存储传过来的数据
    while(1)//循环接受传过来的数据
    {
        int size=sizeof(buf)-sizeof(buf.mtype);//计算正文的大小
        int msgrc=msgrcv(id,&buf,size,1,0);//msgrc函数返回接受到消息的长度
        if(msgrc<0)
        {
            printf("msgrce");
            exit(-1);
        }
        strcpy(bu,buf.mtext); //将传过来的数据复制给bu
        printf("%s",bu);//打印出来
    }
    return 0;
}