linux 消息发送接收

在Linux系统中，消息的发送和接收可以通过多种机制实现，其中最常见的是使用消息队列（Message Queues）。以下是关于Linux消息发送接收的基础概念、优势、类型、应用场景以及可能遇到的问题和解决方法：

基础概念

消息队列是一种进程间通信（IPC）机制，允许进程将消息发送到队列中，其他进程可以从队列中接收这些消息。Linux中的消息队列通常通过POSIX消息队列或System V消息队列实现。

优势

异步通信：发送方和接收方不需要同时在线，消息可以排队等待处理。
解耦：发送方和接收方不需要知道对方的存在，只需要知道消息队列的标识。
灵活性：可以控制消息的优先级、大小和发送/接收的模式。

类型

POSIX消息队列：符合POSIX标准的消息队列，使用mq_open、mq_send、mq_receive等函数进行操作。
System V消息队列：较老的消息队列系统，使用msgget、msgsnd、msgrcv等函数进行操作。

应用场景

任务分发：一个进程生成任务，其他进程从队列中取出任务执行。
日志记录：将日志消息发送到队列，由专门的日志处理进程进行处理。
事件通知：一个进程发生特定事件时，发送消息通知其他进程。

示例代码（POSIX消息队列）

发送消息

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

#define QUEUE_NAME "/test_queue"
#define MAX_MSG_SIZE 100

int main() {
    mqd_t mq;
    struct mq_attr attr;
    char buffer[] = "Hello, World!";

    attr.mq_flags = 0;
    attr.mq_maxmsg = 10;
    attr.mq_msgsize = MAX_MSG_SIZE;
    attr.mq_curmsgs = 0;

    mq = mq_open(QUEUE_NAME, O_CREAT | O_WRONLY, 0644, &attr);
    if (mq == -1) {
        perror("mq_open");
        exit(1);
    }

    if (mq_send(mq, buffer, strlen(buffer) + 1, 0) == -1) {
        perror("mq_send");
        mq_close(mq);
        exit(1);
    }

    mq_close(mq);
    return 0;
}

接收消息

#include <stdio.h>
#include <stdlib.h>
#include <mqueue.h>

#define QUEUE_NAME "/test_queue"
#define MAX_MSG_SIZE 100

int main() {
    mqd_t mq;
    char buffer[MAX_MSG_SIZE];

    mq = mq_open(QUEUE_NAME, O_RDONLY);
    if (mq == -1) {
        perror("mq_open");
        exit(1);
    }

    if (mq_receive(mq, buffer, MAX_MSG_SIZE, NULL) == -1) {
        perror("mq_receive");
        mq_close(mq);
        exit(1);
    }

    printf("Received message: %s
", buffer);

    mq_close(mq);
    mq_unlink(QUEUE_NAME);
    return 0;
}