练习1：
使用消息队列实现的2个终端之间的互相聊天 并使用信号控制消息队列的读取方式： 当键盘按ctrl+c的时候，切换消息读取方式，一般情况为读取指定编号的消息，按ctrl+c之后，指定的编号不读取，读取其他所有编号的消息
//聊天一号机位 #include <stdio.h> #include <string.h> #include <stdlib.h> #include <sys/types.h> #include <unistd.h> #include <sys/stat.h> #include <fcntl.h> #include <pthread.h> #include <semaphore.h> #include <wait.h> #include <signal.h> #include <sys/socket.h> #include <arpa/inet.h> #include <sys/socket.h> #include <sys/ipc.h> #include <sys/sem.h> #include <semaphore.h> #include <sys/msg.h> #include <sys/shm.h> #include <sys/un.h> //定义结构体 struct msgbuf{long mtype;char mtext[128]; }; int msgid; int signal_l=0;//ctrl+c改变的变量信息编号 int s=0;//用来判断切换回去的变量 void handle(int sig){if(s==0){signal_l=020000;s=1;}else if(s!=0){signal_l=0;s=0;} } //用于读取的线程 void *ltread(void *arg){signal(SIGINT,handle);struct msgbuf rbuf;while(1){memset(&rbuf,0,sizeof(rbuf));//初始化结构体msgrcv(msgid,&rbuf,128,2,signal_l);//读取消息队列中的消息printf("读取到的消息为%s\n",rbuf.mtext);} } int main(int argc, const char *argv[]) {//调用函数ftok，获取访问同一个消息队列的秘钥key_t key;if((key=ftok("liantianle",100))==EOF){perror("ftok");return -1;}//根据秘钥创建消息队列/根据秘钥访问一个已经存在的消息队列if((msgid=msgget(key,IPC_CREAT|0666))==EOF){perror("msgget");return -1;}//创建并运行一个线程pthread_t thread;if((thread=pthread_create(&thread,NULL,ltread,NULL))!=0){perror("pthread_create");return -1;}struct msgbuf wbuf;signal(SIGINT,SIG_IGN);while(1){memset(&wbuf,0,sizeof(wbuf));//初始化结构体wbuf.mtype=1;//确定消息编号printf("1号输入：");fgets(wbuf.mtext,128,stdin);//直接读取终端输入，避免了scanf不吸收空格的影响msgsnd(msgid,&wbuf,strlen(wbuf.mtext),0);//将消息写入消息队列，以阻塞的形式}return 0; }// 聊天2号机位 #include <stdio.h> #include <string.h> #include <stdlib.h> #include <sys/types.h> #include <unistd.h> #include <sys/stat.h> #include <fcntl.h> #include <pthread.h> #include <semaphore.h> #include <wait.h> #include <signal.h> #include <sys/socket.h> #include <arpa/inet.h> #include <sys/socket.h> #include <sys/ipc.h> #include <sys/sem.h> #include <semaphore.h> #include <sys/msg.h> #include <sys/shm.h> #include <sys/un.h> //定义结构体 struct msgbuf{long mtype;char mtext[128]; }; int msgid; int signal_l=0;//ctrl+c改变的变量信息编号 int s=0;//用来判断切换回去的变量 void handle(int sig){if(s==0){signal_l=020000;s=1;}else if(s!=0){signal_l=0;s=0;} } //用于读取的线程 void *ltread(void *arg){signal(SIGINT,handle);struct msgbuf rbuf;while(1){memset(&rbuf,0,sizeof(rbuf));//初始化结构体msgrcv(msgid,&rbuf,128,1,signal_l);//读取消息队列中的消息printf("读取到的消息为%s\n",rbuf.mtext);} } int main(int argc, const char *argv[]) {//调用函数ftok，获取访问同一个消息队列的秘钥key_t key;if((key=ftok("liantianle",100))==EOF){perror("ftok");return -1;}//根据秘钥创建消息队列/根据秘钥访问一个已经存在的消息队列if((msgid=msgget(key,IPC_CREAT|0666))==EOF){perror("msgget");return -1;}//创建并运行一个线程pthread_t thread;if((thread=pthread_create(&thread,NULL,ltread,NULL))!=0){perror("pthread_create");return -1;}struct msgbuf wbuf;signal(SIGINT,SIG_IGN);while(1){memset(&wbuf,0,sizeof(wbuf));//初始化结构体wbuf.mtype=2;//确定消息编号printf("2号输入：");fgets(wbuf.mtext,128,stdin);//直接读取终端输入，避免了scanf不吸收空格的影响msgsnd(msgid,&wbuf,strlen(wbuf.mtext),0);//将消息写入消息队列，以阻塞的形式}return 0; }
