实现消息队列实现AB进程对话。

a.A进程发送一句话后，B进程接收到打印。然后B进程发送一句话，A进程接收后打印

b.重复上述步骤。直到AB接收或者发送完quit后，结束AB进程

A:

#include <stdio.h>
#include <sys/types.h>
#include <sys/ipc.h>
#include <sys/msg.h>
#include <string.h>
#include <stdlib.h>typedef struct
{long mtype;       //  消息类型  必须 > 0;char mtext[32];   //  消息内容  
}msgp;int main(int argc, const char *argv[])
{key_t key = ftok("/home/ubuntu/",1);if(key < 0){perror("ftok");return -1;}// 创建消息队列int msqid = msgget(key, IPC_CREAT|0664);if( msqid < 0){perror("msgget");return -1;}// 消息打包发送msgp msg;ssize_t res = 0;while(1){
//      **************    A 写	 *******************	printf("请输入消息类型:");scanf("%ld", &msg.mtype);getchar();if(msg.mtype <= 0){break;}printf("请输入消息内容:");fgets(msg.mtext, sizeof(msg.mtext), stdin);msg.mtext[strlen(msg.mtext) - 1] = '\0';if( msgsnd(msqid, &msg, sizeof(msg.mtext), IPC_NOWAIT) < 0 ){perror("msgsnd");return -1;}if( strcmp(msg.mtext,"quit") == 0 ){break;}printf("消息发送成功!!!\n");printf("消息队列如下:\n");system("ipcs -q");// **************    A  接收   ***************************printf("A等待接收.....\n");res = msgrcv(msqid, &msg, sizeof(msg.mtext), 0, 0);if( res < 0 ){perror("msgsnd");//          break;}if( strcmp(msg.mtext,"quit") == 0){break;}printf("A--消息接收成功!   ");printf("A--接受消息如下:\n");printf("res=%ld | mtype=%ld : mtext=%s \n",res, msg.mtype, msg.mtext);printf("------------------------------------------\n");}return 0;
}

B：

#include <stdio.h>
#include <sys/types.h>
#include <sys/ipc.h>
#include <sys/msg.h>
#include <string.h>
#include <stdlib.h>#define MSG_EXCEPT      020000typedef struct
{long mtype;       //  消息类型  必须 > 0;char mtext[32];   //  消息内容  
}msgp;int main(int argc, const char *argv[])
{key_t key = ftok("/home/ubuntu/",1);if(key < 0){perror("ftok");return -1;}// 创建消息队列int msqid = msgget(key, IPC_CREAT|0664);if( msqid < 0){perror("msgget");return -1;}// 消息打包发送msgp msg;ssize_t res = 0;while(1){
//  ******************    B 接收  *******************printf("B等待接收.....\n");   res = msgrcv(msqid, &msg, sizeof(msg.mtext), 0, 0);if( res < 0 ){perror("msgsnd");}if( strcmp(msg.mtext,"quit") == 0){break;}printf("B--消息接收成功!   ");printf("B--接受消息如下:\n");printf("res=%ld | mtype=%ld : mtext=%s \n",res, msg.mtype, msg.mtext);printf("------------------------------------------\n"); //      **************    B 写   *******************    printf("请输入消息类型:");                                  scanf("%ld", &msg.mtype);getchar();if(msg.mtype <= 0){break;}printf("请输入消息内容:");fgets(msg.mtext, sizeof(msg.mtext), stdin);msg.mtext[strlen(msg.mtext) - 1] = '\0';if( msgsnd(msqid, &msg, sizeof(msg.mtext), IPC_NOWAIT) < 0 ){perror("msgsnd");return -1;}if( strcmp(msg.mtext,"quit") == 0 ){break;}printf("消息发送成功!!!\n");printf("消息队列如下:\n");system("ipcs -q");}
/*	// 删除消息队列if( msgctl(msqid, IPC_RMID, NULL) < 0 ){perror("msgctl");return -1;}printf("删除消息队列成功!!!\n");system("ipcs -q");
*/return 0;
}