zoukankan      html  css  js  c++  java
  • 【转】php进程间通信--有名管道

    原文: https://www.cnblogs.com/nickbai/articles/6125491.html

    ----------------------------------------------

    php进行进程间通信的方式有好几种:消息队列,管道,共享内存,socket,信号。本文介绍的是通过有名管道的方式。  

      管道PIPE

      管道用于承载简称之间的通讯数据。为了方便理解,可以将管道比作文件,进程A将数据写到管道P中,然后进程B从管道P中读取数据。php提供的管道操作API与操作文件的API基本一样,除了创建管道使用posix_mkfifo函数,读写等操作均与文件操作函数相同。当然,你可以直接使用文件模拟管道,但是那样无法使用管道的特性了。

      通过管道通信的大概思路是,首先创建一个管道,然后子进程向管道中写入信息,父进程从管道中读取信息,这样就可以做到父子进程直接实现通信了。

      代码如下:

    复制代码
     1 <?php
     2 /**
     3  * author: NickBai
     4  * createTime: 2016/12/2 0002 上午 11:12
     5  */
     6 //创建管道
     7 $pipePath = "/tmp/test.pipe";
     8 if( !file_exists( $pipePath ) ){
     9     if( !posix_mkfifo( $pipePath, 0666 ) ){
    10         exit('make pipe false!' . PHP_EOL);
    11     }
    12 }
    13 
    14 //创建进程,子进程写管道,父进程读管道
    15 $pid = pcntl_fork();
    16 
    17 if( $pid == 0 ){
    18     //子进程写管道
    19     $file = fopen( $pipePath, 'w' );
    20     fwrite( $file, 'hello world' );
    21     sleep(1);
    22     exit();
    23 }else{
    24     //父进程读管道
    25     $file = fopen( $pipePath, 'r' );
    26     //stream_set_blocking( $file, False );  //设置成读取非阻塞
    27     echo fread( $file, 20 ) . PHP_EOL;
    28 
    29     pcntl_wait($status);  //回收子进程
    30 }
    复制代码
      注意:本代码只能在linux下运行,并且只能在php-cli模式下。

      第7行:指定一个管道的路径,这里跟普通文件没什么区别。

      第9行:通过 posix_mkfifo 函数创建 管道 并且设置读写权限为 0666

      第15行:通过 pcntl_fork函数创建一个子进程。注意从现在开始,程序将会被分成两个进程来执行。 pcntl_fork 函数 很特殊,它调用一次拥有 多个返回值。在父进程中:它返回 子进程的ID 这个值是 大于0 的。在子进程中,它返回0。当返回 -1 时表示

    创建进程失败。

         第17行:两个进程根据当前进程所获得的$pid的值不同,而进入不同的分支。

       第18~22行:子进程打开管道,并向其中写入hello world ,然后进入休眠,休眠结束之后,退出。

       第25~29行:父进程打开管道,并进行读取,最后执行 29行的代码回收掉子进程。这里面两个地方是阻塞的,首先是默认读的地方,要等待子进程发出exit命令之后,才能返回数据。还有就是回收进程的 pcntl_wait方法。要等到进程退出。

       在linux 下运行该代码:

      会看到程序阻塞 1秒 之后,输出 hello world。

      当我们打开 第 26 行代码,并将 27行改为 var_dump(fread( $file, 20 )) . PHP_EOL; 时,运行程序:

      能看到程序立马输出 空串,并等待 1秒 中之后退出。这是因为。当读取是非阻塞的情况下,父进程进行读取信息的时候,不会等待立马有信息,管道中没有信息,也会立马返回。然后执行到 29行回收子进程的时候,阻塞等待子进程退出后结束。

      

      下面来看一个简单的实际小例子。两个子进程向一个文件中写信息,父进程负责监听检测这个文件是否写入完成,完成之后,讲这个文件copy一份。这里,父子进程之间通过管道通信,确认是否完成写入。

    复制代码
     1 <?php
     2 /**
     3  * author: NickBai
     4  * createTime: 2016/12/2 0002 下午 2:00
     5  */
     6 //创建管道
     7 $pipePath = "/tmp/test.pipe";
     8 if( !file_exists( $pipePath ) ){
     9     if( !posix_mkfifo( $pipePath, 0666 ) ){
    10         exit("make pipe fail 
    ");
    11     }
    12 }
    13 
    14 //创建两个子进程写文件
    15 for( $i = 0; $i < 2; $i++ ){
    16 
    17     $pid = pcntl_fork();
    18     if( $pid == 0 ){
    19         file_put_contents( './pipe.log', $i . " write pipe
    ", FILE_APPEND );  //写入文件
    20         $file = fopen( $pipePath, 'w' );
    21         fwrite( $file, $i . "
    " );  //向管道中写标识,标识写入完毕。
    22         fclose( $file );
    23         exit();  //退出子进程
    24     }
    25 }
    26 
    27 //父进程要做的是:
    28 //1、读取管道中的写出状态,判断是否完全写完
    29 //2、拷贝写好的文件
    30 //3、删除管道
    31 //4、回收进程
    32 
    33 $file = fopen( $pipePath, 'r' );
    34 $line = 0;
    35 while(1){
    36     $end = fread( $file, 1024 );
    37     foreach( str_split( $end ) as $c) {
    38         if ( "
    " == $c ) {
    39             $line++;
    40         }
    41     }
    42 
    43     if( $line == 2 ){
    44         copy( './pipe.log', './pipe_copy.log' );
    45         fclose( $file );
    46         unlink( $pipePath );
    47         pcntl_wait( $status );
    48         exit("ok 
    ");
    49     }
    50 }
    复制代码
  • 相关阅读:
    java实验报告三
    学术论文撰写准备事项整理
    mac终端下运行shell脚本
    关于1*1卷积核的理解
    车牌识别项目的准备思路
    快捷键备忘
    跑caffe过程中的备忘
    caffe中全卷积层和全连接层训练参数如何确定
    从零开始足球战术分析
    卷积与反卷积以及步长stride
  • 原文地址:https://www.cnblogs.com/oxspirt/p/14188648.html
Copyright © 2011-2022 走看看