Linux 高级编程 - 消息队列 Msg Queue

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

/*
 * key：用来指定返回 MQ 的 ID
 * msgflg：创建的标志，例如 IPC_CREAT
 * return：成功返回队列 ID，失败返回 -1, 并设置 erron
 */
int msgget(key_t key, int msgflg);

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

/*
 * msgid：消息队列 ID
 * msgp：指向 msgbuf 的指针，用来指定发送的消息
 * msgsz：要发送消息的长度
 * msgflg：创建标记，如果指定 IPC_NOWAIT，失败会立刻返回
 * return：成功返回 0, 失败返回 -1, 并设置 erron
 */
int msgsnd(int msqid, const void *msgp, size_t msgsz, int msgflg);

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

/*
 * msgid：消息队列 ID
 * msgp：指向 msgbuf 的指针，用来接收消息
 * msgsz：要接收消息的长度
 * msgtyp：接收消息的方式
 * msgflg：创建标记，如果指定 IPC_NOWAIT，获取失败会立刻返回
 * return：成功返回实际读取消息的字节数, 失败返回 -1, 并设置 erron
 */
ssize_t msgrcv(int msqid, void *msgp, size_t msgsz, long msgtyp, int msgflg);

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

/*
 * msqid：消息队列 ID
 * cmd：控制命令，例如 IPC_RMID 删除命令
 * buf：存储消息队列的相关信息的 buf
 * return：成功根据不同的 cmd 有不同的返回值，失败返回 -1, 并设置 erron
 */
int msgctl(int msqid, int cmd, struct msqid_ds *buf);

// write_msg.c

#include <sys/types.h>
#include <sys/ipc.h>
#include <sys/msg.h>
#include <stdio.h>
#include <string.h>
#include <stdlib.h>

struct msgbuf {
	long mtype;
	char mtext[255];
};

int main() {
	// 1. 创建一个消息队列，用 key = 123 来唯一表示这个队列
	int msg_id = msgget(123, IPC_CREAT | 0666);
	if (msg_id != -1) {

		// 2. 初始化要发生的消息
		struct msgbuf mybuf;
		mybuf.mtype = 1;
		strcpy(mybuf.mtext, "I'm send process.\n");

		// 3. 发送消息
		if (msgsnd(msg_id, &mybuf, sizeof(mybuf.mtext), 0))
			printf("success\n");			
		else
			perror("msgsnd:");
	} else {
		perror("msgget:");
	}

	return 0;
}

// read_msg.c
#include <sys/types.h>
#include <sys/ipc.h>
#include <sys/msg.h>
#include <stdio.h>
#include <string.h>
#include <stdlib.h>

struct msgbuf {
	long mtype;
	char mtext[255];
};

int main() {
	// 1. 获取消息队列
	int msg_id = msgget(123, IPC_CREAT | 0666);
	if (msg_id != -1) {
		struct msgbuf mybuf;
		// 2. 接收第一条消息，存到 mybuf 中
		if (msgrcv(msg_id, &mybuf, sizeof(mybuf.mtext), 0, IPC_NOWAIT) != -1) {
			printf("read success: %s\n", mybuf.mtext);
			// 3. 接收完就删除这个消息队列
			if (msgctl(msg_id, IPC_RMID, 0) != -1)
				printf("delete msg success\n");
		} else {
			perror("msgsnd:");
		}

	} else {
		perror("msgget:");
	}

	return 0;
}

// Linux 3.4: _msg_sm.h
struct msg_queue {
	struct list_head list_elem;
	struct msg_mgr *msg_mgr;
	u32 max_msgs;		/* Node message depth */
	u32 msgq_id;		/* Node environment pointer */
	struct list_head msg_free_list;	/* Free MsgFrames ready to be filled */

	/* Filled MsgFramess waiting to be read */
	struct list_head msg_used_list;
	void *arg;		/* Handle passed to mgr on_exit callback */
	struct sync_object *sync_event;	/* Signalled when message is ready */
	struct sync_object *sync_done;	/* For synchronizing cleanup */
	struct sync_object *sync_done_ack;	/* For synchronizing cleanup */
	struct ntfy_object *ntfy_obj;	/* For notification of message ready */
	bool done;		/* TRUE <==> deleting the object */
	u32 io_msg_pend;	/* Number of pending MSG_get/put calls */
};

int	msgget(key, msgflg)
	key_t key;
	int msgflg;
{
	return INLINE_SYSCALL (ipc, 5, IPCOP_msgget, key, msgflg, 0, NULL);
}