1.有名管道
int mkfifo(const char *pathname, mode_t mode);
功能：創(chuàng)建有名管道，文件存儲(chǔ)在內(nèi)核，在本地磁盤有這個(gè)文件的文件名
//有名管道：寫數(shù)據(jù)
#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) //最終權(quán)限：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)
{
//寫數(shù)據(jù)：從終端獲取數(shù)據(jù)掏秩，寫到有名管道內(nèi)
fgets(buf, sizeof(buf), stdin);
write(fd_w, buf, sizeof(buf));
if(strncmp(buf, "quit", 4) == 0)
{
exit(0);
}
}
close(fd_w);
return 0;
}
//有名管道：讀數(shù)據(jù)
#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) //最終權(quán)限：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)
{
//讀數(shù)據(jù)：從有名管道讀數(shù)據(jù)，將數(shù)據(jù)寫到終端
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);
功能：創(chuàng)建一個(gè)key值荆姆，用于IPC蒙幻。
3.消息隊(duì)列
int msgget(key_t key, int msgflg);
功能：獲得一個(gè)消息隊(duì)列ID
int msgsnd(int msqid, const void *msgp, size_t msgsz, int msgflg);
功能：按照類型發(fā)送消息
參數(shù)： msgp：存儲(chǔ)消息的地址
??? msgsz：消息的大小（不包括消息類型）
??? msgflg：0（阻塞）胆筒， IPC_NOWAIT（非阻塞）
ssize_t msgrcv(int msqid, void *msgp, size_t msgsz, long msgtyp, int msgflg);
功能：按照消息類型接收數(shù)據(jù)
參數(shù)：msgp：存儲(chǔ)接受到的消息
??? msgsz：消息的大杏势啤（除消息類型）
??? msgtyp：指定接收的消息類型
?????? = 0：接收消息隊(duì)列中的第一個(gè)消息
?????? > 0：接收指定類型的第一個(gè)消息
?????? < 0：接收小于等于|msgtyp|且最小的類型中的第一個(gè)消息
msgflg：0（阻塞）诈豌，IPC_NOWAIT（非阻塞）
// 發(fā)送消息
#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[])
{
//獲得一個(gè)key，用于打開唯一一個(gè)消息隊(duì)列
key_t key = ftok(".", 1);
//創(chuàng)建并打開
int msgid = msgget(key, IPC_CREAT|0664);
if(msgid == -1)
{
perror("msgget error");
exit(1);
}
//發(fā)送消息
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;
}
