一、什么是共享內存
- 共享內存就是允許兩個不相關的進程訪問同一個邏輯內存。共享內存是在兩個正在運行的進程之間共享和傳遞數據的一種非常有效的方式。不同進程之間共享的內存通常為同一段物理內存。使用共享內存進行通信的進程都需要同一段共享內存連接到它們自己的地址空間中,從而所有進程都可以訪問共享內存中的數據,這段內存就好像由C語言函數malloc()分配的一樣。而如果某個進程向共享內存寫入數據,所做的改動將立即影響到可以訪問同一段共享內存的其他進程
- 特別提醒:共享內存并未提供同步機制,也就是說,在第一個進程結束對共享內存的寫操作之前,并無機制可以阻止第二個進程對內存數據的讀取。
- 可以使用信號量來同步對共享內存的訪問
二、共享內存的使用
- 與信號量一樣,在Linux中也提供了一組函數接口用于使用共享內存,而且使用共享共存的接口還與信號量的非常相似,而且比使用信號量的接口來得簡單。它們聲明在頭文件?sys/shm.h?中。
1、shmget()函數
- 該函數用來創建共享內存,它的原型為:
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,它表示允許一個進程創建的共享內存被內存創建者所擁有的進程向共享內存讀取和寫入數據,同時其他用戶創建的進程只能讀取共享內存。
2、shmat()函數 ? ?-- at:attach
- 第一次創建完共享內存時,它還不能被任何進程訪問,shmat()函數的作用就是用來啟動對該共享內存的訪問,并把共享內存連接到當前進程的地址空間。它的原型如下:
void *shmat(int shm_id, const void *shm_addr, int shmflg);
- 第一個參數,shm_id是由shmget()函數返回的共享內存標識。
- 第二個參數,shm_addr指定共享內存連接到當前進程中的地址位置,通常為空,表示讓系統來選擇共享內存的地址。
- 第三個參數,shm_flg是一組標志位,通常為0。
- 調用成功時返回一個指向共享內存第一個字節的指針,如果調用失敗返回-1.
3、shmdt()函數 ? ?-- dt:detach
- 該函數用于將共享內存從當前進程中分離。注意,將共享內存分離并不是刪除它,只是使該共享內存對當前進程不再可用。它的原型如下:
int?shmdt(const void *shmaddr);
- 參數shmaddr是shmat()函數返回的地址指針,調用成功時返回0,失敗時返回-1.
4、shmctl()函數 ? ?-- ctl:control
- 與信號量的semctl()函數一樣,用來控制共享內存,它的原型如下:
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結構 至少包括以下成員:
struct shmid_ds
{uid_t shm_perm.uid;uid_t shm_perm.gid;mode_t shm_perm.mode;
};
三、使用共享內存進行進程間通信
- 說了這么多,又到了實戰的時候了。下面就以兩個不相關的進程來說明進程間如何通過共享內存來進行通信。其中一個文件shmread.c創建共享內存,并讀取其中的信息,另一個文件shmwrite.c向共享內存中寫入數據。為了方便操作和數據結構的統一,為這兩個文件定義了相同的數據結構,定義在文件shmdata.c中。結構shared_use_st中的written作為一個可讀或可寫的標志,非0:表示可讀,0:表示可寫,text則是內存中的文件。
- 將shmdata.h和shmread.h作為一個工程
- 將shmdata.h和shmwrite.h作為一個工程
- 先執行shmread.h的代碼,再執行shmwrite.h的代碼
-
shmdata.h的源代碼如下:
#ifndef _SHMDATA_H_HEADER
#define _SHMDATA_H_HEADER#define TEXT_SZ 2048struct shared_use_st
{int written; // 作為一個標志,非0:表示可讀,0:表示可寫char text[TEXT_SZ]; // 記錄寫入 和 讀取 的文本
};#endif
-
shmread.h
#include <cstdlib>
#include <cstdio>
#include <sys/shm.h>
#include <unistd.h>
#include <cstring>#include "shmdata.h"
int main() {void *shm = nullptr;struct shared_use_st *shared;int shmid;// 創建共享內存shmid = shmget((key_t)1234,sizeof(struct shared_use_st),0666|IPC_CREAT);if (shmid == -1){fprintf(stderr,"shmat failed\n");exit(EXIT_FAILURE);}// 將共享內存連接到當前進程的地址空間shm = shmat(shmid,0,0);if (shm == (void *)-1){fprintf(stderr,"shmat failed\n");exit(EXIT_FAILURE);}printf("Memory attched at %p\n", &shm);shared = (struct shared_use_st*)shm;shared->written = 0;while (1){if (shared->written == 1){printf("You wrote:%s",shared->text);sleep(1);// 讀取完數據,設置written使共享內存段可寫shared->written =0;if (strncmp(shared->text,"end",3) == 0){break;}}else{sleep(1);}}// 把共享內存從當前進程中分離if (shmdt(shm) == -1){fprintf(stderr,"shmat failed\n");exit(EXIT_FAILURE);}// 刪除共享內存if (shmctl(shmid,IPC_RMID,0) ==-1){fprintf(stderr, "shmctl(IPC_RMID) failed\n");exit(EXIT_FAILURE);}exit(EXIT_SUCCESS);
}
-
shmwrite.h
#include <cstdlib>
#include <cstdio>
#include <cstring>
#include <sys/shm.h>
#include <unistd.h>
#include "shmdata.h"int main(int argc, char **argv)
{void *shm = NULL;struct shared_use_st *shared = NULL;char buffer[BUFSIZ + 1]; // 用于保存輸入的文本int shmid;// 創建共享內存shmid = shmget((key_t)1234, sizeof(struct shared_use_st), 0666|IPC_CREAT);if (shmid == -1){fprintf(stderr, "shmget failed\n");exit(EXIT_FAILURE);}// 將共享內存連接到當前的進程地址空間shm = shmat(shmid, (void *)0, 0);if (shm == (void *)-1){fprintf(stderr, "shmat failed\n");exit(EXIT_FAILURE);}printf("Memory attched at %p\n", &shm);// 設置共享內存shared = (struct shared_use_st *)shm;while (1) // 向共享內存中寫數據{// 數據還沒有被讀取,則等待數據被讀取,不能向共享內存中寫入文本while (shared->written == 1){sleep(1);printf("Waiting...\n");}// 向共享內存中寫入數據printf("Enter some text: ");fgets(buffer, BUFSIZ, stdin);strncpy(shared->text, buffer, TEXT_SZ);// 寫完數據,設置written使共享內存段可讀shared->written = 1;// 輸入了end,退出循環(程序)if (strncmp(buffer, "end", 3) == 0){break;}}// 把共享內存從當前進程中分離if (shmdt(shm) == -1){fprintf(stderr, "shmdt failed\n");exit(EXIT_FAILURE);}sleep(2);exit(EXIT_SUCCESS);
}
輸出結果
分析
- 程序shmread創建共享內存,然后將它連接到自己的地址空間。在共享內存的開始處使用了一個結構struct_use_st。該結構中有個標志written,當共享內存中有其他進程向它寫入數據時,共享內存中的written被設置為0,程序等待。當它不為0時,表示沒有進程對共享內存寫入數據,程序就從共享內存中讀取數據并輸出,然后重置設置共享內存中的written為0,即讓其可被shmwrite進程寫入數據。
- 程序shmwrite取得共享內存并連接到自己的地址空間中。檢查共享內存中的written,是否為0,若不是,表示共享內存中的數據還沒有被完,則等待其他進程讀取完成,并提示用戶等待。若共享內存的written為0,表示沒有其他進程對共享內存進行讀取,則提示用戶輸入文本,并再次設置共享內存中的written為1,表示寫完成,其他進程可對共享內存進行讀操作。
四、關于前面的例子的安全性討論
- 這個程序是不安全的,當有多個程序同時向共享內存中讀寫數據時,問題就會出現。可能你會認為,可以改變一下written的使用方式,例如,只有當written為0時進程才可以向共享內存寫入數據,而當一個進程只有在written不為0時才能對其進行讀取,同時把written進行加1操作,讀取完后進行減1操作。這就有點像文件鎖中的讀寫鎖的功能。咋看之下,它似乎能行得通。但是這都不是原子操作,所以這種做法是行不能的。試想當written為0時,如果有兩個進程同時訪問共享內存,它們就會發現written為0,于是兩個進程都對其進行寫操作,顯然不行。當written為1時,有兩個進程同時對共享內存進行讀操作時也是如些,當這兩個進程都讀取完是,written就變成了-1.
- 要想讓程序安全地執行,就要有一種進程同步的進制,保證在進入臨界區的操作是原子操作。例如,可以使用前面所講的信號量來進行進程的同步。因為信號量的操作都是原子性的。
五、使用共享內存的優缺點
- 優點:我們可以看到使用共享內存進行進程間的通信真的是非常方便,而且函數的接口也簡單,數據的共享還使進程間的數據不用傳送,而是直接訪問內存,也加快了程序的效率。同時,它也不像匿名管道那樣要求通信的進程有一定的父子關系。
- 缺點:共享內存沒有提供同步的機制,這使得我們在使用共享內存進行進程間通信時,往往要借助其他的手段來進行進程間的同步工作。
參考鏈接
- shmget