進(jìn)程間通信(IPC)作用
1.數(shù)據(jù)傳輸
2.共享資源
3.通知事件
4.進(jìn)程控制

IPC的方式 6種
1.管道(pipe)和有名管道(FIFO)
2.信號(hào)(signal)
3.消息隊(duì)列
4.共享內(nèi)存
5.信號(hào)量
6.套接字

管道
一進(jìn)程寫入管道尾部,另一進(jìn)程從管道頭讀出
讀空管道,進(jìn)程被阻塞
寫滿管道,進(jìn)程被阻塞



無(wú)名管道 多用于父子進(jìn)程間的通信

    
int pipe(int filedis[2])//創(chuàng)建無(wú)名管道

  

filedis文件描述符
filedis[0]用于讀管道
filedis[1]用于寫管道

    
//管道的創(chuàng)建和關(guān)閉
#include <unistd.h>
#include <errno.h>
#include <stdio.h>
#include <stdlib.h>

int main(){
    int pipe)fd[2];
    //創(chuàng)建pipe
    if(pipe(pipe_fd)<0){
        printf("pipe create error\n");
        return -1;
    }else{
        printf("pipe create success\n"):
    }
    //關(guān)閉pipe
    close(pipe_fd[0]);
    colse(pipe_fd[1]);
}

  

通常 先創(chuàng)建一個(gè)管道, 再通過(guò)fork創(chuàng)建一個(gè)子進(jìn)程 ,子進(jìn)程會(huì)繼承父進(jìn)程所創(chuàng)建的管道



有名管道

    
#include <sys/types.h>
#include <sys/stat.h>

int mkfifo(const char *pathname, mode_t mode)

  

pathname:FIFO的路徑

讀寫管道時(shí): 非阻塞標(biāo)志O_NONBLOCK,非阻塞時(shí),出錯(cuò)立即返回,errno是ENXIO

刪除管道

    
unlink(const char *pathname)

  

讀有名管道

    
#include <sys/types.h>
#include <sys/stat.h>
#include <errno.h>
#include <fcntl.h>
#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#define FIFO "/tmp/myfifo"

main(int argc,char** argv)
{
	char buf_r[100];
	int  fd;
	int  nread;
	
	/* 創(chuàng)建管道 */
	if((mkfifo(FIFO,O_CREAT|O_EXCL)<0)&&(errno!=EEXIST))
		printf("cannot create fifoserver\n");
	
	printf("Preparing for reading bytes...\n");
	
	memset(buf_r,0,sizeof(buf_r));
	
	/* 打開管道 */
	fd=open(FIFO,O_RDONLY|O_NONBLOCK,0);
	if(fd==-1)
	{
		perror("open");
		exit(1);	
	}
	while(1)
	{
		memset(buf_r,0,sizeof(buf_r));
		
		if((nread=read(fd,buf_r,100))==-1)
		{
			if(errno==EAGAIN)
				printf("no data yet\n");
		}
		printf("read %s from FIFO\n",buf_r);
		sleep(1);
	}	
	pause(); /*暫停，等待信號(hào)*/
	unlink(FIFO); //刪除文件
}

  

寫有名管道

    
#include <sys/types.h>
#include <sys/stat.h>
#include <errno.h>
#include <fcntl.h>
#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#define FIFO_SERVER "/tmp/myfifo"

main(int argc,char** argv)
{
	int fd;
	char w_buf[100];
	int nwrite;
		
	/*打開管道*/
	fd=open(FIFO_SERVER,O_WRONLY|O_NONBLOCK,0);
	
	if(argc==1)
	{
		printf("Please send something\n");
		exit(-1);
	}
	
	strcpy(w_buf,argv[1]);
	
	/* 向管道寫入數(shù)據(jù) */
	if((nwrite=write(fd,w_buf,100))==-1)
	{
		if(errno==EAGAIN)
			printf("The FIFO has not been read yet.Please try later\n");
	}
	else 
		printf("write %s to the FIFO\n",w_buf);
}

  

進(jìn)程通信--管道聽課筆記