訊息佇列

1.建立新訊息佇列或取得已存在訊息佇列

key：可以認為是一個埠號，也可以由函式ftok生成。

msgflg：  

如果單獨使用IPC_CREAT，XXXget()函式要麼返一個已經存在的共享記憶體的操作符，要麼返回一個新建的共享記憶體的識別符號。

如果將IPC_CREAT和IPC_EXCL標誌一起使用，XXXget()將返回一個新建的IPC識別符號

IPC_EXEL標誌本身並沒有太大的意義，但是和IPC_CREAT標誌一起使用可以用來保證所得的物件是新建的，而不是開啟已有的物件。

2.向佇列讀/寫訊息

 msgid：訊息佇列的標識

struct msgstru{

long mtype; //大於0

msgsz：訊息的大小。

msgtyp：從訊息佇列內讀取的訊息形態。如果值為零，則表示訊息佇列中的所有訊息都會被讀取。

msgflg：用來指明核心程式在佇列沒有資料的情況下所應採取的行動。如果msgflg和常數IPC_NOWAIT合用，則在msgsnd()執行時若是訊息佇列已滿，則msgsnd()將不會阻塞，而會立即返回-1，如果執行的是msgrcv()，則在訊息佇列呈空時，不做等待馬上返回-1，並設定錯誤碼為ENOMSG。當msgflg為0時，msgsnd()及msgrcv()在佇列呈滿或呈空的情形時，採取阻塞等待的處理模式。

3.設定訊息佇列屬性

引數：msgctl 系統呼叫對 msgqid 標識的訊息佇列執行 cmd 操作，系統定義了 3 種 cmd 操作IPC_STAT , IPC_SET , IPC_RMID

IPC_STAT : 該命令用來獲取訊息佇列對應的 msqid_ds 資料結構，並將其儲存到 buf 指定的地址空間。

IPC_SET : 該命令用來設定訊息佇列的屬性，要設定的屬性儲存在buf中。  

IPC_RMID : 從核心中刪除 msqid 標識的訊息佇列。

4、程式碼如下

Makefile中的程式碼

client_=client
server_=server
cc=gcc
cliSrc=client.c comm.c
serSrc=server.c comm.c

.PHONY:all
all:$(client_) $(server_)

$(client_):$(cliSrc)
$(cc) -o [email protected] $^
$(server_):$(serSrc)
$(cc) -o [email protected] $^

.PHONY:clean
clean:
rm -f $(client_) $(server_)

1、標頭檔案comm.h中的程式碼

#ifndef _COMM_H_
#define _COMM_H_

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

#define PATHNAME "."
#define PROJ_ID 0x6666

#define SIZE 128

#define SERVER_TYPE 1
#define CLIENT_TYPE 2

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

int createMsgQueue();
int getMsgQueue();
int sendMsg(int msgid,long type,const char* info);
int recvMsg(int msgid,long type,char out[]);
int destroyMsgQueue(int);

#endif

2、編寫檔案comm.c中的程式碼

#include"comm.h"
int commMsgQueue(int flag)
{
key_t k = ftok(PATHNAME,PROJ_ID);
if(k < 0){
perror("ftok");
return -1;
}

int msg_id = msgget(k,flag);
if(msg_id < 0){
perror("msg_id");
return -2;
}
return msg_id;
}

int createMsgQueue()
{
return commMsgQueue(IPC_CREAT|IPC_EXCL|0666);
}
int getMsgQueue()
{
return commMsgQueue(IPC_CREAT);
}

int sendMsg(int msgid,long type,const char* info)
{
struct msgbuf msg;
msg .mtype = type;
strcpy(msg.mtext,info);
if(msgsnd(msgid,&msg,sizeof(msg.mtext),0) < 0){
perror("msgsnd");
return -1;
}
return 0;
}
int recvMsg(int msgid,long type,char out[] )//recrve
{
struct msgbuf msg;
if(msgrcv(msgid,&msg,sizeof(msg.mtext),type,0) < 0){
perror("recvMsg");
return -1;
}
strcpy(out,msg.mtext);
return 0;
}

int destroyMsgQueue(int msgid)
{
if(msgctl(msgid,IPC_RMID,NULL) < 0){
perror("msgctl");
return -1;
}
return 0;
}

3、伺服器端程式碼

#include"comm.h"
int main()
{
int msgid = createMsgQueue();
printf("msgid: %d\n",msgid);
char buf[SIZE];
while(1){
recvMsg(msgid,CLIENT_TYPE,buf);
printf("client# %s\n",buf);
printf("please Enter$");
fflush(stdout);
  ssize_t s = read(0,buf,sizeof(buf)-1);
if(s > 0){
buf[s-1] = '\0';
sendMsg(msgid,SERVER_TYPE,buf);
}
}
destroyMsgQueue(msgid);
return 0;
}

4、客戶端程式碼

#include"comm.h"
int main()
{
int msgid = getMsgQueue();
printf("msgid: %d\n",msgid);
//int i = 0;
char buf[SIZE];
while(1){
printf("please Enter$");
fflush(stdout);
  ssize_t s = read(0,buf,sizeof(buf)-1);
if(s > 0){
buf[s-1] = '\0';
     sendMsg(msgid,CLIENT_TYPE,buf);
sleep(1);
// i++;
}
recvMsg(msgid,SERVER_TYPE,buf);
printf("server# %s\n",buf);
}
// destroyMsgQueue(msgid);
return 0;
}

執行客戶端提示輸入：

執行伺服器端接收然後提示輸入：