c + + msgsnd＆msgrcv似乎不溝通

Question

我想使兩個進程在C++中進行通信，但是，它似乎並不工作。我有這樣的代碼：

#include <sys/types.h> 
#include <sys/ipc.h> 
#include <sys/msg.h> 
#include <string.h> 
#include <iostream> 
#include <unistd.h> 
#include <sys/wait.h> 
#include <stdlib.h> 

void sender(int qid) 
{ 
    // declare my message buffer 
    struct buf { 
    long mtype; // required 
    char greeting[50]; // mesg content 
    }; 

    buf msg; 
    int size = sizeof(msg)-sizeof(long); 

    std::cout << "Type [exit] to stop the program." << std::endl; 

    bool exit = false; 
    while (!exit) 
    { 
     std::cout << getpid() << ": "; 
     std::cin.getline(msg.greeting, 50, '\n'); 
     //std::cout << msg.greeting << std::endl; 
     msg.mtype = 23; 
     if (strcmp(msg.greeting, "exit") == 0) 
    exit = true; 
     msgsnd(qid, (struct msgbuf *)&msg, size, 0); 
    } 

} 

void receiver(int qid) 
{ 
    // declare my message buffer 
    struct buf { 
    long mtype; 
    char greeting[50]; 
    }; 
    buf msg; 
    int size = sizeof(msg)-sizeof(long); 

    bool exit = false; 
    while (!exit) 
    { 
     msgrcv(qid, (struct msgbuf *)&msg, size, 23, 0); 
     if (strcmp(msg.greeting, "exit") == 0) 
    exit = true; 
     std::cout << getpid() << ": " << msg.greeting << std::endl; 
    } 
} 

int main(int ac, char **av) { 

    //spawning two child processes 
    pid_t cpid = fork(); 
    int qid = msgget(IPC_PRIVATE, IPC_EXCL|IPC_CREAT|0600); 

    if (cpid == 0) { 
    // execv("./sender", av); 
    sender(qid); 
    exit(0); 
    } 
    cpid = fork(); 
    if (cpid == 0) { 
    //execv("./receiver", av); 
    receiver(qid); 
    exit(0); 
    } 

    while (wait(NULL) != -1); // waiting for both children to terminate 

    msgctl(qid, IPC_RMID, NULL); 

    std::cout << "END" << std::endl; 

    exit(0); 
} 

因此，大家可以看到，sender()等待用戶的輸入。 receiver()正在等待，所以一切都很好。但是，當用戶完成輸入時，他按[enter]鍵，但是...接收器沒有任何東西。

他們有相同的QID，相同的信息大小，相同的ID（23）..我不明白爲什麼它不起作用。我看到很多例子，對我來說，這似乎是邏輯，那麼問題是什麼？

感謝您的幫助

Answer 1

一個錯誤在此代碼是每個進程創建自己的私有IPC隊列。

讓他們共享同一個隊列可以通過它來傳達：

//spawning two child processes 
int qid = msgget(IPC_PRIVATE, IPC_EXCL|IPC_CREAT|0600); 
pid_t cpid = fork();