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;
}