程序間通訊 訊息佇列

2021-09-25 04:03:27 字數 3083 閱讀 8847

訊息佇列(message queue):是訊息的鍊錶,存放在核心中並由訊息佇列識別符號標識

訊息佇列提供了乙個從乙個程序向另乙個程序傳送資料塊的方法,每個資料塊都可以被認為是有乙個型別,接收者接受的資料塊可以有不同的型別。

訊息佇列函式:

#include #include #include int msgget(key_t key, int msgflag);
key:訊息佇列名稱,用ftok()產生

msgflag:ipc_creat或者ipc_excl,如果訊息佇列不存在則建立之,如果存在則開啟返回;單獨使用ipc_excl是沒有意義的;兩個同時使用,如果訊息佇列不存在則建立之,如果存在則出錯返回。

返回值:成功返回非負整數,即訊息佇列的標識碼,失敗返回-1

#include #include key_t ftok(const char *pathname, int proj_id);
返回值:成功返回乙個key值,用於建立訊息佇列,失敗返回-1

#include #include #include int msgctl(int msqid, int cmd, struct msqid_ds *buf);
mgqid:由msgget函式返回的訊息佇列標識

cmd:命令,這邊有三個命令

返回值:成功返回0,失敗返回-1

#include #include #include int msgsnd(int msqid, const void *msgp, size_t msgsz, int msg***);
msgid:msgget函式返回的訊息佇列標識碼

msgp:指標指向準備傳送的訊息

msgsz:msgp指向的訊息的長度

msg***:預設為0

返回值:成功返回0,失敗返回-1

傳送的訊息結構:

struct msgbuf

;

ssize_t msgrcv(int msqid, void *msgp, size_t msgsz, long msgtyp, int msg***);
msgid:msgget函式返回的訊息佇列標識碼

msgp:指標指向準備傳送的訊息

msgsz:msgp指向的訊息的長度

msgtyp:訊息型別

msg***:預設為0

#ifndef _comm_h_

#define _comm_h_

#include #include #include #include #include #include struct msgbuf

;#define server_type 1

#define client_type 2

int createmsgqueue();

int getmsgqueue();

int destorymsgqueue(int msg_id);

int sendmsgqueue(int msg_id, int who, char *msg);

int recvmsgqueue(int msg_id, int recvtype, char out);

#endif

#include "comm.h"

static int commmsgqueue(int cmd)

int msg_id = msgget(key, cmd);

if(msg_id < 0)

return msg_id;

}int createmsgqueue()

int getmsgqueue()

int destorymsgqueue(int msg_id)

return 0;

}int sendmsgqueue(int msg_id, int type, char *msg)

return 0;

}int recvmsgqueue(int msg_id, int recvtype, char out)

strncpy(out, buf.mtext, size);

out[size] = 0;

return 0;

}

#include "comm.h"

int main()

; while(1)*/}

destorymsgqueue(msgid);

return 0;

}

#include "comm.h"

int main()

; while(1)

//recvmsgqueue(msgid, server_type, buf);

//printf("server#%s\n", buf);

}return 0;

}

client傳送訊息:

[root@live*** tmp]# ./client

msgid:360448

please enter:aaaa

please enter:bbbbb

please enter:heiil

please enter:quit

[root@live*** tmp]#

server接收訊息:

[root@live*** tmp]# ./server

msgid = 360448

client:aaaa

client:bbbbb

client:heiil

[root@live*** tmp]#

其中,有兩個重要的命令:

ipcs -q :檢視ipc資源

ipcrm -q:刪除ipc資源

參考:

程序間訊息佇列通訊

要保證server能夠接收client的訊息,就必須保證server的生成的msg的識別符號是一樣的,也就是兩個用的key是必須一樣的。msglucy.c include include include include include include include include include ...

程序間通訊(訊息佇列)

在嵌入式linux應用開發中,linux程序通訊的方式有6種,分別是管道 pipe 及有名管道 named pipe 訊號 signal 訊息佇列 msg 共享記憶體 shm 訊號量 和套接字 socket 在這我就簡單的描述一下程序通訊中的資訊佇列 msg 首先,訊息佇列的實現有重要的幾步 1 建...

程序間通訊 訊息佇列

有三種稱作xsi ipc的ipc 訊息佇列 訊號量以及 共享記憶體。它們只見有很多的相似之處。訊息佇列是訊息的鏈結表,儲存在核心中,由訊息佇列識別符號表示。它不同於管道,其生命週期是隨核心的。訊息佇列提供了 一種從 乙個程序向另 乙個程序傳送 乙個資料塊的 方法。每個資料塊都被認為是有 乙個型別,接...