消息隊列給了我一個無效的參數

Question

我在使用我的代碼時遇到了一些麻煩。它應該創建一個消息隊列併發送消息，而不是等待另一個程序接收該消息並回答。問題是，當我運行它時，我在msgsnd和msgrcv上都得到了一個無效的參數。

#include <stdlib.h> 
#include <unistd.h> 
#include <stdio.h> 
#include <string.h> 
#include <errno.h> 
#include <sys/types.h> 
#include <sys/msg.h> 

typedef struct my_msg{ 
    long type; 
    char text[100]; 
    char sqdr; 
}message; 

static void score(int messagge_id, char* A_B){ 
    message send; 
    send.type=1; 
    strcpy(send.text, "Try to score"); 
    send.sqdr = *A_B; 
    if((msgsnd(messagge_id, &send, sizeof(send), 0))<0)perror("Error msgsnd\n"); 
    sleep(3); 
    if((msgrcv(messagge_id, &send, sizeof(send), 4, 0))==-1)perror("Error msgrcv 1\n"); 
    int test=atoi(send.text); 
    printf("%d\n", test); 
} 


int main(){ 
    int caso, key; 
    char team= 'A'; 
    key=1234; 
    int msg_id=msgget(key, S_IRUSR|S_IWUSR); 
    printf("Try function score\n"); 
    score(msg_id, &team); 
    printf("After score\n"); 
return 0; 
} 

Answer 1

您需要確保該消息隊列創建。您可以使用密鑰​​3210或將IPC_CREAT添加到標誌。您還需要嘗試正確閱讀該消息。您發送了「類型1」消息並嘗試讀取「類型4」消息，因此讀取掛起。

此代碼還會刪除消息隊列。如果它是一個私有隊列（這種隊列在程序終止時被刪除），這並不重要，但對於使用IPC_CREAT和用戶定義的密鑰的隊列來說，這一點非常重要。 （我還更改了消息文本，以便atoi()返回的內容比零更有趣並且令人信服 - 代碼還使用單獨的發送緩衝區和接收緩衝區，以便我們知道代碼不會作弊並重新使用緩衝區中的數據。）

#include <stdlib.h> 
#include <unistd.h> 
#include <stdio.h> 
#include <string.h> 
#include <sys/msg.h> 
#include <fcntl.h> 

typedef struct my_msg 
{ 
    long type; 
    char text[100]; 
    char sqdr; 
} message; 

static void score(int messagge_id) 
{ 
    message send; 
    message recv; 
    send.type = 1; 
    strcpy(send.text, "47 tries to score"); 
    send.sqdr = 'A'; 
    if ((msgsnd(messagge_id, &send, sizeof(send), 0)) < 0) 
     perror("Error msgsnd"); 
    printf("Dozing...\n"); 
    sleep(3); 
    printf("Unslumbering...\n"); 
    if ((msgrcv(messagge_id, &recv, sizeof(recv), -4, 0)) == -1) 
     perror("Error msgrcv"); 
    int test = atoi(recv.text); 
    printf("%d\n", test); 
} 

int main(void) 
{ 
    int key = 1234; 
    int flags = S_IRUSR|S_IWUSR|IPC_CREAT; 
    // int key = IPC_PRIVATE; 
    // int flags = S_IRUSR|S_IWUSR; 
    int msg_id = msgget(key, flags); 
    if (msg_id < 0) 
     perror("Error msgget"); 
    else 
    { 
     printf("Try function score\n"); 
     score(msg_id); 
     printf("After score\n"); 
     if (msgctl(msg_id, IPC_RMID, 0) < 0) 
      perror("Error msgctl"); 
    } 
    return 0; 
} 

示例輸出：

Try function score 
Dozing... 
Unslumbering... 
47 
After score 

有 '休眠' 和 '警'，當然之間有3秒的暫停。

Answer 2

使用這樣的： -

if((msgsnd(messagge_id, (void *)&send, sizeof(send), 0))<0)perror("Error msgsnd\n"); 

if((msgrcv(messagge_id, (void *)&send, sizeof(send), 4, 0))==-1)perror("Error msgrcv 1\n");