溫馨提示×

溫馨提示×

您好，登錄后才能下訂單哦！

密碼登錄×
登錄注冊×
其他方式登錄
點擊 登錄注冊 即表示同意《億速云用戶服務條款》

unix 無關(guān)系進程間通信-有名管道

發(fā)布時間：2020-07-03 00:54:12 來源：網(wǎng)絡 閱讀：502 作者：xieyihua 欄目：系統(tǒng)運維
  1. 有名管道是專用于無關(guān)系進程間的通信
  2. open("../share_fifo", O_RDONLY, 777); 這個以只讀打開有名管道，會產(chǎn)生阻塞,直到有其它進程以寫打開才會繼續(xù)執(zhí)行下去
  3. open("../share_fifo", O_RDONLY|O_NONBLOCK, 777); 這個以只讀且注明以非阻塞打開，open不會產(chǎn)生阻塞，導致read()函數(shù)對有無數(shù)據(jù)讀完即離開
  4. open(fifo,O_WRONLY, 777) 阻塞到其它進行以讀打開這個管道
  5. open(fifo,O_WRONLY|O_NONBLOCK, 777) 沒有阻塞，如果沒有其它進行以讀打開管道會立即返回報錯-1 ENXIO
  6. 寫一個無讀打開的管道會產(chǎn)生一個信號 SIGPIPE，可以捕捉以信號來進行后續(xù)處理
  7. 此例程，功能為一個服務進程 與 多個客戶進程之間的通信
  8. 程序還需要進行一步完美

server.c

  1. #include <stdlib.h> 
  2. #include <sys/types.h> 
  3. #include <sys/stat.h> 
  4. #include <fcntl.h> 
  5. #include <unistd.h> 
  6. #include <limits.h> 
  7. #include <string.h> 
  8. #include <stdbool.h> 
  9. #include <stdio.h> 
  10. #include <stdlib.h> 
  11.  
  12. #define MAXLINE 100 
  13.  
  14. pid_t str_handler(char*); 
  15. void handler_client_corrupt(int); 
  16. static char* itoa(int);//因為itoa是一個非標準C函數(shù)，因此需要自己定義 
  17. void del_fifo(void);//退出時將管道刪除 
  18.  
  19. int main() 
  20. { 
  21.         int fd; 
  22.         int count = 10; 
  23.         int BUF_SIZE; 
  24.         pid_t client_id; 
  25. //注冊 程序退出時執(zhí)行刪除管道 
  26.       if(atexit(del_fifo)) 
  27.       { 
  28.             perror("atexit\n"); 
  29.             exit(1);          
  30.       } 
  31. #if 1 
  32. // 創(chuàng)建一個客戶端到服務器共享有命管道,此管道必需不存在  
  33.         if(0 != mkfifo("../share_fifo", 0777 )) 
  34.         { 
  35.                 perror("mkfifo\n"); 
  36.                 exit(1); 
  37.         } 
  38.         fputs("share_fifo has been created\n",stdout); 
  39. #endif 
  40. //打開管道并設置只讀 
  41.         fd = open("../share_fifo", O_RDONLY, S_IRUSR|S_IRGRP|S_IROTH); 
  42.          if(fd<0) 
  43.         { 
  44.                 perror("open\n"); 
  45.                 exit(1);                
  46.         }  
  47. //初始化緩存數(shù)組 
  48.         (MAXLINE > PIPE_BUF) ?  (BUF_SIZE = PIPE_BUF) :  (BUF_SIZE = MAXLINE); 
  49.         //原子操作寫進fifo最大數(shù)據(jù)量，若超過會導致進行間的竟爭 MAXLINE < PIPE_BUFPIPE_BUF = 4096 
  50.         //#define PIPE_BUF     4096 
  51.         //usr/lib/limits.h 
  52.         char buf[BUF_SIZE]; 
  53.         memset(buf, sizeof(buf), 0); 
  54. //讀取數(shù)據(jù)并進行處理 
  55.         while(20) 
  56.         {      
  57. //讀客戶端發(fā)來的信息內(nèi)容，并沖洗標準輸入出進行顯示 
  58.                 int num;   
  59.                 num = read(fd, buf, BUF_SIZE); 
  60.                 if(-1 == num) 
  61.                 { 
  62.                         perror("read\n"); 
  63.                         exit(1);                       
  64.                 } 
  65.                 fputs(buf,stdout); 
  66.                 //由于標準輸出需要遇到換行符“\n”才會進行顯示，而收到內(nèi)容中沒有換行符，使此函數(shù)進行沖洗顯示 
  67.                 putchar('\n'); 
  68.                  
  69. //回復客戶端，并對回復的內(nèi)容進行處理                
  70.                 client_id = str_handler(buf); 
  71.                  
  72.                 //處理回復內(nèi)容字符串 
  73.                 char str[100] = "receided successfully:"; 
  74.                 strcat(str,itoa(client_id)); 
  75.                 int len = strlen(str); 
  76.                 char str_reply[len+1]; 
  77.                 strcpy(str_reply, str); 
  78.                  
  79.                 //處理客戶端路徑 
  80.                 char tmp[100]= "../"; 
  81.                 strcat(tmp,itoa(client_id)); 
  82.                 len = strlen(tmp); 
  83.                 char path[len+1]; 
  84.                 strcpy(path,tmp); 
  85.             
  86.                 //打開對應客戶端的管道進行寫操作 
  87.                 int cfd = open(path,O_WRONLY, S_IWUSR|S_IWGRP); 
  88.                 if(cfd<0) 
  89.                 { 
  90.                         perror("open_1\n"); 
  91.                         exit(1);                
  92.                 } 
  93.                 //回復對應的客戶端             
  94.                 if(write(cfd, str_reply, (strlen(str_reply)+1) ) == -1) 
  95.                 { 
  96.                         perror("write\n"); 
  97.                         exit(1);                
  98.                 } 
  99.                 //寫完后關(guān)閉對應的管道 
  100.                 if(close(cfd)) 
  101.                 { 
  102.                         perror("close\n"); 
  103.                         exit(1);                   
  104.                 } 
  105.                 sleep(1); 
  106.         } 
  107.       if(close(fd)) 
  108.       { 
  109.             perror("close\n"); 
  110.             exit(1);                   
  111.       }        
  112.         
  113.         return 0; 
  114. } 
  115.  
  116.  
  117. pid_t str_handler(char*buf) 
  118. { 
  119.         pid_t tmp;  
  120.         int len = strlen(buf); 
  121.          
  122.         tmp = atoi(buf); 
  123.         printf("len :%d tmp:%d,buf:%s\n",len,tmp,buf); 
  124.         if( (tmp == 0) || (tmp < 0) ) 
  125.         { 
  126.                 return -1; 
  127.         } 
  128.         return tmp; 
  129. } 
  130.  
  131. static char* itoa(int i) 
  132. { 
  133.       char * local =  (char*) malloc(10); 
  134.       memset(local,10,0); 
  135.       sprintf(local,"%d",i); 
  136.       return local; 
  137. } 
  138.  
  139.  
  140.  
  141. void del_fifo(void) 
  142. { 
  143.       if(remove("../share_fifo")) 
  144.       { 
  145.             perror("remove\n"); 
  146.             exit(1);     
  147.       } 
  148. } 


client.c

  1. #include <unistd.h> 
  2. #include <stdio.h> 
  3. #include <string.h> 
  4. #include <stdlib.h> 
  5. #include <sys/types.h> 
  6. #include <sys/stat.h> 
  7. #include <fcntl.h> 
  8.  
  9. #define MAXLINE 100 
  10. char buf[MAXLINE]; 
  11.  
  12. char tmp[100]= "../"; 
  13. char* path; 
  14.  
  15. static char* itoa(int i) 
  16. { 
  17.       char * local =  (char*) malloc(10); 
  18.       memset(local,10,0); 
  19.       sprintf(local,"%d",i); 
  20.       return local; 
  21. } 
  22.  
  23. void del_fifo(void) 
  24. { 
  25.       if(remove(path)) 
  26.       { 
  27.             perror("remove\n"); 
  28.             exit(1);     
  29.       } 
  30. } 
  31.  
  32.  
  33. int main(int argc, char** argv) 
  34. { 
  35.       int fd0 , fd1; 
  36.        
  37.       int len; 
  38.             
  39.       strcat(tmp,itoa(getpid())); 
  40.       len = strlen(tmp); 
  41.       char tmp_path[len+1]; 
  42.       strcpy(tmp_path,tmp); 
  43.       path = tmp_path; 
  44.             
  45.       if(0 != mkfifo(path, 0777 )) 
  46.       { 
  47.             perror("mkfifo\n"); 
  48.             exit(1); 
  49.       }   
  50.        
  51.  #if 0         
  52.       fd0 = open("../client0", O_RDONLY, S_IRUSR|S_IRGRP); 
  53.       if(fd0<0) 
  54.       { 
  55.             perror("open_0\n"); 
  56.             exit(1);                
  57.       }       
  58. #endif        
  59.     //處理回復內(nèi)容字符串 
  60.     
  61.     char str[10]; 
  62.     memset(str,10,0); 
  63.     strcpy(str,itoa(getpid())); 
  64.     len = strlen(str); 
  65.     char str_send[len+1]; 
  66.     strcpy(str_send, str); 
  67.     printf("%s\n",str_send); 
  68.      
  69.        fd1 = open("../share_fifo", O_WRONLY, S_IWUSR|S_IWGRP); 
  70.       if(fd1<0) 
  71.       { 
  72.             perror("open_1\n"); 
  73.             exit(1);                
  74.       } 
  75.  
  76.       fd0 = open(path, O_RDONLY|O_NONBLOCK, S_IRUSR|S_IRGRP); 
  77.       if(fd0<0) 
  78.       { 
  79.             perror("open_0\n"); 
  80.             exit(1);                
  81.       } 
  82.              
  83.     int count = 10; 
  84.       while(count--) 
  85.       { 
  86.  
  87.             if(write(fd1, str_send, (strlen(str_send)+1) ) == -1) 
  88.             //if(write(fd1, "test\n", 5 ) == -1) 
  89.             { 
  90.                   perror("write\n"); 
  91.                   exit(1);                
  92.             } 
  93.             fputs("write complete\n",stdout);   
  94.           #if 0   
  95.             if(close(fd1)) 
  96.             { 
  97.                   perror("close\n"); 
  98.                   exit(1);                   
  99.             }   
  100.           #endif   
  101.             while(read(fd0, buf, MAXLINE)<=0); 
  102.             printf("%s\n",buf);  
  103.             sleep(1);   
  104.              
  105.       } 
  106.       return 0; 
  107. } 

 

附件：http://down.51cto.com/data/2362203
向AI問一下細節(jié)

免責聲明：本站發(fā)布的內(nèi)容（圖片、視頻和文字）以原創(chuàng)、轉(zhuǎn)載和分享為主，文章觀點不代表本網(wǎng)站立場，如果涉及侵權(quán)請聯(lián)系站長郵箱：is@yisu.com進行舉報，并提供相關(guān)證據(jù)，一經(jīng)查實，將立刻刪除涉嫌侵權(quán)內(nèi)容。

AI
助
手