189 8069 5689
sockpair实现进程间通信
创新互联公司于2013年创立，先为朔州等服务建站，朔州等地企业，进行企业商务咨询服务。为朔州企业网站制作PC+手机+微官网三网同步一站式服务解决您的所有建站问题。
我们以前学习的利用管道（此处为匿名管道）实现进程间通信，只能是单向的，一边只能读而另一边只能写，且只能在有血缘关系的进程间才能通信，若想实现双向通信就必须创建双向管道，而sockpair它的实现就是双向管道进行通信。它可以用来创建双向通信管道
1 #include2 #include 3 #include 4 #include 5 #include 6 #include 7 #include 8 9 int main() 10 { 11 int sv[2]={0,0}; 12 char buf[1024]; 13 int sock_pair=socketpair(AF_LOCAL,SOCK_STREAM,0,sv); 14 if(sock_pair < 0) 15 { 16 perror("socketpair"); 17 exit(1); 18 } 19 pid_t id=fork(); 20 if(id<0) 21 { 22 perror("fork"); 23 return -1;
24 }else if(id==0){ //child
25 close(sv[0]);
26 while(1)
27 {
28 memset(buf,'\0',sizeof(buf));
29 strcpy(buf,"I'm child");
30 write(sv[1],buf,strlen(buf));
31 ssize_t _size=read(sv[1],buf,sizeof(buf)-1);
32 if(_size<0)
33 {
34 perror("read");
35 return -2;
36 }else if(_size > 0)
37 {
38 buf[_size]='\0';
39 printf("father->child:%s\n",buf);
40 }
41 sleep(1);
42 }
43 close(sv[1]);
44
45 }else
46 {
47 close(sv[1]);
48 while(1)
49 {
50 ssize_t _size=read(sv[0],buf,sizeof(buf)-1);
51 if(_size<0)
52 {
53 perror("read");
54 exit(2);
55 }else if(_size >0)
56 {
57 buf[_size]='\0';
58 printf("child->father:%s\n",buf);
59 }
60 // memset(buf,'\0',sizeof(buf));
61 strcpy(buf,"I'm father");
62 write(sv[0],buf,sizeof(buf)-1);
63 }
64 close(sv[0]);
65 }
66 return 0;
67 }程序运行结果：
重定向：对文件描述符进行重定向
例：将一个文件中的内容打印到标准输出上，若关闭了标准输出文件描述符，此时再打开一个文件，文件描述符将为1，而此时第一个文件的内容将会被打印到文件中（即重定向）
若新创建一个进程文件描述符会从3（若0、1、2都不关）开始？
当打开一个终端时，该过程即为创建一个会话的过程，会有一个控制进程bash，也就是会话首进程，关联terminal终端后会默认填上标准输入、标准输出以及标准错误，因此在当下创建的进程都为子进程，又因子进程在创建时会继承父进程的文件描述符，因此创建一个进程后文件描述符会从3开始。
使用dup重定向：函数原型 int dup(int oldfd)
例：关闭1号文件描述符（标准输出），本应将标准输入的内容打印到标准输出上，重定向到了log文件中
1 #include2 #include 3 #include 4 #include 5 #include 6 #include 7 #include 8 9 int main() 10 { 11 int fd=open("./log",O_CREAT|O_RDWR,0644); 12 if(fd<0) 13 { 14 perror("open"); 15 exit(1); 16 } 17 close(1); //必须关闭要重定向的文件描述符 18 int newfd=dup(fd); 19 if(newfd <0) 20 { 21 perror("dup"); 22 exit(2); 23 }
24 char buf[1024];
25
26 while(1)
27 {
28 memset(buf,'\0',sizeof(buf));
29 fgets(buf,sizeof(buf),stdin);
30 if((strncmp("quit",buf,4))==0)
31 {
32 break;
33 }
34 printf("%s\n",buf);
35 //printf("hello world\n");
36 fflush(stdout);
37 }
38 close(newfd);
39
40 return 0;
41 }
输入内容：
重定向到log文件中内容
int dup2(int oldfd,int newfd)
1 #include2 #include 3 #include 4 #include 5 #include 6 #include 7 #include 8 9 int main() 10 { 11 int fd=open("./log",O_CREAT|O_RDWR,0644); 12 if(fd<0) 13 { 14 perror("open"); 15 exit(1); 16 } 17 close(1); //可以不必关闭1号文件描述符 18 int newfd=dup2(fd,1); 19 if(newfd <0) 20 { 21 perror("dup"); 22 exit(2); 23 }
24 char buf[1024];
25 while(1)
26 {
27 memset(buf,'\0',sizeof(buf));
28 fgets(buf,sizeof(buf),stdin);
29 if((strncmp("quit",buf,4))==0)
30 {
31 break;
32 }
33 printf("%s",buf);
34 //printf("hello world\n");
35 fflush(stdout);
36 }
37 close(newfd);
38
39 return 0;
40 }
41输入内容：
log文件中内容：
