目錄

一：訊息佇列

1.1定義

1.2設計方案

1.3知識瞭解

二：程式碼實現

2.1傳送訊息

2.2取用訊息

2.3測試執行

一：訊息佇列

1.1定義

             訊息佇列是訊息的連結表，儲存在核心中，由訊息佇列識別符號 標識。

1.2設計方案

          如圖所示：先呼叫msgget（）獲取一個已存在，或者 建立一個新的佇列。A程序負責傳送某一型別的資料，B程序負責接受相應型別的資料。

1.3知識瞭解

      一：相關結構

        ①訊息結構：

//假設傳送的最長訊息是512個位元組
struct mymesg{
    long mtype; /* positive message type */
    char mtext[512]; /*message data, or length nbytes */
}

        ②每個訊息佇列都會維護一個相關資料結構: msqid_ds

//訊息佇列維護資訊。
struct msqid_ds{
    struct ipc_perm     msg_perm;  //許可權控制
    msgqnum_t           msg_qnum;  //訊息佇列訊息數目
    msglen_t            msg_qbytes;//max # of bytes on queue
    pid_t               msg_lspid; //pid of last msgsnd()上一次傳送訊息的程序
    pid_t               msg_lrpid; //pid of lase msgrcv()上一次接受訊息的程序
    time_t              msg_stime; //last_msgsnd() time

    time_t              msg_rtime; //last_ecvsnd() time
    time_t              msg_ctime; //last_change time
}
    
 

        二：相關函式

            ①函式：msgget

            ②函式：msgctl

          ③函式：msgsnd

        ④函式：msgrcv

二：程式碼實現

2.1傳送訊息

#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <assert.h>
#include <unistd.h>
#include <sys/msg.h>


typedef struct  data
{
	long type;
	char text[512];
}Data;


int main()
{
	int msgid = msgget((key_t)1234, 0666 | IPC_CREAT);//獲取
	assert(msgid != -1);


	Data val;
	memset(&val, 0, sizeof(Data));
	val.type = 1000;
	strcpy(val.text, "hello");

	msgsnd(msgid, &val, strlen(val.text)+sizeof(val.type), 0);
	
	memset(&val, 0, sizeof(Data));
	val.type = 2000;
	strcpy(val.text, "world");

	msgsnd(msgid, &val, strlen(val.text)+sizeof(val.type), 0);

	exit(0);
}

2.2取用訊息

#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <assert.h>
#include <unistd.h>
#include <sys/msg.h>


typedef struct  data
{
	long type;
	char text[512];
}Data;


int main()
{
	int msgid = msgget((key_t)1234, 0666 | IPC_CREAT);
	assert(msgid != -1);


	Data val;
	memset(&val, 0, sizeof(Data));

	//char buff[128] = {0};

	msgrcv(msgid, &val, sizeof(Data), 1000, 0);

	printf("type = %d, text = %s\n", val.type, val.text);

	exit(0);
}

2.3測試執行