c语言消息队列 私聊 实现过程

C 语言中实现消息队列可以使用 System V IPC 或 POSIX IPC。这里简单介绍一下使用 System V IPC 实现私聊的过程。

1. 创建一个消息队列：通过调用 `msgget` 函数创建一个消息队列，并返回一个标识符（msgqid）。

key_t key = ftok(".", 'a'); // 生成一个键值
int msgqid = msgget(key, IPC_CREAT | 0666); // 创建一个消息队列

2. 发送消息：通过调用 `msgsnd` 函数向指定的消息队列发送消息。需要指定消息队列的标识符（msgqid）、消息类型（msgtype）、消息内容（msgbuf）以及消息长度（msgsz）。

struct message {
    long mtype; // 消息类型
    char mtext[1024]; // 消息内容
};

struct message msg;
msg.mtype = 1; // 消息类型为 1
strcpy(msg.mtext, "Hello world"); // 消息内容
int ret = msgsnd(msgqid, &msg, sizeof(msg.mtext), IPC_NOWAIT); // 发送消息

3. 接收消息：通过调用 `msgrcv` 函数从指定的消息队列接收消息。需要指定消息队列的标识符（msgqid）、消息类型（msgtype）、消息内容（msgbuf）以及最大消息长度（msgsz）。

struct message msg;
int ret = msgrcv(msgqid, &msg, sizeof(msg.mtext), 1, IPC_NOWAIT); // 接收消息
if (ret == -1) {
    perror("msgrcv");
} else {
    printf("Received message: %s\n", msg.mtext);
}

需要注意的是，发送和接收消息的进程需要使用相同的消息类型。可以通过定义不同的消息类型来实现私聊功能。例如，进程 A 向进程 B 发送消息时，可以使用消息类型 1；进程 B 向进程 A 发送消息时，可以使用消息类型 2。这样，进程 A 只会接收到进程 B 发送的消息，而不会接收到其他进程发送的消息。