0
  • 聊天消息
  • 系統(tǒng)消息
  • 評論與回復
登錄后你可以
  • 下載海量資料
  • 學習在線課程
  • 觀看技術視頻
  • 寫文章/發(fā)帖/加入社區(qū)
會員中心
創(chuàng)作中心

完善資料讓更多小伙伴認識你,還能領取20積分哦,立即完善>

3天內不再提示

進程間通信的實現(xiàn)方式

strongerHuang ? 來源:嵌入式藝術 ? 作者:嵌入式藝術 ? 2022-10-28 09:03 ? 次閱讀

在系統(tǒng)中,隨著我們的進程越來越多,難免不同進程之間要互相傳輸一些數(shù)據(jù),那么這個時候該怎么辦呢?

下面主要簡單了解一下,進程間通信(InterProcess Communication,IPC)的幾種實現(xiàn)方式!

1、管道模型

管道模型與軟件生命周期模型——瀑布模型(Waterfall Model)很相似。 所謂的瀑布模型,其實就是將整個軟件開發(fā)過程分成多個階段,往往是上一個階段完全做完,才將輸出結果交給下一個階段。
還記得咱們最初學 Linux 命令的時候,有下面這樣一行命令:

ps -ef | grep 關鍵字 | awk '{print $2}' | xargs kill -9

這里面的豎線“|”就是一個管道。它會將前一個命令的輸出,作為后一個命令的輸入。

從管道的這個名稱可以看出來,管道是一種單向傳輸數(shù)據(jù)的機制,它其實是一段緩存,里面的數(shù)據(jù)只能從一端寫入,從另一端讀出。如果想互相通信,我們需要創(chuàng)建兩個管道才行。 管道又可以分為匿名管道和命名管道!

1.1 匿名管道

如上命令:

ps -ef | grep 關鍵字 | awk '{print $2}' | xargs kill -9
匿名管道:用"|” 表示的管道,意思就是這個類型的管道沒有名字,用完了就銷毀了。豎線代表的管道隨著命令的執(zhí)行自動創(chuàng)建、自動銷毀。用戶甚至都不知道自己在用管道這種技術,就已經(jīng)解決了問題。

1.2 命名管道

命名管道,這個類型的管道需要通過 mkfifo 命令顯式地創(chuàng)建。

mkfifo donge#建立一個管道
donge就是這個管道的名稱。管道以文件的形式存在,這也符合 Linux 里面一切皆文件的原則。 下面我們看一下文件類型
ls -l
prw-rw-r-- 1 dong dong     0 Sep 28 17:09 donge
可以看到,這個文件的類型是 p,就是 pipe 的意思。 往管道中寫入數(shù)據(jù)
echo "hello world" > donge
這個時候,管道里面的內容沒有被讀出,這個命令就是停在這里的,即進程被堵塞。

這說明當一個項目組要把它的輸出交接給另一個項目組做輸入,當沒有交接完畢的時候,前一個項目組是不能撒手不管的。

重新打開一個終端,讀出管道數(shù)據(jù)

cat < hello 
hello world
一方面,我們能夠看到,管道里面的內容被讀取出來,打印到了終端上; 另一方面,echo 那個命令正常退出了,也即交接完畢,前一個項目組就完成了使命,可以解散了。 管道通信,我們可以看出,瀑布模型的開發(fā)流程效率比較低下,因為團隊之間無法頻繁地溝通。而且,管道的使用模式,也不適合進程間頻繁的交換數(shù)據(jù)。

2、消息隊列

消息隊列可以理解為發(fā)郵件,每一封郵件都視為一個獨立的數(shù)據(jù)單元,也就是消息體,每個消息體都是固定大小的存儲塊,在字節(jié)流上不連續(xù)。

這個消息結構的定義我寫在下面了。這里面的類型 type 和正文 text 沒有強制規(guī)定,只要消息的發(fā)送方和接收方約定好即可。

struct msg_buffer {
    long mtype;
    char mtext[1024];
};

2.1 創(chuàng)建消息隊列

消息隊列的創(chuàng)建,需要用到msgget函數(shù)

int msgget(key_t key, int msgflg);

key:該參數(shù)是消息隊列的唯一標識,由ftok生成。

msgflg:取值有以下幾個選擇:IPC_CREAT、IPC_EXCL ,這兩個參數(shù)詳細的作用可以man msgflg看詳細介紹。

返回值:返回一個近乎唯一的Message queue id

那么,key是如何由ftok生成的呢?

我們可以指定一個文件,調用ftok ,它會根據(jù)這個文件的 inode,生成一個近乎唯一的 key。

key_t ftok(const char *pathname, int proj_id);

pathname:文件信息,必須指定在一個存在的,可訪問的文件

proj_id:8bit的數(shù)據(jù),0-255隨意設定

這樣就可以獲得一個近乎唯一的key了!

只要在這個消息隊列的生命周期內,這個文件不要被刪除就可以了。只要不刪除,無論什么時刻,再調用 ftok,也會得到同樣的 key。

綜上,創(chuàng)建一個消息隊列只需兩步:

①:ftok生成一個key

②:msgget生成一個消息隊列的ID

如下:

#include 
#include 
#include 
 
 
int main() {
  int messagequeueid;
  key_t key;
 
 
  if((key = ftok("/root/messagequeue/messagequeuekey", 1)) < 0)
  {
      perror("ftok error");
      exit(1);
  }
 
 
  printf("Message Queue key: %d.
", key);
 
 
  if ((messagequeueid = msgget(key, IPC_CREAT|0777)) == -1)
  {
      perror("msgget error");
      exit(1);
  }
 
 
  printf("Message queue id: %d.
", messagequeueid);
}

ftok要指定一個存在的文件,所以我們在執(zhí)行之前,需要創(chuàng)建該文件。

查看消息隊列

System V IPC 體系有一個統(tǒng)一的命令行工具:ipcmk,ipcs 和 ipcrm 用于創(chuàng)建、查看和刪除 IPC 對象。

查看創(chuàng)建的IPC對象:ipcs -q

dong@ubuntu:~//Interprocess_Communication$ ipcs 

------ Message Queues --------
key        msqid      owner      perms      used-bytes   messages    
0x01110005 0          dong       777        0            0           

------ Shared Memory Segments --------
key        shmid      owner      perms      bytes      nattch     status      

------ Semaphore Arrays --------
key        semid      owner      perms      nsems

2.2 發(fā)送消息

消息隊列發(fā)送消息,主要調用msgsnd 函數(shù)

int msgsnd(int msqid, const void *msgp, size_t msgsz, int msgflg);

msqid:該參數(shù)是msgget所得到的message queue 的 id

msgp:消息結構體

struct msg_buffer {
    long mtype;
    char mtext[1024];
};

msgsz:表示消息結構體中,mtext最大長度

msgflg:一位掩碼,可取值有:IPC_NOWAIT、MSG_COPY、MSG_EXCEPT、MSG_NOERROR,取值說明可見man msgsnd

2.3 接收消息

消息隊列接收消息,主要調用msgrcv 函數(shù)

ssize_t msgrcv(int msqid, void *msgp, size_t msgsz, long msgtyp,
                      int msgflg);

msqid:該參數(shù)是msgget所得到的message queue 的 id

msgp:消息結構體

msgsz:可接收數(shù)據(jù)最大長度

msgflg:一位掩碼,可取值有:IPC_NOWAIT、MSG_COPY、MSG_EXCEPT、MSG_NOERROR,取值說明可見man msgsnd

有了消息這種模型,兩個進程之間的通信就像咱們平時發(fā)郵件一樣,你來一封,我回一封,可以頻繁溝通了。

3、共享內存

image-20220924172026172

怎么理解共享內存呢?

我們知道每個進程都有自己獨立的虛擬內存空間,不同的進程的虛擬內存空間映射到不同的物理內存中去。這個進程訪問 A 地址和另一個進程訪問 A 地址,其實訪問的是不同的物理內存地址,對于數(shù)據(jù)的增刪查改互不影響。

但是,咱們是不是可以變通一下,拿出一塊虛擬地址空間來,映射到相同的物理內存中。這樣這個進程寫入的東西,另外一個進程馬上就能看到了,都不需要拷貝來拷貝去,傳來傳去。

相比于消息隊列,共享內存的優(yōu)勢在哪里呢?

大數(shù)據(jù)傳輸:如果批量的大數(shù)據(jù)進行傳輸,使用郵件的方式,來去發(fā)送不及時,并且大小也有限制

實時性:用共享內存,其可以大大節(jié)省通信時間

3.1 創(chuàng)建共享內存

我們可以創(chuàng)建一個共享內存,調用 shmget。

int shmget(key_t key, size_t size, int shmflg);

key:和 msgget 里面的 key 一樣,都是唯一定位一個共享內存的對象

size:共享內存的大小

shmflg:其值可以?。篒PC_CREAT、IPC_EXCL、SHM_HUGETLB、SHM_HUGE_2MB等

返回值:共享內存的唯一ID

創(chuàng)建完畢之后,我們可以通過 ipcs 命令查看這個共享內存。

#ipcs --shmems
 
------ Shared Memory Segments ------ --------
key        shmid    owner perms    bytes nattch status
0x00000000 19398656 marc  600    1048576 2      dest

3.2 訪問共享內存

接下來,如果一個進程想要訪問這一段共享內存,需要將這個內存加載到自己的虛擬地址空間的某個位置,通過 shmat 函數(shù),就是 attach 的意思。

void *shmat(int shmid, const void *shmaddr, int shmflg);

shmid:標識一個共享內存段的唯一ID

shmaddr:就是要指定 attach 到這個地方。但是這個地址的設定難度比較大,除非對于內存布局非常熟悉,否則可能會 attach到一個非法地址。所以,通常的做法是將 shmaddr設為 NULL,讓內核選一個合適的地址。

shmflg:一位掩碼,可取值:SHM_EXEC、SHM_RDONLY、SHM_REMAP。

返回值:為所連接的實際地址

3.3 關閉共享內存

如果共享內存使用完畢,可以通過 shmdt 解除綁定,然后通過 shmctl,將 cmd 設置為 IPC_RMID,從而刪除這個共享內存對象。

int shmdt(void *addr); 
int shmctl(int shmid, int cmd, struct shmid_ds *buf);

shmdt的參數(shù)addr:為shmat的返回值,表示卸載一片共享內存

shmctl的參數(shù):

shm_id:shmget的返回值,為共享內存的唯一ID

cmd:取值有:IPC_STAT、IPC_RMID等,見:man shmctl

buf:共享內存管理結構體。

3.4 信號

這里你是不是有一個疑問,如果兩個進程 attach 同一個共享內存,大家都往里面寫東西,很有可能就沖突了。例如兩個進程都同時寫一個地址,那先寫的那個進程會發(fā)現(xiàn)內容被別人覆蓋了。

所以,這里就需要一種保護機制,使得同一個共享的資源,同時只能被一個進程訪問。在 System V IPC 進程間通信機制體系中,早就想好了應對辦法,就是信號量(Semaphore)。因此,信號量和共享內存往往要配合使用。

信號量和共享內存都比較復雜,兩者還要結合起來用,就更加復雜,它們內核的機制就更加復雜。這一節(jié)我們先不講。

4、信號

上面講的進程間通信的方式,都是常規(guī)狀態(tài)下的工作模式,對應到咱們平時的工作交接,收發(fā)郵件、聯(lián)合開發(fā)等,其實還有一種異常情況下的工作模式。

例如出現(xiàn)線上系統(tǒng)故障,這個時候,什么流程都來不及了,不可能發(fā)郵件,也來不及開會,所有的架構師、開發(fā)、運維都要被通知緊急出動。所以,7 乘 24 小時不間斷執(zhí)行的系統(tǒng)都需要有告警系統(tǒng),一旦出事情,就要通知到人,哪怕是半夜,也要電話叫起來,處理故障。

信號可以在任何時候發(fā)送給某一進程,進程需要為這個信號配置信號處理函數(shù)。

Linux所支持的異常信號如下:

 1) SIGHUP       2) SIGINT       3) SIGQUIT      4) SIGILL       5) SIGTRAP
 6) SIGABRT      7) SIGBUS       8) SIGFPE       9) SIGKILL     10) SIGUSR1
11) SIGSEGV     12) SIGUSR2     13) SIGPIPE     14) SIGALRM     15) SIGTERM
16) SIGSTKFLT   17) SIGCHLD     18) SIGCONT     19) SIGSTOP     20) SIGTSTP
21) SIGTTIN     22) SIGTTOU     23) SIGURG      24) SIGXCPU     25) SIGXFSZ
26) SIGVTALRM   27) SIGPROF     28) SIGWINCH    29) SIGIO       30) SIGPWR
31) SIGSYS      34) SIGRTMIN    35) SIGRTMIN+1  36) SIGRTMIN+2  37) SIGRTMIN+3
38) SIGRTMIN+4  39) SIGRTMIN+5  40) SIGRTMIN+6  41) SIGRTMIN+7  42) SIGRTMIN+8
43) SIGRTMIN+9  44) SIGRTMIN+10 45) SIGRTMIN+11 46) SIGRTMIN+12 47) SIGRTMIN+13
48) SIGRTMIN+14 49) SIGRTMIN+15 50) SIGRTMAX-14 51) SIGRTMAX-13 52) SIGRTMAX-12
53) SIGRTMAX-11 54) SIGRTMAX-10 55) SIGRTMAX-9  56) SIGRTMAX-8  57) SIGRTMAX-7
58) SIGRTMAX-6  59) SIGRTMAX-5  60) SIGRTMAX-4  61) SIGRTMAX-3  62) SIGRTMAX-2
63) SIGRTMAX-1  64) SIGRTMAX

當某個信號發(fā)生的時候,就默認執(zhí)行這個函數(shù)就可以了。這就相當于咱們運維一個系統(tǒng)應急手冊,當遇到什么情況,做什么事情,都事先準備好,出了事情照著做就可以了。

有點類似于異常中斷……

審核編輯:彭靜
聲明:本文內容及配圖由入駐作者撰寫或者入駐合作網(wǎng)站授權轉載。文章觀點僅代表作者本人,不代表電子發(fā)燒友網(wǎng)立場。文章及其配圖僅供工程師學習之用,如有內容侵權或者其他違規(guī)問題,請聯(lián)系本站處理。 舉報投訴
  • 數(shù)據(jù)

    關注

    8

    文章

    6772

    瀏覽量

    88655
  • 通信
    +關注

    關注

    18

    文章

    5931

    瀏覽量

    135720
  • 模型
    +關注

    關注

    1

    文章

    3081

    瀏覽量

    48592
收藏 人收藏

    評論

    相關推薦

    Linux下進程如何實現(xiàn)共享內存通信

    這次我們來講一下Linux進程通信中重要的通信方式:共享內存作為Linux軟件開發(fā)攻城獅,進程
    發(fā)表于 04-26 17:14 ?665次閱讀

    Linux下進程通信方式-管道

    Linux下進程通信方式-管道分享到: 本文關鍵字: linux 管道通信,linux 進程
    發(fā)表于 08-29 15:29

    管道文件如何實現(xiàn)兩個進程通信

    管道文件如何實現(xiàn)兩個進程通信
    發(fā)表于 01-11 16:54

    進程通信方式有哪些?

    進程通信方式有哪些?
    發(fā)表于 12-24 06:46

    怎樣通過匿名管道去實現(xiàn)進程通信

    進程通信是指什么?怎樣通過匿名管道去實現(xiàn)進程通信呢?有哪些步驟?
    發(fā)表于 12-24 06:45

    哪些方式可以實現(xiàn)Linux系統(tǒng)下的進程通信

    哪些方式可以實現(xiàn)Linux系統(tǒng)下的進程通信?進程與線程有哪些不同之處呢?
    發(fā)表于 12-24 06:38

    進程通信之Linux下進程通信概述

    在上一章中,讀者已經(jīng)知道了進程是一個程序的一次執(zhí)行。這里所說的進程一般是指運行在用戶態(tài)的進程,而由于處于用戶態(tài)的不同進程之間是彼此隔離的,就像處于不同城市的人們,它們必須通過某種
    發(fā)表于 10-18 16:21 ?0次下載

    如何實現(xiàn)進程通信(IPC)?

    1、管道( pipe ) 既可在程序中使用,也可在shell中使用。 管道是一種半雙工的通信方式,數(shù)據(jù)只能單向流動。 管道的問題在于他們沒有名字,只能在具有親緣關系(父子進程)的
    發(fā)表于 11-29 13:33 ?9111次閱讀

    linux進程通信方式

    共享內存 是被多個進程共享的一部分物理內存。共享內存是進程共享數(shù)據(jù)的一種最快的方法,一個進程向共享內存區(qū)域寫入了數(shù)據(jù),共享這個內存區(qū)域的所有
    發(fā)表于 03-06 10:11 ?494次閱讀

    進程與線程通信方式

    進程通信則不同,它的數(shù)據(jù)空間的獨立性決定了它的通信相對比較復雜,需要通過操作系統(tǒng)。以前進程
    的頭像 發(fā)表于 04-09 15:58 ?8867次閱讀
    <b class='flag-5'>進程</b><b class='flag-5'>間</b>與線程<b class='flag-5'>間</b>的<b class='flag-5'>通信</b><b class='flag-5'>方式</b>

    Linux進程通信方式——管道

    管道是Linux中進程通信的一種方式,它把一個程序的輸出直接連接到另一個程序的輸入。Linux的管道主要包括兩種:無名管道和有名管道。
    發(fā)表于 06-01 09:13 ?1358次閱讀
    Linux<b class='flag-5'>進程</b><b class='flag-5'>間</b><b class='flag-5'>通信</b><b class='flag-5'>方式</b>——管道

    使用MQTT作為進程通信方式

    小編對Linux這一塊的實際開發(fā)經(jīng)驗雖然還不是很足,但也知道進程通信有那么幾種方式:管道、消息隊列、共享內存、套接字等。
    的頭像 發(fā)表于 10-22 12:09 ?5982次閱讀
    使用MQTT作為<b class='flag-5'>進程</b><b class='flag-5'>間</b><b class='flag-5'>通信</b>的<b class='flag-5'>方式</b>

    常見的進程通信方式

    進程通信 如果兩個進程,想要知道對方在干嘛,或者進行協(xié)調運行,就需要進程
    的頭像 發(fā)表于 10-08 15:48 ?1258次閱讀
    常見的<b class='flag-5'>進程</b><b class='flag-5'>間</b><b class='flag-5'>通信</b><b class='flag-5'>方式</b>

    進程通信方式總結

    進程通信(IPC): 進程通信方式有很多,這里
    的頭像 發(fā)表于 11-09 09:25 ?664次閱讀
    <b class='flag-5'>進程</b><b class='flag-5'>間</b><b class='flag-5'>通信</b><b class='flag-5'>方式</b>總結

    進程通信的消息隊列介紹

    消息隊列是一種非常常見的進程通信方式
    的頭像 發(fā)表于 04-08 17:27 ?266次閱讀