Linux進程間通訊——使用共享內存

時間  2019-11-24
標籤 linux 進程 通訊 使用 共享 內存 欄目 Linux 简体版
原文   原文鏈接
下面將講解進程間通訊的另外一種方式，使用共享內存。
 
1、什麼是共享內存
顧名思義，共享內存就是容許兩個不相關的進程訪問同一個邏輯內存。共享內存是在兩個正在運行的進程之間共享和傳遞數據的一種很是有效的方式。不一樣進程之間共享的內存一般安排爲同一段物理內存。進程能夠將同一段共享內存鏈接到它們本身的地址空間中，全部進程均可以訪問共享內存中的地址，就好像它們是由用C語言函數malloc分配的內存同樣。而若是某個進程向共享內存寫入數據，所作的改動將當即影響到能夠訪問同一段共享內存的任何其餘進程。
 
特別提醒：共享內存並未提供同步機制，也就是說，在第一個進程結束對共享內存的寫操做以前，並沒有自動機制能夠阻止第二個進程開始對它進行讀取。因此咱們一般須要用其餘的機制來同步對共享內存的訪問，例如前面說到的信號量。有關信號量的更多內容，能夠查閱個人另外一篇文章： Linux進程間通訊——使用信號量
 
2、共享內存的使得
與信號量同樣，在Linux中也提供了一組函數接口用於使用共享內存，並且使用共享共存的接口還與信號量的很是類似，並且比使用信號量的接口來得簡單。它們聲明在頭文件 sys/shm.h中。
 
一、shmget函數
該函數用來建立共享內存，它的原型爲：
[cpp]  view plain copy print ? 在CODE上查看代碼片 派生到個人代碼片
 
  1. int shmget(key_t key, size_t size, int shmflg);  
第一個參數，與信號量的semget函數同樣，程序須要提供一個參數key（非0整數），它有效地爲共享內存段命名，shmget函數成功時返回一個與key相關的共享內存標識符（非負整數），用於後續的共享內存函數。調用失敗返回-1.
 
不相關的進程能夠經過該函數的返回值訪問同一共享內存，它表明程序可能要使用的某個資源，程序對全部共享內存的訪問都是間接的，程序先經過調用shmget函數並提供一個鍵，再由系統生成一個相應的共享內存標識符（shmget函數的返回值），只有shmget函數才直接使用信號量鍵，全部其餘的信號量函數使用由semget函數返回的信號量標識符。
 
第二個參數，size以字節爲單位指定須要共享的內存容量
 
第三個參數，shmflg是權限標誌，它的做用與open函數的mode參數同樣，若是要想在key標識的共享內存不存在時，建立它的話，能夠與IPC_CREAT作或操做。共享內存的權限標誌與文件的讀寫權限同樣，舉例來講，0644,它表示容許一個進程建立的共享內存被內存建立者所擁有的進程向共享內存讀取和寫入數據，同時其餘用戶建立的進程只能讀取共享內存。
 
二、shmat函數
第一次建立完共享內存時，它還不能被任何進程訪問，shmat函數的做用就是用來啓動對該共享內存的訪問，並把共享內存鏈接到當前進程的地址空間。它的原型以下：
[cpp]  view plain copy print ? 在CODE上查看代碼片 派生到個人代碼片
 
  1. void *shmat(int shm_id, const void *shm_addr, int shmflg);  
第一個參數，shm_id是由shmget函數返回的共享內存標識。
第二個參數，shm_addr指定共享內存鏈接到當前進程中的地址位置，一般爲空，表示讓系統來選擇共享內存的地址。
第三個參數，shm_flg是一組標誌位，一般爲0。
 
調用成功時返回一個指向共享內存第一個字節的指針，若是調用失敗返回-1.
 
三、shmdt函數
該函數用於將共享內存從當前進程中分離。注意，將共享內存分離並非刪除它，只是使該共享內存對當前進程再也不可用。它的原型以下：
[cpp]  view plain copy print ? 在CODE上查看代碼片 派生到個人代碼片
 
  1. int shmdt(const void *shmaddr);  
參數shmaddr是shmat函數返回的地址指針，調用成功時返回0，失敗時返回-1.
 
四、shmctl函數
與信號量的semctl函數同樣，用來控制共享內存，它的原型以下：
[cpp]  view plain copy print ? 在CODE上查看代碼片 派生到個人代碼片
 
  1. int shmctl(int shm_id, int command, struct shmid_ds *buf);  
第一個參數，shm_id是shmget函數返回的共享內存標識符。
 
第二個參數，command是要採起的操做，它能夠取下面的三個值 ：
    IPC_STAT：把shmid_ds結構中的數據設置爲共享內存的當前關聯值，即用共享內存的當前關聯值覆蓋shmid_ds的值。
    IPC_SET：若是進程有足夠的權限，就把共享內存的當前關聯值設置爲shmid_ds結構中給出的值
    IPC_RMID：刪除共享內存段
 
第三個參數，buf是一個結構指針，它指向共享內存模式和訪問權限的結構。
shmid_ds結構至少包括如下成員：
 
[cpp]  view plain copy print ? 在CODE上查看代碼片 派生到個人代碼片
 
  1. struct shmid_ds  
  2. {  
  3.     uid_t shm_perm.uid;  
  4.     uid_t shm_perm.gid;  
  5.     mode_t shm_perm.mode;  
  6. };  

 

 
3、使用共享內存進行進程間通訊
說了這麼多，又到了實戰的時候了。下面就以兩個不相關的進程來講明進程間如何經過共享內存來進行通訊。其中一個文件shmread.c建立共享內存，並讀取其中的信息，另外一個文件shmwrite.c向共享內存中寫入數據。爲了方便操做和數據結構的統一，爲這兩個文件定義了相同的數據結構，定義在文件shmdata.c中。結構shared_use_st中的written做爲一個可讀或可寫的標誌，非0：表示可讀，0表示可寫，text則是內存中的文件。
 
shmdata.c的源代碼以下：
 
[cpp]  view plain copy print ? 在CODE上查看代碼片 派生到個人代碼片
 
  1. #ifndef _SHMDATA_H_HEADER  
  2. #define _SHMDATA_H_HEADER  
  3.   
  4. #define TEXT_SZ 2048  
  5.   
  6. struct shared_use_st  
  7. {  
  8.     int written;//做爲一個標誌，非0：表示可讀，0表示可寫  
  9.     char text[TEXT_SZ];//記錄寫入和讀取的文本  
  10. };  
  11.   
  12. #endif  
源文件shmread.c的源代碼以下：
 
[cpp]  view plain copy print ? 在CODE上查看代碼片 派生到個人代碼片
 
  1. #include <unistd.h>  
  2. #include <stdlib.h>  
  3. #include <stdio.h>  
  4. #include <sys/shm.h>  
  5. #include "shmdata.h"  
  6.   
  7. int main()  
  8. {  
  9.     int running = 1;//程序是否繼續運行的標誌  
  10.     void *shm = NULL;//分配的共享內存的原始首地址  
  11.     struct shared_use_st *shared;//指向shm  
  12.     int shmid;//共享內存標識符  
  13.     //建立共享內存  
  14.     shmid = shmget((key_t)1234, sizeof(struct shared_use_st), 0666|IPC_CREAT);  
  15.     if(shmid == -1)  
  16.     {  
  17.         fprintf(stderr, "shmget failed\n");  
  18.         exit(EXIT_FAILURE);  
  19.     }  
  20.     //將共享內存鏈接到當前進程的地址空間  
  21.     shm = shmat(shmid, 0, 0);  
  22.     if(shm == (void*)-1)  
  23.     {  
  24.         fprintf(stderr, "shmat failed\n");  
  25.         exit(EXIT_FAILURE);  
  26.     }  
  27.     printf("\nMemory attached at %X\n", (int)shm);  
  28.     //設置共享內存  
  29.     shared = (struct shared_use_st*)shm;  
  30.     shared->written = 0;  
  31.     while(running)//讀取共享內存中的數據  
  32.     {  
  33.         //沒有進程向共享內存定數據有數據可讀取  
  34.         if(shared->written != 0)  
  35.         {  
  36.             printf("You wrote: %s", shared->text);  
  37.             sleep(rand() % 3);  
  38.             //讀取完數據，設置written使共享內存段可寫  
  39.             shared->written = 0;  
  40.             //輸入了end，退出循環（程序）  
  41.             if(strncmp(shared->text, "end", 3) == 0)  
  42.                 running = 0;  
  43.         }  
  44.         else//有其餘進程在寫數據，不能讀取數據  
  45.             sleep(1);  
  46.     }  
  47.     //把共享內存從當前進程中分離  
  48.     if(shmdt(shm) == -1)  
  49.     {  
  50.         fprintf(stderr, "shmdt failed\n");  
  51.         exit(EXIT_FAILURE);  
  52.     }  
  53.     //刪除共享內存  
  54.     if(shmctl(shmid, IPC_RMID, 0) == -1)  
  55.     {  
  56.         fprintf(stderr, "shmctl(IPC_RMID) failed\n");  
  57.         exit(EXIT_FAILURE);  
  58.     }  
  59.     exit(EXIT_SUCCESS);  
  60. }  
源文件shmwrite.c的源代碼以下：
 
[cpp]  view plain copy print ? 在CODE上查看代碼片 派生到個人代碼片
 
  1. #include <unistd.h>  
  2. #include <stdlib.h>  
  3. #include <stdio.h>  
  4. #include <string.h>  
  5. #include <sys/shm.h>  
  6. #include "shmdata.h"  
  7.   
  8. int main()  
  9. {  
  10.     int running = 1;  
  11.     void *shm = NULL;  
  12.     struct shared_use_st *shared = NULL;  
  13.     char buffer[BUFSIZ + 1];//用於保存輸入的文本  
  14.     int shmid;  
  15.     //建立共享內存  
  16.     shmid = shmget((key_t)1234, sizeof(struct shared_use_st), 0666|IPC_CREAT);  
  17.     if(shmid == -1)  
  18.     {  
  19.         fprintf(stderr, "shmget failed\n");  
  20.         exit(EXIT_FAILURE);  
  21.     }  
  22.     //將共享內存鏈接到當前進程的地址空間  
  23.     shm = shmat(shmid, (void*)0, 0);  
  24.     if(shm == (void*)-1)  
  25.     {  
  26.         fprintf(stderr, "shmat failed\n");  
  27.         exit(EXIT_FAILURE);  
  28.     }  
  29.     printf("Memory attached at %X\n", (int)shm);  
  30.     //設置共享內存  
  31.     shared = (struct shared_use_st*)shm;  
  32.     while(running)//向共享內存中寫數據  
  33.     {  
  34.         //數據尚未被讀取，則等待數據被讀取,不能向共享內存中寫入文本  
  35.         while(shared->written == 1)  
  36.         {  
  37.             sleep(1);  
  38.             printf("Waiting...\n");  
  39.         }  
  40.         //向共享內存中寫入數據  
  41.         printf("Enter some text: ");  
  42.         fgets(buffer, BUFSIZ, stdin);  
  43.         strncpy(shared->text, buffer, TEXT_SZ);  
  44.         //寫完數據，設置written使共享內存段可讀  
  45.         shared->written = 1;  
  46.         //輸入了end，退出循環（程序）  
  47.         if(strncmp(buffer, "end", 3) == 0)  
  48.             running = 0;  
  49.     }  
  50.     //把共享內存從當前進程中分離  
  51.     if(shmdt(shm) == -1)  
  52.     {  
  53.         fprintf(stderr, "shmdt failed\n");  
  54.         exit(EXIT_FAILURE);  
  55.     }  
  56.     sleep(2);  
  57.     exit(EXIT_SUCCESS);  
  58. }  
再來看看運行的結果：
 
 
分析：
一、程序shmread建立共享內存，而後將它鏈接到本身的地址空間。在共享內存的開始處使用了一個結構struct_use_st。該結構中有個標誌written，當共享內存中有其餘進程向它寫入數據時，共享內存中的written被設置爲0，程序等待。當它不爲0時，表示沒有進程對共享內存寫入數據，程序就從共享內存中讀取數據並輸出，而後重置設置共享內存中的written爲0，即讓其可被shmwrite進程寫入數據。
 
二、程序shmwrite取得共享內存並鏈接到本身的地址空間中。檢查共享內存中的written，是否爲0，若不是，表示共享內存中的數據尚未被完，則等待其餘進程讀取完成，並提示用戶等待。若共享內存的written爲0，表示沒有其餘進程對共享內存進行讀取，則提示用戶輸入文本，並再次設置共享內存中的written爲1，表示寫完成，其餘進程可對共享內存進行讀操做。
 
4、關於前面的例子的安全性討論
這個程序是不安全的，當有多個程序同時向共享內存中讀寫數據時，問題就會出現。可能你會認爲，能夠改變一下written的使用方式，例如，只有當written爲0時進程才能夠向共享內存寫入數據，而當一個進程只有在written不爲0時才能對其進行讀取，同時把written進行加1操做，讀取完後進行減1操做。這就有點像文件鎖中的讀寫鎖的功能。咋看之下，它彷佛能行得通。可是這都不是原子操做，因此這種作法是行不能的。試想當written爲0時，若是有兩個進程同時訪問共享內存，它們就會發現written爲0，因而兩個進程都對其進行寫操做，顯然不行。當written爲1時，有兩個進程同時對共享內存進行讀操做時也是如些，當這兩個進程都讀取完是，written就變成了-1.
 
要想讓程序安全地執行，就要有一種進程同步的進制，保證在進入臨界區的操做是原子操做。例如，可使用前面所講的信號量來進行進程的同步。由於信號量的操做都是原子性的。
 
5、使用共享內存的優缺點
一、優勢：咱們能夠看到使用共享內存進行進程間的通訊真的是很是方便，並且函數的接口也簡單，數據的共享還使進程間的數據不用傳送，而是直接訪問內存，也加快了程序的效率。同時，它也不像匿名管道那樣要求通訊的進程有必定的父子關係。
 
二、缺點：共享內存沒有提供同步的機制，這使得咱們在使用共享內存進行進程間通訊時，每每要藉助其餘的手段來進行進程間的同步工做。
相關文章
相關標籤/搜索
每日一句
    每一个你不满意的现在，都有一个你没有努力的曾经。
本站公眾號
   歡迎關注本站公眾號,獲取更多信息
聯繫我們 最近搜索 最新文章 沪ICP备13005482号-10 MyBatis教程 SQL 教程 MySQL教程 Java 教程 Thymeleaf 教程 Hibernate教程 Spring教程 Redis教程