共享內存可以說是最有用的進程間通信方式,也是最快的
IPC
形式。兩個不同進程
A
、
B
共享內存的意思是,同一塊物理內存被映射到進程
A
、
B
各自的進程地址空間。進程
A
可以即時看到進程
B
對共享內存中數據的更新,反之亦然。由于多個進程共享同一塊內存區域,必然需要某種同步機制,互斥鎖和信號量都可以。
采用共享內存通信的一個顯而易見的好處是效率高,因為進程可以直接讀寫內存,而不需要任何數據的拷貝。對于像管道和消息隊列等通信方式,則需要在內核和用戶空間進行四次的數據拷貝,而共享內存則只拷貝兩次數據
[1]
:
一次從輸入文件到共享內存區,另一次從共享內存區到輸出文件。實際上,進程之間在共享內存時,并不總是讀寫少量數據后就解除映射,有新的通信時,再重新建
立共享內存區域。而是保持共享區域,直到通信完畢為止,這樣,數據內容一直保存在共享內存中,并沒有寫回文件。共享內存中的內容往往是在解除映射時才寫回
文件的。因此,采用共享內存的通信方式效率是非常高的。
Linux
的
2.2.x
內核支持多種共享內存方式,如
mmap()
系統調用,
Posix
共享內存,以及系統
V
共享內存。
linux
發行版本如
Redhat 8.0
支持
mmap()
系統調用及系統
V
共享內存,但還沒實現
Posix
共享內存,本文將主要介紹
mmap()
系統調用及系統
V
共享內存
API
的原理及應用。
一、內核怎樣保證各個進程尋址到同一個共享內存區域的內存頁面
1
、
page cache
及
swap cache
中頁面的區分:一個被訪問文件的物理頁面都駐留在
page cache
或
swap cache
中,一個頁面的所有信息由
struct page
來描述。
struct page
中有一個域為指針
mapping
,它指向一個
struct address_space
類型結構。
page cache
或
swap cache
中的所有頁面就是根據
address_space
結構以及一個偏移量來區分的。
2
、文件與
address_space
結構的對應:一個具體的文件在打開后,內核會在內存中為之建立一個
struct inode
結構,其中的
i_mapping
域指向一個
address_space
結構。這樣,一個文件就對應一個
address_space
結構,一個
address_space
與一個偏移量能夠確定一個
page cache
或
swap cache
中的一個頁面。因此,當要尋址某個數據時,很容易根據給定的文件及數據在文件內的偏移量而找到相應的頁面。
3
、進程調用
mmap()
時,只是在進程空間內新增了一塊相應大小的緩沖區,并設置了相應的訪問標識,但并沒有建立進程空間到物理頁面的映射。因此,第一次訪問該空間時,會引發一個缺頁異常。
4
、對于共享內存映射情況,缺頁異常處理程序首先在
swap cache
中尋找目標頁(符合
address_space
以及偏移量的物理頁),如果找到,則直接返回地址;如果沒有找到,則判斷該頁是否在交換區
(swap area)
,如果在,則執行一個換入操作;如果上述兩種情況都不滿足,處理程序將分配新的物理頁面,并把它插入到
page cache
中。進程最終將更新進程頁表。
注:對于映射普通文件情況(非共享映射),缺頁異常處理程序首先會在
page cache
中根據
address_space
以及數據偏移量尋找相應的頁面。如果沒有找到,則說明文件數據還沒有讀入內存,處理程序會從磁盤讀入相應的頁面,并返回相應地址,同時,進程頁表也會更新。
5
、所有進程在映射同一個共享內存區域時,情況都一樣,在建立線性地址與物理地址之間的映射之后,不論進程各自的返回地址如何,實際訪問的必然是同一個共享內存區域對應的物理頁面。
注:一個共享內存區域可以看作是特殊文件系統
shm
中的一個文件,
shm
的安裝點在交換區上。
上面涉及到了一些數據結構,圍繞數據結構理解問題會容易一些。
二、
mmap()
及其相關系統調用
mmap()
系統調用使得進程之間通過映射同一個普通文件實現共享內存。普通文件被映射到進程地址空間后,進程可以向訪問普通內存一樣對文件進行訪問,不必再調用
read()
,
write
()等操作。
注:實際上,
mmap()
系統調用并不是完全為了用于共享內存而設計的。它本身提供了不同于一般對普通文件的訪問方式,進程可以像讀寫內存一樣對普通文件的操作。而
Posix
或系統
V
的共享內存
IPC
則純粹用于共享目的,當然
mmap()
實現共享內存也是其主要應用之一。
1
、
mmap()
系統調用形式如下:
void* mmap ( void * addr , size_t len , int prot , int flags , int fd , off_t offset )
參數
fd
為即將映射到進程空間的文件描述字,一般由
open()
返回,同時,
fd
可以指定為
-1
,此時須指定
flags
參數中的
MAP_ANON
,表明進行的是匿名映射(不涉及具體的文件名,避免了文件的創建及打開,很顯然只能用于具有親緣關系的進程間通信)。
len
是映射到調用進程地址空間的字節數,它從被映射文件開頭
offset
個字節開始算起。
prot
參數指定共享內存的訪問權限??扇∪缦聨讉€值的或:
PROT_READ
(可讀)
, PROT_WRITE
(可寫)
, PROT_EXEC
(可執行)
, PROT_NONE
(不可訪問)。
flags
由以下幾個常值指定:
MAP_SHARED , MAP_PRIVATE , MAP_FIXED
,其中,
MAP_SHARED , MAP_PRIVATE
必選其一,而
MAP_FIXED
則不推薦使用。
offset
參數一般設為
0
,表示從文件頭開始映射。參數
addr
指定文件應被映射到進程空間的起始地址,一般被指定一個空指針,此時選擇起始地址的任務留給內核來完成。函數的返回值為最后文件映射到進程空間的地址,進程可直接操作起始地址為該值的有效地址。這里不再詳細介紹
mmap()
的參數,讀者可參考
mmap()
手冊頁獲得進一步的信息。
2
、系統調用
mmap()
用于共享內存的兩種方式:
(
1
)使用普通文件提供的內存映射:適用于任何進程之間;此時,需要打開或創建一個文件,然后再調用
mmap()
;典型調用代碼如下:
?
????? fd=open(name, flag, mode);
if(fd<0)
????? ...
?????
|
ptr=mmap(NULL, len , PROT_READ|PROT_WRITE, MAP_SHARED , fd , 0);
通過
mmap()
實現共享內存的通信方式有許多特點和要注意的地方,我們將在范例中進行具體說明。
(
2
)使用特殊文件提供匿名內存映射:適用于具有親緣關系的進程之間;由于父子進程特殊的親緣關系,在父進程中先調用
mmap()
,然后調用
fork()
。那么在調用
fork()
之后,子進程繼承父進程匿名映射后的地址空間,同樣也繼承
mmap()
返回的地址,這樣,父子進程就可以通過映射區域進行通信了。注意,這里不是一般的繼承關系。一般來說,子進程單獨維護從父進程繼承下來的一些變量。而
mmap()
返回的地址,卻由父子進程共同維護。
對于具有親緣關系的進程實現共享內存最好的方式應該是采用匿名內存映射的方式。此時,不必指定具體的文件,只要設置相應的標志即可,參見范例
2
。
3
、系統調用
munmap()
int munmap( void * addr, size_t len )
該調用在進程地址空間中解除一個映射關系,
addr
是調用
mmap()
時返回的地址,
len
是映射區的大小。當映射關系解除后,對原來映射地址的訪問將導致段錯誤發生。
4
、系統調用
msync()
int msync ( void * addr , size_t len, int flags)
一般說來,進程在映射空間的對共享內容的改變并不直接寫回到磁盤文件中,往往在調用
munmap
()后才執行該操作。可以通過調用
msync()
實現磁盤上文件內容與共享內存區的內容一致。
三、
mmap()
范例
下面將給出使用
mmap()
的兩個范例:范例
1
給出兩個進程通過映射普通文件實現共享內存通信;范例
2
給出父子進程通過匿名映射實現共享內存。系統調用
mmap()
有許多有趣的地方,下面是通過
mmap
()映射普通文件實現進程間的通信的范例,我們通過該范例來說明
mmap()
實現共享內存的特點及注意事項。
范例
1
:兩個進程通過映射普通文件實現共享內存通信
范例
1
包含兩個子程序:
map_normalfile1.c
及
map_normalfile2.c
。編譯兩個程序,可執行文件分別為
map_normalfile1
及
map_normalfile2
。兩個程序通過命令行參數指定同一個文件來實現共享內存方式的進程間通信。
map_normalfile2
試圖打開命令行參數指定的一個普通文件,把該文件映射到進程的地址空間,并對映射后的地址空間進行寫操作。
map_normalfile1
把命令行參數指定的文件映射到進程地址空間,然后對映射后的地址空間執行讀操作。這樣,兩個進程通過命令行參數指定同一個文件來實現共享內存方式的進程間通信。
下面是兩個程序代碼:
?
/*-------------map_normalfile1.c-----------*/
#include <sys/mman.h>
#include <sys/types.h>
#include <fcntl.h>
#include <unistd.h>
typedef struct{
????? char name[4];
????? int? age;
}people;
?
main(int argc, char** argv) // map a normal file as shared mem:
{
????? int fd,i;
????? people *p_map;
????? char temp;
?????
????? fd=open(argv[1],O_CREAT|O_RDWR|O_TRUNC,00777);
????? lseek(fd,sizeof(people)*5-1,SEEK_SET);
????? write(fd,"",1);
?????
????? p_map = (people*) mmap( NULL,sizeof(people)*10,PROT_READ|PROT_WRITE,MAP_SHARED,fd,0 );
????? close( fd );
????? temp = 'a';
????? for(i=0; i<10; i++)
????? {
??????????? temp += 1;
??????????? memcpy( ( *(p_map+i) ).name, &temp,2 );
??????????? ( *(p_map+i) ).age = 20+i;
????? }
????? printf(" initialize over \n ")
;
????? sleep(10);
?
????? munmap( p_map, sizeof(people)*10 );
????? printf( "umap ok \n" );
}
?
/*-------------map_normalfile2.c-----------*/
#include <sys/mman.h>
#include <sys/types.h>
#include <fcntl.h>
#include <unistd.h>
typedef struct{
????? char name[4];
????? int? age;
}people;
?
main(int argc, char** argv)??? // map a normal file as shared mem:
{
????? int fd,i;
????? people *p_map;
????? fd=open( argv[1],O_CREAT|O_RDWR,00777 );
????? p_map = (people*)mmap(NULL,sizeof(people)*10,PROT_READ|PROT_WRITE,MAP_SHARED,fd,0);
????? for(i = 0;i<10;i++)
????? {
????? printf( "name: %s age %d;\n",(*(p_map+i)).name, (*(p_map+i)).age );
?
????? }
????? munmap( p_map,sizeof(people)*10 );
}
|
?
map_normalfile1.c
首先定義了一個
people
數據結構,(在這里采用數據結構的方式是因為,共享內存區的數據往往是有固定格式的,這由通信的各個進程決定,采用結構的方式有普遍代表性)。
map_normfile1
首先打開或創建一個文件,并把文件的長度設置為
5
個
people
結構大小。然后從
mmap()
的返回地址開始,設置了
10
個
people
結構。然后,進程睡眠
10
秒鐘,等待其他進程映射同一個文件,最后解除映射。
map_normfile2.c
只是簡單的映射一個文件,并以
people
數據結構的格式從
mmap()
返回的地址處讀取
10
個
people
結構,并輸出讀取的值,然后解除映射。
分別把兩個程序編譯成可執行文件
map_normalfile1
和
map_normalfile2
后,在一個終端上先運行
./map_normalfile2 /tmp/test_shm
,程序輸出結果如下:
?
initialize over
umap ok
|
?
在
map_normalfile1
輸出
initialize over
之后,輸出
umap ok
之前,在另一個終端上運行
map_normalfile2 /tmp/test_shm
,將會產生如下輸出
(
為了節省空間,輸出結果為稍作整理后的結果
)
:
?
name: b???? age 20;???? name: c???? age 21;???? name: d???? age 22;????? name: e???? age 23;???? name: f???? age 24;
name: g???? age 25;???? name: h???? age 26;???? name: I???? age 27;????? name: j???? age 28;???? name: k???? age 29;
|
?
在
map_normalfile1
輸出
umap ok
后,運行
map_normalfile2
則輸出如下結果:
?
name: b???? age 20;???? name: c???? age 21;???? name: d???? age 22;????? name: e???? age 23;???? name: f???? age 24;
name:age 0;????? name:age 0;????? name:age 0;name:age 0;????? name:????? age 0;
|
?
從程序的運行結果中可以得出的結論
1
、
最終被映射文件的內容的長度不會超過文件本身的初始大小,即映射不能改變文件的大??;
2
、
可以用于進程通信的有效地址空間大小大體上受限于被映射文件的大小,但不完全受限于文件大小。打開文件被截短為
5
個
people
結構大小,而在
map_normalfile1
中初始化了
10
個
people
數據結構,在恰當時候(
map_normalfile1
輸出
initialize over
之后,輸出
umap ok
之前)調用
map_normalfile2
會發現
map_normalfile2
將輸出全部
10
個
people
結構的值,后面將給出詳細討論。
注:在
linux
中,內存的保護是以頁為基本單位的,即使被映射文件只有一個字節大小,內核也會為映射分配一個頁面大小的內存。當被映射文件小于一個頁面大小時,進程可以對從
mmap()
返回地址開始的一個頁面大小進行訪問,而不會出錯;但是,如果對一個頁面以外的地址空間進行訪問,則導致錯誤發生,后面將進一步描述。因此,可用于進程間通信的有效地址空間大小不會超過文件大小及一個頁面大小的和。
3
、
文件一旦被映射后,調用
mmap()
的進程對返回地址的訪問是對某一內存區域的訪問,暫時脫離了磁盤上文件的影響。所有對
mmap()
返回地址空間的操作只在內存中有意義,只有在調用了
munmap()
后或者
msync()
時,才把內存中的相應內容寫回磁盤文件,所寫內容仍然不能超過文件的大小。
范例
2
:父子進程通過匿名映射實現共享內存
?
#include <sys/mman.h>
#include <sys/types.h>
#include <fcntl.h>
#include <unistd.h>
typedef struct{
????? char name[4];
????? int? age;
}people;
main(int argc, char** argv)
{
????? int i;
????? people *p_map;
????? char temp;
????? p_map=(people*)mmap(NULL,sizeof(people)*10,PROT_READ|PROT_WRITE,MAP_SHARED|MAP_ANONYMOUS,-1,0);
????? if(fork() == 0)
????? {
??????????? sleep(2);
??????????? for(i = 0;i<5;i++)
????????????????? printf("child read: the %d people's age is %d\n",i+1,(*(p_map+i)).age);
??????????? (*p_map).age = 100;
??????????? munmap(p_map,sizeof(people)*10); //
實際上,進程終止時,會自動解除映射。
??????????? exit();
????? }
????? temp = 'a';
????? for(i = 0;i<5;i++)
????? {
??????????? temp += 1;
??????????? memcpy((*(p_map+i)).name, &temp,2);
??????????? (*(p_map+i)).age=20+i;
????? }
?
????? sleep(5);
????? printf( "parent read: the first people,s age is %d\n",(*p_map).age );
????? printf("umap\n");
????? munmap( p_map,sizeof(people)*10 );
????? printf( "umap ok\n" );
}
|
?
考察程序的輸出結果,體會父子進程匿名共享內存:
?
child read: the 1 people's age is 20
child read: the 2 people's age is 21
child read: the 3 people's age is 22
child read: the 4 people's age is 23
child read: the 5 people's age is 24
?
parent read: the first people,s age is 100
umap
umap ok
|
?
?
四、對
mmap()
返回地址的訪問
前面對范例運行結構的討論中已經提到,
linux
采用的是頁式管理機制。對于用
mmap()
映射普通文件來說,進程會在自己的地址空間新增一塊空間,空間大小由
mmap()
的
len
參數指定,注意,進程并不一定能夠對全部新增空間都能進行有效訪問。進程能夠訪問的有效地址大小取決于文件被映射部分的大小。簡單的說,能夠容納文件被映射部分大小的最少頁面個數決定了進程從
mmap()
返回的地址開始,能夠有效訪問的地址空間大小。超過這個空間大小,內核會根據超過的嚴重程度返回發送不同的信號給進程??捎萌缦聢D示說明:
注意:文件被映射部分而不是整個文件決定了進程能夠訪問的空間大小,另外,如果指定文件的偏移部分,一定要注意為頁面大小的整數倍。下面是對進程映射地址空間的訪問范例:
?
#include <sys/mman.h>
#include <sys/types.h>
#include <fcntl.h>
#include <unistd.h>
typedef struct{
????? char name[4];
????? int? age;
}people;
?
main(int argc, char** argv)
{
????? int fd,i;
????? int pagesize,offset;
????? people *p_map;
?????
????? pagesize = sysconf(_SC_PAGESIZE);
????? printf("pagesize is %d\n",pagesize);
????? fd = open(argv[1],O_CREAT|O_RDWR|O_TRUNC,00777);
????? lseek(fd,pagesize*2-100,SEEK_SET);
????? write(fd,"",1);
????? offset = 0;//
此處
offset = 0
編譯成版本
1
;
offset = pagesize
編譯成版本
2
????? p_map = (people*)mmap(NULL,pagesize*3,PROT_READ|PROT_WRITE,MAP_SHARED,fd,offset);
????? close(fd);
?????
????? for(i = 1; i<10; i++)
????? {
??????????? (*(p_map+pagesize/sizeof(people)*i-2)).age = 100;
??????????? printf("access page %d over\n",i);
??????????? (*(p_map+pagesize/sizeof(people)*i-1)).age = 100;
??????????? printf("access page %d edge over, now begin to access page %d\n",i, i+1);
??????????? (*(p_map+pagesize/sizeof(people)*i)).age = 100;
??????????? printf("access page %d over\n",i+1);
????? }
????? munmap(p_map,sizeof(people)*10);
}
|
?
如程序中所注釋的那樣,把程序編譯成兩個版本,兩個版本主要體現在文件被映射部分的大小不同。文件的大小介于一個頁面與兩個頁面之間(大小為:
pagesize*2-99
),版本
1
的被映射部分是整個文件,版本
2
的文件被映射部分是文件大小減去一個頁面后的剩余部分,不到一個頁面大小
(
大小為:
pagesize-99)
。程序中試圖訪問每一個頁面邊界,兩個版本都試圖在進程空間中映射
pagesize*3
的字節數。
版本
1
的輸出結果如下:
?
pagesize is 4096
access page 1 over
access page 1 edge over, now begin to access page 2
access page 2 over
access page 2 over
access page 2 edge over, now begin to access page 3
Bus error???????? //
被映射文件在進程空間中覆蓋了兩個頁面,此時,進程試圖訪問第三個頁面
|
?
版本
2
的輸出結果如下:
?
pagesize is 4096
access page 1 over
access page 1 edge over, now begin to access page 2
Bus error???????? //
被映射文件在進程空間中覆蓋了一個頁面,此時,進程試圖訪問第二個頁面
|
?
結論:采用系統調用
mmap()
實現進程間通信是很方便的,在應用層上接口非常簡潔。內部實現機制區涉及到了
linux
存儲管理以及文件系統等方面的內容,可以參考一下相關重要數據結構來加深理解。在本專題的后面部分,將介紹系統
v
共享內存的實現。
?
共享內存(下)
在共享內存(上)中,主要圍繞著系統調用
mmap()
進行討論的,本部分將討論系統
V
共享內存,并通過實驗結果對比來闡述兩者的異同。系統
V
共享內存指的是把所有共享數據放在共享內存區域(
IPC shared memory region
),任何想要訪問該數據的進程都必須在本進程的地址空間新增一塊內存區域,用來映射存放共享數據的物理內存頁面。
系統調用
mmap()
通過映射一個普通文件實現共享內存。系統
V
則是通過映射特殊文件系統
shm
中的文件實現進程間的共享內存通信。也就是說,每個共享內存區域對應特殊文件系統
shm
中的一個文件(這是通過
shmid_kernel
結構聯系起來的),后面還將闡述。
1
、系統
V
共享內存原理
進程間需要共享的數據被放在一個叫做
IPC
共享內存區域的地方,所有需要訪問該共享區域的進程都要把該共享區域映射到本進程的地址空間中去。系統
V
共享內存通過
shmget
獲得或創建一個
IPC
共享內存區域,并返回相應的標識符。內核在保證
shmget
獲得或創建一個共享內存區,初始化該共享內存區相應的
shmid_kernel
結構注同時,還將在特殊文件系統
shm
中,創建并打開一個同名文件,并在內存中建立起該文件的相應
dentry
及
inode
結構,新打開的文件不屬于任何一個進程(任何進程都可以訪問該共享內存區)。所有這一切都是系統調用
shmget
完成的。
注:每一個共享內存區都有一個控制結構
struct shmid_kernel
,
shmid_kernel
是共享內存區域中非常重要的一個數據結構,它是存儲管理和文件系統結合起來的橋梁,定義如下:
?
struct shmid_kernel /* private to the kernel */
{????
????? struct kern_ipc_perm??? shm_perm;
????? struct file *?????????? shm_file;
????? int?????????????? id;
????? unsigned long?????????? shm_nattch;
????? unsigned long?????????? shm_segsz;
????? time_t????????????????? shm_atim;
????? time_t????????????????? shm_dtim;
????? time_t????????????????? shm_ctim;
????? pid_t???????????? shm_cprid;
????? pid_t???????????? shm_lprid;
};
|
?
該結構中最重要的一個域應該是
shm_file
,它存儲了將被映射文件的地址。每個共享內存區對象都對應特殊文件系統
shm
中的一個文件,一般情況下,特殊文件系統
shm
中的文件是不能用
read()
、
write()
等方法訪問的,當采取共享內存的方式把其中的文件映射到進程地址空間后,可直接采用訪問內存的方式對其訪問。
這里我們采用
[1]
中的圖表給出與系統
V
共享內存相關數據結構:
正如消息隊列和信號燈一樣,內核通過數據結構
struct ipc_ids shm_ids
維護系統中的所有共享內存區域。上圖中的
shm_ids.entries
變量指向一個
ipc_id
結構數組,而每個
ipc_id
結構數組中有個指向
kern_ipc_perm
結構的指針。到這里讀者應該很熟悉了,對于系統
V
共享內存區來說,
kern_ipc_perm
的宿主是
shmid_kernel
結構,
shmid_kernel
是用來描述一個共享內存區域的,這樣內核就能夠控制系統中所有的共享區域。同時,在
shmid_kernel
結構的
file
類型指針
shm_file
指向文件系統
shm
中相應的文件,這樣,共享內存區域就與
shm
文件系統中的文件對應起來。
在創建了一個共享內存區域后,還要將它映射到進程地址空間,系統調用
shmat()
完成此項功能。由于在調用
shmget()
時,已經創建了文件系統
shm
中的一個同名文件與共享內存區域相對應,因此,調用
shmat()
的過程相當于映射文件系統
shm
中的同名文件過程,原理與
mmap()
大同小異。
?
?
2
、系統
V
共享內存
API
對于系統
V
共享內存,主要有以下幾個
API
:
shmget()
、
shmat()
、
shmdt()
及
shmctl()
。
?
#include <sys/ipc.h>
#include <sys/shm.h>
|
?
shmget
()用來獲得共享內存區域的
ID
,如果不存在指定的共享區域就創建相應的區域。
shmat()
把共享內存區域映射到調用進程的地址空間中去,這樣,進程就可以方便地對共享區域進行訪問操作。
shmdt()
調用用來解除進程對共享內存區域的映射。
shmctl
實現對共享內存區域的控制操作。這里我們不對這些系統調用作具體的介紹,讀者可參考相應的手冊頁面,后面的范例中將給出它們的調用方法。
注:
shmget
的內部實現包含了許多重要的系統
V
共享內存機制;
shmat
在把共享內存區域映射到進程空間時,并不真正改變進程的頁表。當進程第一次訪問內存映射區域訪問時,會因為沒有物理頁表的分配而導致一個缺頁異常,然后內核再根據相應的存儲管理機制為共享內存映射區域分配相應的頁表。
?
?
3
、系統
V
共享內存限制
在
/proc/sys/kernel/
目錄下,記錄著系統
V
共享內存的一下限制,如一個共享內存區的最大字節數
shmmax
,系統范圍內最大共享內存區標識符數
shmmni
等,可以手工對其調整,但不推薦這樣做。
在
[2]
中,給出了這些限制的測試方法,不再贅述。
?
?
4
、系統
V
共享內存范例
本部分將給出系統
V
共享內存
API
的使用方法,并對比分析系統
V
共享內存機制與
mmap()
映射普通文件實現共享內存之間的差異,首先給出兩個進程通過系統
V
共享內存通信的范例:
?
/***** testwrite.c *******/
#include <sys/ipc.h>
#include <sys/shm.h>
#include <sys/types.h>
#include <unistd.h>
typedef struct{
????? char name[4];
????? int age;
} people;
main(int argc, char** argv)
{
????? int shm_id,i;
????? key_t key;
????? char temp;
????? people *p_map;
????? char* name = "/dev/shm/myshm2";
????? key = ftok(name,0);
????? if(key==-1)
??????????? perror("ftok error");
????? shm_id=shmget(key,4096,IPC_CREAT);??
????? if(shm_id==-1)
????? {
??????????? perror("shmget error");
??????????? return;
????? }
????? p_map=(people*)shmat(shm_id,NULL,0);
????? temp='a';
????? for(i = 0;i<10;i++)
????? {
??????????? temp+=1;
??????????? memcpy((*(p_map+i)).name,&temp,1);
??????????? (*(p_map+i)).age=20+i;
????? }
????? if(shmdt(p_map)==-1)
??????????? perror(" detach error ");
}
/********** testread.c ************/
#include <sys/ipc.h>
#include <sys/shm.h>
#include <sys/types.h>
#include <unistd.h>
typedef struct{
????? char name[4];
????? int age;
} people;
main(int argc, char** argv)
{
????? int shm_id,i;
????? key_t key;
????? people *p_map;
????? char* name = "/dev/shm/myshm2";
????? key = ftok(name,0);
????? if(key == -1)
??????????? perror("ftok error");
????? shm_id = shmget(key,4096,IPC_CREAT);
????? if(shm_id == -1)
????? {
??????????? perror("shmget error");
??????????? return;
????? }
????? p_map = (people*)shmat(shm_id,NULL,0);
????? for(i = 0;i<10;i++)
????? {
????? printf( "name:%s\n",(*(p_map+i)).name );
????? printf( "age %d\n",(*(p_map+i)).age );
????? }
????? if(shmdt(p_map) == -1)
??????????? perror(" detach error ");
}
|
?
testwrite.c
創建一個系統
V
共享內存區,并在其中寫入格式化數據;
testread.c
訪問同一個系統
V
共享內存區,讀出其中的格式化數據。分別把兩個程序編譯為
testwrite
及
testread
,先后執行
./testwrite
及
./testread
則
./testread
輸出結果如下:
?
name: b???? age 20;???? name: c???? age 21;???? name: d???? age 22;????? name: e???? age 23;???? name: f???? age 24;
name: g???? age 25;???? name: h???? age 26;???? name: I???? age 27;????? name: j???? age 28;???? name: k???? age 29;
|
?
通過對試驗結果分析,對比系統
V
與
mmap()
映射普通文件實現共享內存通信,可以得出如下結論:
1
、
系統
V
共享內存中的數據,從來不寫入到實際磁盤文件中去;而通過
mmap()
映射普通文件實現的共享內存通信可以指定何時將數據寫入磁盤文件中。注:前面講到,系統
V
共享內存機制實際是通過映射特殊文件系統
shm
中的文件實現的,文件系統
shm
的安裝點在交換分區上,系統重新引導后,所有的內容都丟失。
2
、
系統
V
共享內存是隨內核持續的,即使所有訪問共享內存的進程都已經正常終止,共享內存區仍然存在(除非顯式刪除共享內存),在內核重新引導之前,對該共享內存區域的任何改寫操作都將一直保留。
3
、
通過調用
mmap()
映射普通文件進行進程間通信時,一定要注意考慮進程何時終止對通信的影響。而通過系統
V
共享內存實現通信的進程則不然。注:這里沒有給出
shmctl
的使用范例,原理與消息隊列大同小異。
?
Trackback: http://tb.blog.csdn.net/TrackBack.aspx?PostId=1006744