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