linux进程间通信消息队列：msgsnd: Invalid argument

今天写了个消息队列的小测试程序结果send端程序总是出现：msgsnd: Invalid argument，搞了半个小时也没搞明白，后来查资料发现我将（st_msg_buf.msg_type = 0;    //设置消息类型）设置为0了，原来0表示是任意类型的消息，只有recv端才可以设置为0表示：可以接受任意类型消息。

代码：

发送端源代码：

#include <stdio.h>
#include <stdlib.h>
#include <unistd.h>
#include <string.h>

#include <sys/types.h>
#include <sys/msg.h>
#include <sys/ipc.h>

#define MAX_TEXT      512
#define BUF_SIZE    512


struct my_msg_st{            //临时消息结构

    int  msg_type;
    char msg_text[MAX_TEXT];        //自定义存储空间大小
};

int main()
{
    key_t key;
    int  running  = 1;
    struct my_msg_st st_msg_buf;
    int msgid;
    char buffer[BUF_SIZE];
    memset(&st_msg_buf, 0, sizeof(st_msg_buf));
    memset(buffer, 0, sizeof(buffer));

    //创建键值
    if((key = ftok("./", 100)) == -1){
        perror("ftok");
        exit(1);
    }
    printf("key : %#x
", key);

    //创建信息队列
    if((msgid = msgget(key, 0666 | IPC_CREAT)) == -1){
        perror("msgget");
        exit(1);
    }
    printf("Enter the messge to send:");
        
    //发送消息
    while(running)
    {
        fgets(buffer, BUF_SIZE, stdin);//读取输入的消息
        if(buffer[0] == '' || buffer[0] == '
')
            continue;
        buffer[strlen(buffer) - 1] = '';//去回车符
        st_msg_buf.msg_type = 1;       //设置消息类型
        strcpy(st_msg_buf.msg_text, buffer);//复制消息

        printf("message have send to
");
        if(msgsnd(msgid, (void *)&st_msg_buf, MAX_TEXT, 0) < 0){
            perror("msgsnd");
            exit(1);
        }
        
        if(strncmp(buffer, "end", 3) == 0)//判断是否为退出结束消息
            running = 0;
            
    }

    return 0;
}

接收端源代码：

#include <stdio.h>
#include <stdlib.h>
#include <unistd.h>
#include <string.h>

#include <sys/types.h>
#include <sys/msg.h>
#include <sys/ipc.h>

#define MAX_TEXT      512
#define BUF_SIZE    512

struct my_msg_st{            //临时消息结构

    int  msg_type;
    char msg_text[MAX_TEXT];        //自定义存储空间大小
};

int main()
{
    key_t key;
    int running  = 1, size = 0;
    struct my_msg_st st_msg_buf;
    int msgid;
    int msg_to_receiver = 0;
    memset(&st_msg_buf, 0, sizeof(st_msg_buf));

    //创建键值
    if((key = ftok("./", 100)) == -1){
        perror("ftok");
        exit(1);
    }
    printf("key : %#x
", key);

    //创建信息队列
    if((msgid = msgget(key, 0666 | IPC_CREAT)) == -1){
        perror("msgget");
        exit(1);
    }
    

    //接受消息
    while(running)
    {
        if((size = msgrcv(msgid, (void *)&st_msg_buf, 
                    MAX_TEXT, msg_to_receiver,0)) <  0){
            perror("msgsnd");
            exit(1);
        }

        printf("receiver mssage: %d, %s
", size, st_msg_buf.msg_text);

        if(strncmp(st_msg_buf.msg_text, "end", 3) == 0)
            running = 0;
    }

    if(msgctl(msgid, IPC_RMID, 0) < 0){
        perror("msgctl");
        exit(1);
    }

    return 0;
}