client.c

#include#include // shared memory#include // semaphore#include // message queue
// 消息隊(duì)列結(jié)構(gòu)struct msg_form {    long mtype;    char mtext;};
// 聯(lián)合體，用于semctl初始化union semun{    int              val; /for SETVAL/    struct semid_ds buf;    unsigned short  *array;};
// P操作://  若信號(hào)量值為1，獲取資源并將信號(hào)量值-1 //  若信號(hào)量值為0，進(jìn)程掛起等待int sem_p(int sem_id){    struct sembuf sbuf;    sbuf.sem_num = 0; /序號(hào)/    sbuf.sem_op = -1; /P操作/    sbuf.sem_flg = SEM_UNDO;
    if(semop(sem_id, &sbuf, 1) == -1)    {        perror("P operation Error");        return -1;    }    return 0;}
// V操作：//  釋放資源并將信號(hào)量值+1//  如果有進(jìn)程正在掛起等待，則喚醒它們int sem_v(int sem_id){    struct sembuf sbuf;    sbuf.sem_num = 0; /序號(hào)/    sbuf.sem_op = 1;  /V操作/    sbuf.sem_flg = SEM_UNDO;
    if(semop(sem_id, &sbuf, 1) == -1)    {        perror("V operation Error");        return -1;    }    return 0;}
int main(){    key_t key;    int shmid, semid, msqid;    char shm;    struct msg_form msg;    int flag = 1; /while循環(huán)條件/
    // 獲取key值    if((key = ftok(".", 'z')) < 0)    {        perror("ftok error");        exit(1);    }
    // 獲取共享內(nèi)存    if((shmid = shmget(key, 1024, 0)) == -1)    {        perror("shmget error");        exit(1);    }
    // 連接共享內(nèi)存    shm = (char*)shmat(shmid, 0, 0);    if((int)shm == -1)    {        perror("Attach Shared Memory Error");        exit(1);    }
    // 創(chuàng)建消息隊(duì)列    if ((msqid = msgget(key, 0)) == -1)    {        perror("msgget error");        exit(1);    }
    // 獲取信號(hào)量    if((semid = semget(key, 0, 0)) == -1)    {        perror("semget error");        exit(1);    }    // 寫(xiě)數(shù)據(jù)    printf("\\n");    printf("*                 IPC                 \\n");    printf("    Input r to send data to server.  \\n");    printf("    Input q to quit.                 \\n");    printf("\\n");    while(flag)    {        char c;        printf("Please input command: ");        scanf("%c", &c);        switch(c)        {            case 'r':                printf("Data to send: ");                sem_p(semid);  /訪問(wèn)資源/                scanf("%s", shm);                sem_v(semid);  /釋放資源/                /清空標(biāo)準(zhǔn)輸入緩沖區(qū)/                while((c=getchar())!='\\n' && c!=EOF);                msg.mtype = 888;                  msg.mtext = 'r';  /發(fā)送消息通知服務(wù)器讀數(shù)據(jù)/                msgsnd(msqid, &msg, sizeof(msg.mtext), 0);                break;            case 'q':                msg.mtype = 888;                msg.mtext = 'q';                msgsnd(msqid, &msg, sizeof(msg.mtext), 0);                flag = 0;                break;            default:                printf("Wrong input!\\n");                /清空標(biāo)準(zhǔn)輸入緩沖區(qū)*/                while((c=getchar())!='\\n' && c!=EOF);        }    }
    // 斷開(kāi)連接    shmdt(shm);
    return 0;}

注意：當(dāng)scanf()輸入字符或字符串時(shí)，緩沖區(qū)中遺留下了\\n，所以每次輸入操作后都需要清空標(biāo)準(zhǔn)輸入的緩沖區(qū)。但是由于 gcc 編譯器不支持fflush(stdin)（它只是標(biāo)準(zhǔn)C的擴(kuò)展），所以我們使用了替代方案：

while((c=getchar())!='\\n' && c!=EOF);

五種通訊方式總結(jié)

1.管道：速度慢，容量有限，只有父子進(jìn)程能通訊

2.FIFO：任何進(jìn)程間都能通訊，但速度慢

3.消息隊(duì)列：容量受到系統(tǒng)限制，且要注意第一次讀的時(shí)候，要考慮上一次沒(méi)有讀完數(shù)據(jù)的問(wèn)題

4.信號(hào)量：不能傳遞復(fù)雜消息，只能用來(lái)同步

5.共享內(nèi)存區(qū)：能夠很容易控制容量，速度快，但要保持同步，比如一個(gè)進(jìn)程在寫(xiě)的時(shí)候，另一個(gè)進(jìn)程要注意讀寫(xiě)的問(wèn)題，相當(dāng)于線(xiàn)程中的線(xiàn)程安全，當(dāng)然，共享內(nèi)存區(qū)同樣可以用作線(xiàn)程間通訊，不過(guò)沒(méi)這個(gè)必要，線(xiàn)程間本來(lái)就已經(jīng)共享了同一進(jìn)程內(nèi)的一塊內(nèi)存。