user1.c

#include <myhead.h>//创建发送信息的数据结构体
struct msgbuf
{long mtepe;char mdata[1024];
};
//宏定义数据的长度
#define MSG (sizeof(struct msgbuf)-sizeof(long))//线程一进行发送信息
void* task1(void * arg)
{//创建key的值key_t key = ftok("/",'a');if(key == -1){perror("key_t error");return NULL;}//创建消息队列int msgqid = msgget(key,IPC_CREAT|0664);if(msgqid == -1){perror("msgget error");return NULL;}//写入向队列中数据struct msgbuf buf;while(1){printf("请输入写入数据的类型>>>");scanf("%ld",&buf.mtepe);getchar();//吸收空格printf("请输入传输的数据:");fgets(buf.mdata,MSG,stdin);buf.mdata[strlen(buf.mdata)-1] = 0;//将消息放入队列中msgsnd(msgqid,&buf,MSG,0);printf("发送成功\n");if(strcmp(buf.mdata,"quit") == 0){break;}}
}void *task2(void * arg)
{//创建key的值//打开同一个key值key_t key = ftok("/",'a');if(key == -1){perror("key_t error");return NULL;}//创建消息队列int msgqid = msgget(key,IPC_CREAT|0664);if(msgqid == -1){perror("msgget error");return NULL;}//从消息队列中读取数据struct msgbuf buf;while(1){msgrcv(msgqid,&buf,MSG,1,0);printf("接受到的消息为：%s\n",buf.mdata);if(strcmp(buf.mdata,"quit") == 0){break;}}}int main(int argc, const char *argv[])
{//定义2个线程pthread_t pid1 ,pid2;//创建线程if(pthread_create(&pid1,NULL,task1,NULL) != 0){perror("pthread_create error");return -1;}if(pthread_create(&pid2,NULL,task2,NULL) != 0){perror("pthread_create error");return -1;}//主线程程序printf("用户一在线，可以进行通信\n");//回收资源//主线程阻塞等待线程完成通信pthread_join(pid1,NULL);pthread_join(pid2,NULL);//创建key的值//打开同一个key值key_t key = ftok("/",'a');if(key == -1){perror("key_t error");return NULL;}//创建消息队列int msgqid = msgget(key,IPC_CREAT|0664);if(msgqid == -1){perror("msgget error");r//删除队列if(msgctl(msgqid,IPC_RMID,NULL) != -1){perror("error");return NULL;}return 0;
}

user2.c

#include <myhead.h>//创建发送信息的数据结构体
struct msgbuf
{long mtepe;char mdata[1024];
};
//宏定义数据的长度
#define MSG (sizeof(struct msgbuf)-sizeof(long))//线程一进行发送信息
void* task1(void * arg)
{//创建key的值key_t key = ftok("/",'a');if(key == -1){perror("key_t error");return NULL;}//创建消息队列int msgqid = msgget(key,IPC_CREAT|0664);if(msgqid == -1){perror("msgget error");return NULL;}//写入向队列中数据struct msgbuf buf;while(1){printf("请输入写入数据的类型>>>");scanf("%ld",&buf.mtepe);getchar();//吸收空格printf("请输入传输的数据:");fgets(buf.mdata,MSG,stdin);buf.mdata[strlen(buf.mdata)-1] = 0;//将消息放入队列中msgsnd(msgqid,&buf,MSG,0);printf("发送成功\n");if(strcmp(buf.mdata,"quit") == 0){break;}}
}void *task2(void * arg)
{//创建key的值//打开同一个key值key_t key = ftok("/",'a');if(key == -1){perror("key_t error");return NULL;}//创建消息队列int msgqid = msgget(key,IPC_CREAT|0664);if(msgqid == -1){perror("msgget error");return NULL;}//从消息队列中读取数据struct msgbuf buf;while(1){msgrcv(msgqid,&buf,MSG,2,0);printf("接受到的消息为：%s\n",buf.mdata);if(strcmp(buf.mdata,"quit") == 0){break;}}}int main(int argc, const char *argv[])
{//定义2个线程pthread_t pid1 ,pid2;//创建线程if(pthread_create(&pid1,NULL,task1,NULL) != 0){perror("pthread_create error");return -1;}if(pthread_create(&pid2,NULL,task2,NULL) != 0){perror("pthread_create error");return -1;}//主线程程序printf("用户一在线，可以进行通信\n");//回收资源//主线程阻塞等待线程完成通信pthread_join(pid1,NULL);pthread_join(pid2,NULL);//创建key的值//打开同一个key值key_t key = ftok("/",'a');if(key == -1){perror("key_t error");return NULL;}//创建消息队列int msgqid = msgget(key,IPC_CREAT|0664);if(msgqid == -1){perror("msgget error");r//删除队列if(msgctl(msgqid,IPC_RMID,NULL) != -1){perror("error");return NULL;}return 0;
}