Linux下的有名管道(06)---使用两个管道实现两个进程之间的通信(手机模式)
2015-09-21 17:22
926 查看
环境:Vmware Workstation;CentOS-6.4-x86_64
说明:
对讲机模式:一个进程输入完成一句话,必须等待第二个进程输入完成一句话之后才能再次输入。
步骤:
1、创建两个管道:
[negivup@negivup mycode]$ mkfifo fifo1
[negivup@negivup mycode]$ mkfifo fifo2
[negivup@negivup mycode]$ ls
fifo1 fifo22、编写makefile文件:
.SUFFIXES:.c .o
CC=gcc
SRCS1=readfifo.c
OBJS1=$(SRCS1:.c=.o)
EXEC1=readfifo
SRCS2=writefifo.c
OBJS2=$(SRCS2:.c=.o)
EXEC2=writefifo
start: $(OBJS1) $(OBJS2)
$(CC) -o $(EXEC1) $(OBJS1)
$(CC) -o $(EXEC2) $(OBJS2)
@echo "--------------------------OK------------------------"
.c.o:
$(CC) -Wall -o $@ -c $<
clean:
rm -rf $(OBJS1) $(EXEC1)
rm -rf $(OBJS2) $(EXEC2)
3、编写读取管道的源文件readfifo.c:
#include <stdio.h>
#include <stdlib.h>
#include <sys/types.h>
#include <sys/stat.h>
#include <string.h>
#include <errno.h>
#include <fcntl.h>
#include <unistd.h>
int main(void)
{
pid_t pid = fork(); //创建了两个进程,父子关系
if (pid > 0) //在主进程里面
{
int fd1 = open("fifo1", O_WRONLY);
if (fd1 == -1)
{
printf("open fifo1 error, %s\n", strerror(errno));
return -1;
}
char buf[1024];
while (1)
{
memset(buf, 0, sizeof(buf));
read(STDIN_FILENO, buf, sizeof(buf));
write(fd1, buf, strlen(buf));
}
close(fd1);
} else
{
int fd1 = open("fifo2", O_RDONLY);
if (fd1 == -1)
{
printf("open fifo2 error, %s\n", strerror(errno));
return -1;
}
char buf[1024];
while (1)
{
memset(buf, 0, sizeof(buf));
read(fd1, buf, sizeof(buf));
printf("%s", buf);
}
close(fd1);
}
return 0;
}
4、编写写入管道的源文件writefifo.c:
5、编译并执行readfifo:
[negivup@negivup mycode]$ make
gcc -Wall -o readfifo.o -c readfifo.c
gcc -Wall -o writefifo.o -c writefifo.c
gcc -o readfifo readfifo.o
gcc -o writefifo writefifo.o
--------------------------OK------------------------
[negivup@negivup mycode]$ readfifo 6、打开一个新的终端,执行writefifo:
这样就实现了两个进程之间的自由通信了。
需要特别注意的是,一个管道的一端,如果确定是读取的操作,那么就不能写入;同理,如果确定是写入的操作,就不能读取。
PS:根据传智播客视频学习整理得出。
说明:
对讲机模式:一个进程输入完成一句话,必须等待第二个进程输入完成一句话之后才能再次输入。
步骤:
1、创建两个管道:
[negivup@negivup mycode]$ mkfifo fifo1
[negivup@negivup mycode]$ mkfifo fifo2
[negivup@negivup mycode]$ ls
fifo1 fifo22、编写makefile文件:
.SUFFIXES:.c .o
CC=gcc
SRCS1=readfifo.c
OBJS1=$(SRCS1:.c=.o)
EXEC1=readfifo
SRCS2=writefifo.c
OBJS2=$(SRCS2:.c=.o)
EXEC2=writefifo
start: $(OBJS1) $(OBJS2)
$(CC) -o $(EXEC1) $(OBJS1)
$(CC) -o $(EXEC2) $(OBJS2)
@echo "--------------------------OK------------------------"
.c.o:
$(CC) -Wall -o $@ -c $<
clean:
rm -rf $(OBJS1) $(EXEC1)
rm -rf $(OBJS2) $(EXEC2)
3、编写读取管道的源文件readfifo.c:
#include <stdio.h>
#include <stdlib.h>
#include <sys/types.h>
#include <sys/stat.h>
#include <string.h>
#include <errno.h>
#include <fcntl.h>
#include <unistd.h>
int main(void)
{
pid_t pid = fork(); //创建了两个进程,父子关系
if (pid > 0) //在主进程里面
{
int fd1 = open("fifo1", O_WRONLY);
if (fd1 == -1)
{
printf("open fifo1 error, %s\n", strerror(errno));
return -1;
}
char buf[1024];
while (1)
{
memset(buf, 0, sizeof(buf));
read(STDIN_FILENO, buf, sizeof(buf));
write(fd1, buf, strlen(buf));
}
close(fd1);
} else
{
int fd1 = open("fifo2", O_RDONLY);
if (fd1 == -1)
{
printf("open fifo2 error, %s\n", strerror(errno));
return -1;
}
char buf[1024];
while (1)
{
memset(buf, 0, sizeof(buf));
read(fd1, buf, sizeof(buf));
printf("%s", buf);
}
close(fd1);
}
return 0;
}
4、编写写入管道的源文件writefifo.c:
#include <stdio.h> #include <stdlib.h> #include <sys/types.h> #include <sys/stat.h> #include <string.h> #include <errno.h> #include <fcntl.h> #include <unistd.h> int main(void) { pid_t pid = fork(); //创建了两个进程,父子关系 if (pi 4000 d > 0) //在主进程里面 { int fd1 = open("fifo2", O_WRONLY); if (fd1 == -1) { printf("open fifo2 error, %s\n", strerror(errno)); return -1; } char buf[1024]; while (1) { memset(buf, 0, sizeof(buf)); read(STDIN_FILENO, buf, sizeof(buf)); write(fd1, buf, strlen(buf)); } close(fd1); } else { int fd1 = open("fifo1", O_RDONLY); if (fd1 == -1) { printf("open fifo1 error, %s\n", strerror(errno)); return -1; } char buf[1024]; while (1) { memset(buf, 0, sizeof(buf)); read(fd1, buf, sizeof(buf)); printf("%s", buf); } close(fd1); } return 0; }
5、编译并执行readfifo:
[negivup@negivup mycode]$ make
gcc -Wall -o readfifo.o -c readfifo.c
gcc -Wall -o writefifo.o -c writefifo.c
gcc -o readfifo readfifo.o
gcc -o writefifo writefifo.o
--------------------------OK------------------------
[negivup@negivup mycode]$ readfifo 6、打开一个新的终端,执行writefifo:
[negivup@negivup mycode]$ writefifo safd
这样就实现了两个进程之间的自由通信了。
需要特别注意的是,一个管道的一端,如果确定是读取的操作,那么就不能写入;同理,如果确定是写入的操作,就不能读取。
PS:根据传智播客视频学习整理得出。
相关文章推荐
- 关于linux有效用户id的解释
- Linux sed命令解析
- CentOS iSCSI服务器搭建------Target篇
- LINUX文件锁定
- Linux知识(2)----fcitx输入法安装
- CentOS 6.5上使用gdb调试时出现Missing separate debuginfos, use: debuginfo-install glibc-2.12-1.132.el6.i686 .
- block_dump观察Linux IO写入的具体文件
- windows远程(xrdp+vnc)连接ubuntu linux
- linux环境变量 export命令详解
- Linux下的有名管道(05)---使用两个管道实现两个进程之间的通信(对讲机模式)
- phalcon的安装详细
- Centos下安装svn客户端
- 【问题】CentOS6.5系统"libc.so.6: version 'GLIBC_2.15' not found"解决方法
- [Linux] ls和size命令以及程序内存映像、磁盘映像的理解
- Linux 正则表达式
- RHEL7无人值守自动安装 DHCP+TFTP +SYSLINUX+FTP +Kickstart
- Linux 下软件安装
- 【Linux导论】Linux引导流程(The Boot Process)
- centos7 开机/etc/rc.local 不执行的问题
- Linux学习笔记01:Linux下的drwxr-xr-x