消息 队列

使用消息队列实现的2个终端之间的互相聊天,并使用信号控制消息队列的读取方式。
当键盘按ctrl+c的时候,切换消息读取方式,一般情况为读取指定编号的消息,按ctrl+c之后,指定的编号不读取,读取其他所有编号的消息

#include <stdio.h>
#include <string.h>
#include <unistd.h>
#include <stdlib.h>
#include <sys/types.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 type;
    char buf[128];
};

int main(int argc, const char *argv[])
{
    if(argc != 2){
        printf("number of parameters wrong\n");
        return 1;
    }
    int msgtype = atoi(argv[1]);
    key_t key = ftok("./file",1);
    if(key == -1){
        perror("ftok");
        return 1;
    }
    int id = msgget(key,IPC_CREAT | 0666);
    if(id == -1){
        perror("msgget");
        return 1;
    }
    struct msgbuf msg;
    int size = 0;
    while(1){
        memset(&msg,0,sizeof(msg));
        msg.type = msgtype;
        printf("pleaae enter:");
        scanf("%128s",msg.buf);
        while(getchar()!=10);
        size = strlen(msg.buf);
        msgsnd(id,&msg,size,0);
    }
    return 0;
}
 

receive.c

#include <stdio.h>
#include <string.h>
#include <unistd.h>
#include <stdlib.h>
#include <sys/types.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 type;
    char buf[128];
};

int read_mode = 1;
void sigint_handler(int msgtype){
    read_mode = -read_mode;
}

int main(int argc, const char *argv[])
{
    if(argc != 2){
        printf("number of parameters wrong\n");
        return 1;
    }
    int msgtype = atoi(argv[1]);
    key_t key = ftok("./file",1);
    if(key == -1){
        perror("ftok");
        return 1;
    }
    int id = msgget(key,IPC_CREAT | 0666);
    if(id == -1){
        perror("msgget");
        return 1;
    }
    signal(SIGINT,sigint_handler);
    struct msgbuf msg;
    int size = 0;
    while(1){
        memset(&msg,0,sizeof(msg));
        msgrcv(id,&msg,128,read_mode,020000);
        printf("the message read is:%s\n",msg.buf);
    }
    return 0;
}
 


 

相关推荐

  1. 消息 队列

    2024-05-13 23:28:11       14 阅读
  2. Redis 消息队列

    2024-05-13 23:28:11       40 阅读

最近更新

  1. TCP协议是安全的吗?

    2024-05-13 23:28:11       16 阅读
  2. 阿里云服务器执行yum,一直下载docker-ce-stable失败

    2024-05-13 23:28:11       16 阅读
  3. 【Python教程】压缩PDF文件大小

    2024-05-13 23:28:11       15 阅读
  4. 通过文章id递归查询所有评论(xml)

    2024-05-13 23:28:11       18 阅读

热门阅读

  1. 在vue3中测试执行typescript代码片段

    2024-05-13 23:28:11       13 阅读
  2. Gauss数据库备份恢复

    2024-05-13 23:28:11       13 阅读
  3. leetcode题目122

    2024-05-13 23:28:11       8 阅读
  4. 如何在服务器上下载,解压github上的代码

    2024-05-13 23:28:11       13 阅读
  5. 【C++ 刷题必备技巧】

    2024-05-13 23:28:11       8 阅读
  6. mac 安装homebrew

    2024-05-13 23:28:11       12 阅读
  7. nvm切换node版本命令

    2024-05-13 23:28:11       13 阅读