版權(quán)聲明：轉(zhuǎn)載時請以超鏈接形式標(biāo)明文章原始出處和作者信息及本聲明
http://xufish.blogbus.com/logs/40537374.html

012號與013 號程序，分別是關(guān)于消息隊列和共享內(nèi)存的

/*********************程序相關(guān)信 息*********************
程序編號：012
程序編寫起始日期：2008.11.1
程序編寫完成日期：2008.11.1
程序修改日 期：                                   修改備注：
程序目的：學(xué)習(xí)linux消息隊列通信
所用主要函 數(shù)：msgget(),msgsnd(),msgrcv(),msgctl()
程序 存疑：
程序完成地點： 宿舍內(nèi)
*********************程序相關(guān)信息*********************/
#include<sys/types.h>
#include<sys/ipc.h>
#include<sys/msg.h>
#include<stdio.h>
#include<string.h>
#include<stdlib.h>
int main()
{
    int pid,msqid;//后者為消息隊列識別代號
    struct msgbuf
    {
        long mtype;//消息類型
        char mtext[20];//消息內(nèi)容
    }send_buf,receive_buf;
    if((msqid=msgget(IPC_PRIVATE,0700))<0)//建立消息隊列
    {
        printf("msgget建立消息隊列失敗。\n");
        exit(1);
    }
    else
        printf("msgget建立消息隊列成功，該消息隊列識別代號為%d。\n",msqid);
    if((pid=fork())<0)
    {
        printf("fork()函數(shù)調(diào)用失敗！\n");
        exit(2);
    }
    else if(pid>0)//父進(jìn)程，發(fā)送消息到消息隊列
    {
        send_buf.mtype=1;
        strcpy(send_buf.mtext,"My test information");
        printf("發(fā)送到消息隊列的信息內(nèi)容為：%s\n",send_buf.mtext);
        if(msgsnd(msqid,&send_buf,20,IPC_NOWAIT)<0)//發(fā)送send_buf中的信息到msqid 對應(yīng)的消息隊列
        {
            printf("msgsnd消息發(fā)送失敗。\n");
            exit(3);
        }
        else
            printf("msgsnd消息發(fā)送成功。\n");
        sleep(2);
        exit(0);
    }
    else//子進(jìn)程，從消息隊列中接收消息]
    {
        sleep(2);//等待父進(jìn)程發(fā)送消息完成
        int infolen;//讀到的信息數(shù)據(jù)長度
        if((infolen=msgrcv(msqid,&receive_buf,20,0,IPC_NOWAIT))<0)//自消息隊列 接收信息
        {
            printf("msgrcv讀取信息錯誤。\n");
            exit(4);
        }
        else
            printf("msgrcv讀取信息成功。\n");
        printf("自消息隊列讀取到的內(nèi)容為%s，共讀取%d個字節(jié)。\n",receive_buf.mtext,infolen);
        if((msgctl(msqid,IPC_RMID,NULL))<0)//刪除msqid對應(yīng)的消息隊列
        {
            printf("msgctl函數(shù)調(diào)用出現(xiàn)錯誤。\n");
            exit(5);
        }
        else
        {
            printf("識別代號為%d的消息隊列已經(jīng)被成功刪除。\n",msqid);
            exit(0);
        }
    }
}
/*********************程序運(yùn)行結(jié) 果*********************
[root@localhost temp]# ./msg
msgget建立消息隊列成功，該消息隊列識別代號為 98304。
發(fā)送到消息隊列的信息內(nèi)容為：My test information
msgsnd消息發(fā)送成功。
msgrcv讀取信息成功。
自消息隊列讀取到的內(nèi)容為My test information，共讀取20個字節(jié)。
識別代號為98304的消息 隊列已經(jīng)被成功刪除。
***********************************************************/

/********************* 程序相關(guān)信息*********************
程序編號：013
程序編寫起始日期：2008.11.1
程序編寫完成日期：2008.11.1
程序修改日 期：                                   修改備注：
程序目的：學(xué)習(xí)linux共享內(nèi)存
所用主要函 數(shù)：shmget(),shmat(),shmctl(),shmdt()
程序存 疑：
程序完成地點： 宿舍內(nèi)
*********************程序相關(guān)信息*********************/
#include<sys/ipc.h>
#include<sys/shm.h>
#include<stdlib.h>
#include<string.h>
#include<stdio.h>
int main()
{
    int pid,shmid;//后者為共享內(nèi)存識別代號
    char *write_address;
    char *read_address;
    struct shmid_ds dsbuf;
    if((shmid=shmget(IPC_PRIVATE,32,0))<0)//分配共享內(nèi)存
    {
        printf("shmid共享內(nèi)存分配出現(xiàn)錯誤。\n");
        exit(1);
    }
    else
        printf("shmid共享內(nèi)存分配成功，共享內(nèi)存識別代號為：%d。\n",shmid);
    if((pid=fork())<0)
    {
        printf("fork函數(shù)調(diào)用出現(xiàn)錯誤！\n");
        exit(2);
    }
    else if(pid>0)//父進(jìn)程，向共享內(nèi)存中寫入數(shù)據(jù)
    {
        printf("父進(jìn)程的ID是：%d\n",getpid());
        write_address=(char *)shmat(shmid,NULL,0);//連接共享內(nèi)存
        if((int)write_address==-1)
        {
            printf("shmat連接共享內(nèi)存錯誤。\n");
            exit(3);
        }
        else
        {
            printf("shmat連接共享內(nèi)存成功。\n");
            strcpy(write_address,"我是寫入共享內(nèi)存的測試數(shù)據(jù)");//將數(shù)據(jù)寫入共享內(nèi)存
            printf("寫入共享內(nèi)存的信息為“%s”。\n",write_address);
            if((shmdt((void *)write_address))<0)//斷開與共享內(nèi)存的連接
                printf("shmdt共享內(nèi)存斷開錯誤。\n");
            else
                printf("shmdt共享內(nèi)存斷開成功。\n");
            sleep(2);
            return;
        }
    }
    else//子進(jìn)程，從共享內(nèi)存中讀取數(shù)據(jù)
    {
        sleep(2);//等待父進(jìn)程寫入共享內(nèi)存完畢
        printf("子進(jìn)程ID是：%d\n",getpid());
        if((shmctl(shmid,IPC_STAT,&dsbuf))<0)
        {
            printf("shmctl獲取共享內(nèi)存數(shù)據(jù)結(jié)構(gòu)出現(xiàn)錯誤。\n");
            exit(4);
        }
        else
        {
            printf("shmctl獲取共享內(nèi)存數(shù)據(jù)結(jié)構(gòu)成功。\n建立這個共享內(nèi)存的進(jìn)程ID是：%d\n",dsbuf.shm_cpid);
            printf("該共享內(nèi)存的大小為：%d\n",dsbuf.shm_segsz);
            if((read_address=(char *)shmat(shmid,0,0))<0)//連接共享內(nèi)存
            {
                printf("shmat連接共享內(nèi)存出現(xiàn)錯誤。\n");
                exit(5);
            }
            else
            {
                printf("自共享內(nèi)存中讀取的信息為：“%s”。\n",read_address);
                printf("最后一個操作該共享內(nèi)存的進(jìn)程ID是：%d\n",dsbuf.shm_lpid);
                if((shmdt((void *)read_address))<0)//斷開與共享內(nèi)存的連接
                {
                    printf("shmdt共享內(nèi)存斷開錯誤。\n");
                    exit(6);
                }
                else
                    printf("shmdt共享內(nèi)存斷開成功。\n");
                if(shmctl(shmid,IPC_RMID,NULL)<0)//刪除共享內(nèi)存及其數(shù)據(jù)結(jié)構(gòu)
                {
                    printf("shmctl刪除共享內(nèi)存及其數(shù)據(jù)結(jié)構(gòu)出現(xiàn)錯誤。\n");
                    exit(7);
                }
                else
                    printf("shmctl刪除共享內(nèi)存及其數(shù)據(jù)結(jié)構(gòu)成功。\n");
                exit(0);
            }
        }    
    }
}
/*********************程序運(yùn)行結(jié) 果*********************
[root@localhost temp]# ./shm
shmid共享內(nèi)存分配成功，共享內(nèi)存識別代號 為：1703947。
父進(jìn)程的ID是：7647
shmat連接共享內(nèi)存成功。
寫入共享內(nèi)存的信息為“我是寫入共享內(nèi)存的測試數(shù)據(jù)”。
shmdt 共享內(nèi)存斷開成功。
子進(jìn)程ID是：7648
shmctl獲取共享內(nèi)存數(shù)據(jù)結(jié)構(gòu)成功。
建立這個共享內(nèi)存的進(jìn)程ID是：7647
該共享內(nèi)存的大小 為：32
自共享內(nèi)存中讀取的信息為：“我是寫入共享內(nèi)存的測試數(shù)據(jù)”。
最后一個操作該共享內(nèi)存的進(jìn)程ID是：7647
shmdt共享內(nèi)存斷開成功。
shmctl刪除共享內(nèi)存及其數(shù)據(jù)結(jié)構(gòu)成功。
***********************************************************/