C语言

3. 进程间通信--有名管道、消息队列

2017-08-17  本文已影响0人  石不琢

1.有名管道

int mkfifo(const char *pathname, mode_t mode);
功能:创建有名管道,文件存储在内核,在本地磁盘有这个文件的文件名

//有名管道:写数据
#include <stdio.h>
#include <sys/types.h>
#include <sys/stat.h>
#include <unistd.h>
#include <errno.h>
#include <stdlib.h>
#include <fcntl.h>
#include <string.h>

int main(int argc, const char *argv[])
{
    if(mkfifo("fifo", 0660) == -1)              //最终权限:mode & ~umask
    {
        if(errno == EEXIST)
        {
            puts("exist");
        }
        else
        {
            perror("mkfifo error");
            exit(1);
        }
    }

    int fd_w = open("fifo" , O_RDWR); 
    if(fd_w == -1)
    {
        perror("open error");
        exit(1);
    }

    char buf[32];
    while(1)
    {
        //写数据:从终端获取数据,写到有名管道内
        fgets(buf, sizeof(buf), stdin);
        write(fd_w, buf, sizeof(buf));
        if(strncmp(buf, "quit", 4) == 0)
        {
            exit(0);
        }
    }

    close(fd_w);
    return 0;
}
//有名管道:读数据

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

int main(int argc, const char *argv[])
{
    if(mkfifo("fifo", 0660) == -1)              //最终权限:mode & ~umask
    {
        if(errno == EEXIST)
        {
            puts("exist");
        }
        else
        {
            perror("mkfifo error");
            exit(1);
        }
    }

    int fd_r = open("fifo" , O_RDWR); 
    if(fd_r == -1)
    {
        perror("open error");
        exit(1);
    }
    char buf[32];

    while(1)
    {
        //读数据:从有名管道读数据,将数据写到终端
        read(fd_r, buf, sizeof(buf));
        if(strncmp(buf, "quit", 4) == 0)
        {
            exit(0);
        }
        printf("----> ");
        fputs(buf, stdout);
    }

    close(fd_r);    
    return 0;
}

2. KEY值

key_t ftok(const char *pathname, int proj_id);
功能:创建一个key值,用于IPC。

3.消息队列

int msgget(key_t key, int msgflg);
功能:获得一个消息队列ID

int msgsnd(int msqid, const void *msgp, size_t msgsz, int msgflg);
功能:按照类型发送消息
参数: msgp:存储消息的地址
    msgsz:消息的大小(不包括消息类型)
    msgflg:0(阻塞), IPC_NOWAIT(非阻塞)

ssize_t msgrcv(int msqid, void *msgp, size_t msgsz, long msgtyp, int msgflg);
功能:按照消息类型接收数据
参数:msgp:存储接受到的消息
    msgsz:消息的大小(除消息类型)
    msgtyp:指定接收的消息类型
       = 0:接收消息队列中的第一个消息
       > 0:接收指定类型的第一个消息
       < 0:接收小于等于|msgtyp|且最小的类型中的第一个消息

msgflg:0(阻塞),IPC_NOWAIT(非阻塞)

// 发送消息
#include <stdio.h>
#include <sys/ipc.h>
#include <sys/types.h>
#include <sys/msg.h>
#include <stdlib.h>

#define N sizeof(msgbuf)-sizeof(long)

struct msgbuf {
    long mtype;       /* message type, must be > 0 */
    int a;
    float b;
    char c;
};

int main(int argc, const char *argv[])
{
    //获得一个key,用于打开唯一一个消息队列
    key_t key = ftok(".", 1);

    //创建并打开
    int msgid = msgget(key, IPC_CREAT|0664);
    if(msgid == -1)
    {
        perror("msgget error");
        exit(1);
    }

    //发送消息
    struct msgbuf msgbuf;

    msgbuf.mtype = 1;
    msgbuf.a = 13;
    msgbuf.b = 13.34;
    msgbuf.c = 'A';
    if(msgsnd(msgid, &msgbuf, N, 0) == -1)
    {
        perror("msgsnd error");
    }

    msgbuf.mtype = 2;
    msgbuf.a = 23;
    msgbuf.b = 23.34;
    msgbuf.c = 'B';
    if(msgsnd(msgid, &msgbuf, N, 0) == -1)
    {
        perror("msgsnd error");
    }

    msgbuf.mtype = 3;
    msgbuf.a = 33;
    msgbuf.b = 33.34;
    msgbuf.c = 'C';
    if(msgsnd(msgid, &msgbuf, N, 0) == -1)
    {
        perror("msgsnd error");
    }


    return 0;
}
// 接受消息
#include <stdio.h>
#include <sys/ipc.h>
#include <sys/types.h>
#include <sys/msg.h>
#include <stdlib.h>

#define N sizeof(msgbuf)-sizeof(long)
struct msgbuf {
    long mtype;       /* message type, must be > 0 */
    int a;
    float b;
    char c;
};

int main(int argc, const char *argv[])
{
    key_t key = ftok(".", 1);
    int msgid = msgget(key, IPC_CREAT|0664);
    if(msgid == -1)
    {
        perror("msgget error");
        exit(1);
    }

    //接收消息 
    struct msgbuf msgbuf;
    if(msgrcv(msgid, &msgbuf, N, -3, 0) == -1)
    {
        perror("msgrcv error");
        exit(1);
    }

    printf("%d %.2f %c\n",msgbuf.a, msgbuf.b, msgbuf.c);

    //删除

    return 0;
}
上一篇 下一篇

猜你喜欢

热点阅读